---

🧩 一、核心定位：什么是 TcpCommunicationSpi？

/*** <tt>TcpCommunicationSpi</tt> is default communication SPI which uses* TCP/IP protocol and Java NIO to communicate with other nodes.*/

翻譯：TcpCommunicationSpi 是默認的通信 SPI，使用 TCP/IP 協議和 Java NIO 與其他節點通信。

? 關鍵點：

• 它是 Ignite 集群中節點間通信的底層引擎。
• 使用 TCP 長連接 + Java NIO（非阻塞 I/O） 實現高性能、可靠的數據傳輸。
• 所有消息（緩存更新、計算任務、事務、心跳等）都走這個通道。

---

🌐 二、節點發現與屬性注入

 * This SPI adds {@link #ATTR_ADDRS} and {@link #ATTR_PORT} local node attributes...

翻譯：該 SPI 會向本地節點添加兩個屬性：IP 地址列表（ATTR_ADDRS）和端口（ATTR_PORT），其他節點可以通過 ClusterNode.attributes() 獲取。

? 作用：

• 其他節點通過 Discovery SPI（如 TcpDiscoverySpi）發現新節點時，能知道它監聽的 IP 和端口。
• 實現自動連接，無需手動配置每個節點的地址。

📌 示例：

for (ClusterNode node : ignite.cluster().nodes()) {String ip = node.attribute(TcpCommunicationSpi.ATTR_ADDRS);int port = node.attribute(TcpCommunicationSpi.ATTR_PORT);System.out.println("Node: " + ip + ":" + port);
}

---

🔌 三、端口綁定與自動遞增

 * At startup, this SPI tries to start listening to local port specified by setLocalPort(int).* If local port is occupied, then SPI will automatically increment the port number...* setLocalPortRange(int) controls maximum number of ports that SPI will try before it fails.

翻譯：啟動時嘗試綁定指定端口，如果被占用，則自動 +1 嘗試，最多嘗試 localPortRange 次。

? 設計目的：

• 支持單機多節點部署（比如開發測試或容器環境）。
• 無需手動為每個節點分配不同端口。

📌 示例：

commSpi.setLocalPort(47100);           // 起始端口
commSpi.setLocalPortRange(100);        // 最多嘗試 100 個端口（47100~47199）

?? 生產建議：固定端口范圍，便于防火墻策略和運維監控。

---

🔁 四、連接緩存與空閑超時

 * This SPI caches connections to remote nodes... idle connections are kept active for DFLT_IDLE_CONN_TIMEOUT...* Use setIdleConnectionTimeout(long) to configure.

翻譯：SPI 會緩存到遠程節點的連接，默認空閑一段時間后關閉（默認 60 秒）。

? 為什么這么做？

• 避免頻繁建立/斷開 TCP 連接（開銷大）。
• 但也不能無限保持連接（浪費資源）。

📌 建議：

• 高并發場景：可適當增大超時時間（如 300 秒），減少連接重建。
• 資源緊張環境：可減小超時，及時釋放資源。

---

🚨 五、故障檢測機制（Failure Detection）

這是最重要的一段！

 * Configuration defaults... are chosen to make possible for communication SPI work reliably...* but this has made failure detection time worse.

翻譯：默認配置為了“穩定運行”而犧牲了“故障檢測速度”。

1. 推薦方式：使用 failureDetectionTimeout

 * It's highly recommended to do this using IgniteConfiguration.setFailureDetectionTimeout(long)

• 這是一個高層超時設置，會自動影響底層多個參數：
  • 連接超時（connectTimeout）
  • 最大重連超時（maxConnectTimeout）
  • 重連次數（reconnectCount）

📌 示例：

IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setFailureDetectionTimeout(10_000); // 10秒內檢測失敗

? 最佳實踐：優先設置 failureDetectionTimeout，不要手動設置底層參數。

2. 高級調優（不推薦）

 * If advanced settings are required... various TcpCommunicationSpi parameters may be used.

• 只有在 failureDetectionTimeout 不夠用時才手動調這些：
  • setConnectTimeout(2000)
  • setMaxConnectTimeout(60000)
  • setReconnectCount(10)

?? 警告：手動設置這些參數會覆蓋 failureDetectionTimeout 的自動計算！

---

?? 六、配置參數詳解（Optional）

文檔列出了大量可選參數，我們分類總結：

類別	參數	建議
網絡地址	setLocalAddress()	多網卡時必須設置
端口	setLocalPort(), setLocalPortRange()	生產建議固定范圍
連接管理	setConnectionsPerNode(2)	提升并發吞吐
性能優化	setTcpNoDelay(true)	禁用 Nagle，降低小消息延遲
	setSocketReceiveBuffer(512*1024)	增大緩沖區提升吞吐
	setDirectBuffer(true)	使用堆外內存減少 GC
NIO 調優	setSelectorsCount(4)	NIO 選擇器線程數（通常 = CPU 核數）
消息控制	setMessageQueueLimit(0)	0 表示無限制（防丟包）
	setAckSendThreshold(32)	每 32 條消息發一次 ACK，減少網絡開銷
安全	setSharedMemoryPort(-1)	生產環境禁用共享內存

---

🛠? 七、Java 和 Spring 配置示例

? Java 配置

TcpCommunicationSpi commSpi = new TcpCommunicationSpi();
commSpi.setLocalPort(4321); // 覆蓋默認端口IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setCommunicationSpi(commSpi);Ignition.start(cfg);

💡 注意：只有需要覆蓋默認值時才需要顯式配置，否則用默認即可。

? Spring XML 配置

<bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"><property name="communicationSpi"><bean class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi"><property name="localPort" value="4321"/></bean></property>
</bean>

📌 Spring 用戶可以通過 XML 統一管理配置。

---

📌 八、關鍵總結與最佳實踐

項目	建議
是否必須配置	? 否，有合理的默認值
生產環境必須設置	? localAddress, localPort, failureDetectionTimeout
性能調優重點	? tcpNoDelay=true, connectionsPerNode=2, socketBuffer=512K+
故障檢測	? 優先使用 failureDetectionTimeout
避免手動設置	? connectTimeout, maxConnectTimeout, reconnectCount（除非高級需求）
單機多節點	? 利用 localPortRange 自動遞增
監控	? 使用 commSpi.getMetrics() 查看連接、吞吐、延遲

---

🎯 一句話理解全文

TcpCommunicationSpi 是 Ignite 的“神經網絡”：

• 它自動建立 TCP 連接，緩存連接，處理消息收發。
• 默認配置追求“穩定”，但故障檢測較慢。
• 生產環境應通過 failureDetectionTimeout 統一調優，并適當優化緩沖區和連接數。
• 你不需要手動管理連接，但需要理解它的行為來避免性能瓶頸。

---