RocketMQ客戶端源碼分析-底層通信

RocketMQ客戶端全部與NameServer和Broker的通信都是經過MQClientAPIImpl完成的。 MQClientAPIImpl包含一個NettyRemotingClient,使用netty實現。 在啓動MQClientAPIImpl時,會啓動NettyRemotintClient,設置通信時的線程池以及pipeline。web pipeline NettyEncoder Net
相關文章
相關標籤/搜索