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

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

因为项目中用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。这些处理都很有实站参考价值。