[一]RabbitMQ-客户端源码之ConnectionFactory

首先看一段amqp-client发送端的示例代码（展示出主要部分）：

相信使用rabbitmq java客户端的同学来说，这段代码并不陌生，主要的作用是发送一条消息至broker然后关闭。通过wireshark抓包工具可以看到整个AMQP协议的流程，如下图：

（10.101.48.240是client的ip，10.198.197.73是broker的ip）

下面通过源码来分析下Connection有关的整个流程，对于上面AMQP流程中的Protocol-Header到Connection.Open-Ok的部分。

首先是ConnectionFactory类(文章开篇的demo中)，这里主要包含一些与broker连接的配置参数等,比如：username, password, virtualHost, host,port, requestedChannelMax, requestedFrameMax, requestedHeartbeat, connectionTimeout, shutdownTimeout（只列出部分）。

这个类中其余都是些Getter和Setter方法，但是有个newConnection方法是关键，文中开篇的demo代码下面列出详细内容：

方法中首先是FrameHandlerFactory fhFactory = createFrameHandlerFactory();这个是用来处理client与broker之间的通信帧（Frame）的，包括建立通信链路（java的原生socket，注意这里没有NIO也没有netty）。

调用createFrameHandlerFactory()方法得到FrameHandlerFactory对象之后再：“ FrameHandler handler = fhFactory.create(addr);”返回的是SocketFrameHandler对象，这个对象是对Socket的一个封装，完全可以看成是一个Socket对象。

注意这里的Socket的TCP_NODELAY参数默认设置为true,而不是默认的false。当然你也可以调用ConnectionFactory的setSocketConfigurator自行设置。

有关Socket的TCP_NODELAY参数：默认情况下发送数据是采用Negale算法。Negale算法是指发送方数据不会立刻发送出去，而是先放在缓冲区内，等待缓冲区满了，在发出去。Negale算法适用于需要发送大量数据的应用场景。这种算法减少传输的次数增加性能。但是如果对于需要即使响应的，小批量数据的应用场景，例如网络游戏就不能采用Negale算法了。默认是false,表示采用Negale算法。

ConnectionParams 主要用来配置与broker连接相关的参数，比如username,password,vhost等。这个与前面Socket的参数不同，需要注意区分。

之后if(isAutomaticRecoveryEnabled()){}之内的方法是建立可自动恢复连接的，这个可以忽略，直接看else里面的代码，因为if和else大体功能上一致，else里的更通用一些，也是默认的。上面提到 FrameHandler handler = fhFactory.create(addr);这段代码返回的是SocketFrameHandler对象，之后： AMQConnection conn = new AMQConnection(params, handler);这句通过参数和Socket与broker建立连接。之后初始化：conn.start();完成之后客户端就已经和broker建立了正常的连接了.

<a href="http://blog.csdn.net/u013256816/article/details/70214929">[Conclusion]RabbitMQ-客户端源码之总结</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214708">[一]RabbitMQ-客户端源码之ConnectionFactory</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214730">[二]RabbitMQ-客户端源码之AMQConnection</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214754">[三]RabbitMQ-客户端源码之ChannelManager</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214776">[四]RabbitMQ-客户端源码之Frame</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214791">[五]RabbitMQ-客户端源码之AMQChannel</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214811">[六]RabbitMQ-客户端源码之AMQCommand</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214835">[七]RabbitMQ-客户端源码之AMQPImpl+Method</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214863">[八]RabbitMQ-客户端源码之ChannelN</a>

<a href="http://blog.csdn.net/u013256816/article/details/70214903">[九]RabbitMQ-客户端源码之Consumer</a>