RabbitMQ概要图

Posted 2021-12-28 itplay

 

使用流程

发布者（推送消息的一端）：

1. 创建一个tcp长连接connection，连接rabbitmq的监听端口5672；

2. 在TCP长连接下创建一个信道channel,信道可以理解为connection的一个分支；

3. 通过信道向rabbitmq声明一个交换机exchange，设置交换机的类型，名称，是否持久化等属性；

4. 通过信道向rabbitmq声明一个队列queue，设置队列的名称，是否持久化等参数；

5. 通过信道向rabbitmq声明一个绑定binding,设置绑定的交换机名称，队列名称，绑定的路由键；

6. 通过信道向rabbitmq推送一条消息，指定交换机和路由；

消费者（接收消息的一端）：

1. 从第一步到第四步和发布者做的事情是一模一样的,如果已经存在相应的exchange、queue等则跳过；

2. 通过信道向rabbitmq声明一个订阅，订阅特定的queue，并且设置回调函数及是否确认等；

3. 通过信道监听rabbitmq推送过来的消息；