中间件系列九 RabbmtiMQ 通过wireshark抓包学习AMQP协议

谁借莪１个温暖的怀抱￠ 2022-05-31 04:13 550阅读 0赞

## 1. 概述 ##

本文先在普通场景下生产者发送一条消息，消费者接受此条消息，然后通过wireshark进行抓包，对抓的包进行详细的分析。

## 2. 背景 ##

### 3.1. 本文测试的环境 ###

RabbitMQ的IP地址是10.240.89.147  
生产者和消费者的IP地址都是10.240.80.99

### 3.2. 测试的代码 ###

本文的代码和之前博客的代码相似，这里略  
相关的代码内容如下：  
**生产者代码**：[NoPublisherConfirmSend.java][]  
**消费者代码**：[PublisherConfirmRecv.java][]  
**测试代码**：[PublisherConfirmTest.java][]  
发送端先发送1条消息，消费者接收消息

// 发送端
    executorService.submit(() -> { NoPublisherConfirmSend.execute(rabbitmq_host, rabbitmq_user, rabbitmq_pwd, routingKey,1); }); Thread.sleep(5* 100); // 接收端 executorService.submit(() -> { PublisherConfirmRecv.execute(rabbitmq_host, rabbitmq_user, rabbitmq_pwd, routingKey); }); Thread.sleep(5* 100);

## 4. 生产者发送消息的包分析 ##

### 4.1. 所有包的截图 ###

![这里写图片描述][SouthEast]

下方对包进行详细描述

### 4.2. 109-110帧 : TCP的建立连接的三次握手 ###

TCP的建立连接的三次握手，关于TCP的基本信息可以参考之前的文章

### 4.3. 112-113帧：RabbitMQ的客户端告诉RabbitMQ自己使用的协议及版本 ###

**112帧**：RabbitMQ的客户端告诉RabbitMQ自己使用的协议及版本  
![这里写图片描述][SouthEast 1]  
**113帧**：TCP应答信令：表示服务端告诉发送端已经收到这之前的包

### 4.4. 114 - 122：RabbitMQ服务端和客户端建立连接，并约定参数 ###

**114帧 Connection.Start**：RabbitMQ告诉客户端通信的协议和版本、SASL认证机制(详细见)、语言环境以及RabbitMQ的版本信息和支持能力  
![这里写图片描述][SouthEast 2]

**117帧 Connection.Start-Ok** ：客户端带上连接使用的帐号和密码、认证机制、语言环境、客户的信息以及能力  
![这里写图片描述][SouthEast 3]

**118帧 Connection.Tune**：RabbitMQ服务端和客户端开始进行参数协商  
![这里写图片描述][SouthEast 4]

**119帧 Connection.Tune-Ok**: 客户端要么接受服务端过来的参数，要么将这些值变低，在发送给服务端  
![这里写图片描述][SouthEast 5]

