RocketMQ客户端源码分析-底层通信

RocketMQ客户端全部与NameServer和Broker的通信都是经过MQClientAPIImpl完成的。 MQClientAPIImpl包含一个NettyRemotingClient,使用netty实现。 在启动MQClientAPIImpl时,会启动NettyRemotintClient,设置通信时的线程池以及pipeline。web pipeline NettyEncoder Net
相关文章
相关标签/搜索