? 所屬類

com.rabbitmq.client.ConnectionFactory

---

🧠 使用背景

RabbitMQ Java 客戶端默認使用傳統的 阻塞 I/O (java.net.Socket) 實現。如果你希望：

• 更好地控制 線程數
• 獲得更好的 并發性能
• 降低 每個連接的線程占用
• 在高并發連接或消費者數量較多的系統中提升擴展性

那么可以使用：

factory.useNio();

這會切換到底層的 Netty-like 異步 NIO 通信方式。

---

? 基本用法示例

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.useNio(); // 啟用 NIO 模式ExecutorService executor = Executors.newFixedThreadPool(4);
Connection connection = factory.newConnection(executor);

---

🔍 工作機制對比

模式	模型	特點
默認（阻塞 IO）	每個連接或信道對應 1+ 個線程	簡單直觀，但線程資源消耗大
NIO 模式	多連接共享 I/O selector	更少線程，支持更多連接，更適合高并發

---

🚨 注意事項

注意點	描述
必須與自定義線程池搭配使用	啟用 NIO 后必須通過 newConnection(executor) 傳入線程池
更復雜的調試	異步通信更難調試，日志和堆棧信息更間接
不兼容舊版客戶端	useNio() 在 RabbitMQ Java 客戶端 5.x 以上版本才支持

---

📦 示例封裝

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.useNio();ExecutorService executor = Executors.newCachedThreadPool();
Connection connection = factory.newConnection(executor);

---

? 總結

項目	說明
方法	factory.useNio()
作用	啟用非阻塞 I/O 模式，提升并發性能和連接擴展性
適用場景	高并發、微服務、高密度連接、容器環境等
要求	必須配合自定義線程池使用