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

  • Post author:
  • Post category:java


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

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

另外注册nio操作的时候,一般

attach参数

是一个持有socketChannel的对象,一般demo中直接用socketChannel读写,但实际上一般要先处理后,再读写的。

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

代码多了也记不住,仅画一个图:分别体现了

运行状态



构建运行状态的主要操作

**运行状态图:**来源于框架的要实现的功能,可以从作者提供的

示例

作为入口进行功能跟踪。

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。这些处理都很有实站参考价值。



版权声明:本文为m0_66557301原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。