**120帧 Connection.Open vhost=/** ：RabbbitMQ客户端打开一个连接，并请求设置vhost值  
![这里写图片描述][SouthEast 6]  
**121帖 TCP应答**  
**122帖 Connection.Open-Ok**：RabbitMQ服务端对vhost进行验证，如果成功，则返回如下此信息  
![这里写图片描述][SouthEast 7]

### 4.5. 123 - 124：创建通道 ###

**123帧 Channel.Open**：客户端打开一个新通道  
![这里写图片描述][SouthEast 8]

**124帧Channel.Open-Ok**：RabbitMQ服务端回复新通道准备完毕  
![这里写图片描述][SouthEast 9]

### 4.6. 125 - 126帧： 创建Exchange ###

**125帧 Exchange.Declare** 客户端向RabbitMQ声明一个Exchange  
![这里写图片描述][SouthEast 10]

**126帧 Exchange.Declare-Ok**：RabbitMQ收到请求后，如果发现同名的exchange存在且属性相同，则返回如下包，否则抛出异常  
![这里写图片描述][SouthEast 11]

### 4.7. 127帧 Basic.Publish 客户端开始发送消息 ###

![这里写图片描述][SouthEast 12]

在这里客户端只管发送消息，而不关心消息是否正确到达RabbitMQ

### 4.8. 128 - 132 帧：关闭通关，关闭连接，回收 资源 ###

**128 帧 Channel.Close**：客户端请求关闭通道  
![这里写图片描述][SouthEast 13]

**129帧 ACK应答**  
**130帧 Channel.Close-Ok**：RabbitMQ关闭通关，并应答  
![这里写图片描述][SouthEast 14]

**131帧 Connection.Close**：客户端请求关闭连接  
![这里写图片描述][SouthEast 15]

**132帧 Connection.Close-Ok**：RabbitMQ关闭连接，并应答  
![这里写图片描述][SouthEast 16]

### 4.9. TCP四次挥手关闭连接 ###

最后是TCP四次挥手关闭连接，但是这里不是标准的四次挥手，可能是会话双方关闭顺序异常引起的问题

### 4.10. 总结如下 ###

![这里写图片描述][SouthEast 17]

## 5. 消费者接收消息的包分析 ##

### 5.1. 所有包的截图 ###

和生产者通话大部分相同，以下部分不同  
消费者比生产者少了发送消息部分  
消费者比生产者多了声明队列、队列绑定到交换机、消费消息部分  
下面只列出不同的地方  
![这里写图片描述][SouthEast 18]

### 5.2. 367 - 368帧 声明队列 ###

**367帧Queue.Declare**： 客户端向RabbitMQ服务端声明队列  
![这里写图片描述][SouthEast 19]

**368帧 Queue.Declare-Ok**：RabbitMQ创建队列成功并返回信息给客户端  
![这里写图片描述][SouthEast 20]

### 5.3. 369-370：队列绑定到交换机 ###

**369帧Queue.Bind**： 客户端向RabbitMQ服务端要求将队列绑定到指定交换机  
![这里写图片描述][SouthEast 21]

**370帧 Queue.Bind-Ok**：RabbitMQ绑定成功并返回信息给客户端  
![这里写图片描述][SouthEast 22]

### 5.4. 371-372帧: 消费者接收消息 ###

**371帧 Basic.Consume** 客户端设置要消费的队列  
![这里写图片描述][SouthEast 23]

**372帧 Basic.Consume-Ok** RabbitMQ服务端向客户端推送消息  
![这里写图片描述][SouthEast 24]

以上是一次接收一个消息，也可以同一个包同时接收多个消息  
![这里写图片描述][SouthEast 25]  
![这里写图片描述][SouthEast 26]  
![这里写图片描述][SouthEast 27]

### 5.5. 整个流程如下 ###

![这里写图片描述][SouthEast 28]

## 代码 ##

上文的详细代码主要如下：  
生产者代码: [NoPublisherConfirmSend.java][]  
消费者代码：[PublisherConfirmRecv.java][]  
测试代码：[PublisherConfirmTest.java][]的方法 publisherconfirm\_noPublisherConfirmSend()  
所有的详细代码见[github代码，请尽量使用tag v0.14，不要使用master，因为master一直在变，不能保证文章中代码和github上的代码一直相同][github_tag v0.14_master_master_github]

[NoPublisherConfirmSend.java]: https://github.com/hryou0922/spring_boot/blob/v0.14/rabbitmq/src/main/java/com/hry/spring/rabbitmq/advanced/publisherconfirm/NoPublisherConfirmSend.java
[PublisherConfirmRecv.java]: https://github.com/hryou0922/spring_boot/blob/v0.14/rabbitmq/src/main/java/com/hry/spring/rabbitmq/advanced/publisherconfirm/PublisherConfirmRecv.java
[PublisherConfirmTest.java]: https://github.com/hryou0922/spring_boot/blob/v0.14/rabbitmq/src/test/java/com/hry/spring/rabbitmq/advanced/PublisherConfirmTest.java
[SouthEast]: /images/20220531/a848a8c63041401a91e8785d6de05302.png
[SouthEast 1]: /images/20220531/33616293a6674412b4fd126e93d72df0.png
[SouthEast 2]: /images/20220531/31525e3f69854529b42d1d23cbc59b11.png
[SouthEast 3]: /images/20220531/e2c4043f830242b5900dbf1decad0828.png
[SouthEast 4]: /images/20220531/01fc7c7c69c1497fbac8da8f414b1442.png
[SouthEast 5]: /images/20220531/d09be1d3013e4a508dc1fe31647ff8d3.png
[SouthEast 6]: /images/20220531/c6b70089fa384c6db03298313a99518b.png
[SouthEast 7]: /images/20220531/30e4c0ac73974d94b109a4fe270724fb.png
[SouthEast 8]: /images/20220531/c8d57bdef109486aa273ecc943f8c924.png
[SouthEast 9]: /images/20220531/3977c7f6b88a43828b7f608470bdc2ef.png
[SouthEast 10]: /images/20220531/dddd7c5a297a4fb48bbf170e536790ba.png
[SouthEast 11]: /images/20220531/732050c594c1470abb804612bff427a3.png
[SouthEast 12]: /images/20220531/00ca12963ce8424a92e0fa1201bc4e71.png
[SouthEast 13]: /images/20220531/6f3554c722224c37af0d92293b78a120.png
[SouthEast 14]: /images/20220531/e918504b27d542099cf1cd3b171d49f4.png
[SouthEast 15]: /images/20220531/f969b8c7459f417a9e463311dd4d865f.png
[SouthEast 16]: /images/20220531/826be895576a4f8c9e84c695d0e29974.png
[SouthEast 17]: /images/20220531/ed74d1865005474d8f80f6ea0c8f8f03.png
[SouthEast 18]: /images/20220531/b51a9741b98a4f50a0164f7432a8a9a3.png
[SouthEast 19]: /images/20220531/e2f2100da73c4188afe62aeb4c216e1b.png
[SouthEast 20]: /images/20220531/bbc33d3176fb4e6eafb7f8db1e7baf93.png
[SouthEast 21]: /images/20220531/1a3986836b9745e89ab7be293b2608e1.png
[SouthEast 22]: /images/20220531/740b10c6834a4a4d8bfb303a5fc8bc7f.png
[SouthEast 23]: /images/20220531/b2a69ead3b834154bcbe9e19a646bc9e.png
[SouthEast 24]: /images/20220531/3cdbee365bcd459b89f5c96354e71752.png
[SouthEast 25]: /images/20220531/97825fffe9ff445a80693e38f867cef5.png
[SouthEast 26]: /images/20220531/cbe2e7f1526a4c59970523054874727d.png
[SouthEast 27]: /images/20220531/6f9e4ed9ebf542b7a232634d55f433ab.png
[SouthEast 28]: /images/20220531/df4b4a478d694e9d971df812c96197fe.png
[github_tag v0.14_master_master_github]: https://github.com/hryou0922/spring_boot/tree/v0.14/rabbitmq/src/main/java/com/hry/spring/rabbitmq/advanced/publisherconfirm