rabbitmq-java-client源码结构设计与分析

骑猪看日落 2023-09-29 08:47 23阅读 0赞

本文减少代码展示，重点是理解整体类关系与结构的设计。

因为项目中用rabbitmq，特意了解一下客户端代码。它使用nio的方式也很典型，它并没有使用netty等间接使用nio，毕竟服务端是Erlang开发的，数据传输的结构简单。它使用两个Selector.open()产生的两个selector，分别处理读写的操作注册。写的数据放在一个state的队列中，循环队列注册写操作，并从队列取数据来写。

另外注册nio操作的时候，一般attach参数是一个持有socketChannel的对象，一般demo中直接用socketChannel读写，但实际上一般要先处理后，再读写的。

nio是低层，至于给用户用的connection是统一读写用，毕竟客户端只是一个socketChannel，而用户的channel是编号的，给用户的独立线程使用的，最终还是通过connection进行读写。

代码多了也记不住，仅画一个图：分别体现了运行状态 与 构建运行状态的主要操作。

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaGVycmltYW4_size_20_color_FFFFFF_t_70_g_se_x_16][]

运行状态图： 来源于框架的要实现的功能，可以从作者提供的示例作为入口进行功能跟踪。

ConnectionFactory factory = new ConnectionFactory();  
...  
Connection conn = factory.newConnection();  
这里最终就是通过nio（实际上支持非nio，SSL也可选）发送（接收）消息或者命令。

客户层的发送与接收与传输层的发送接收不一样，中间一般有一个中介，这里就是frameHandler。  
客户端因为多线程，所以要统一到一个处理类。所以有channel（非socketChannel）与connection。  
发送一般要消峰填谷，使用队列与异步线程。但nio底层使用注册读写操作多路复用，所以用不上线程池。  
接收一般就是轮询机制，再考虑分配给客户的多个channel，所以必然有dispatch。  
通过以上分析，差不多就整理出一个运行时状态图。

构建运行状态：源于对上述运行中的类的创建、初始化、关联起来。按上述运行中的引用关系创建，不是一个new就能说明，所以一般都要有工厂。

connection的具体功能，要通过中介frameHandler实现，所以创建connection时，先创建frameHandler。  
而创建frameHandler前，要建好读写的注册的声明，还要让nio轮询起来，处理读写声明。有点类似于发动机先转起来，设置好引用后，一挂档（放入声明）就处理起来。  
nio的select出来的key，因为Socketchannel只是底层的读写，所以一般用一个持有Socketchannel的上层处理类，作为注册读写的attach。这样一但读写条件准备好了，上层处理类先处理数据对象的转换或者序列化之类的，再用Socketchannel真正收发数据。  
总的来说，rabbitmq-client源码还有很多特点，比如使用nio或bio，使用ssl或者非ssl，使用nio的读写分开的selector。这些处理都很有实站参考价值。  
————————————————  
版权声明：本文为CSDN博主「herriman」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。  
原文链接：https://blog.csdn.net/herriman/article/details/123885741

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaGVycmltYW4_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/c96985c9d0f14e2195c76a9cae0616f9.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAaGVycmltYW4=,size_20,color_FFFFFF,t_70,g_se,x_16