- 生产者连接到RabbitMQ Broker,建立一个Connection,开启一个Channel
- 生产者声明一个交换器,并设置相关属性,如交换器类型、是否持久化
- 生产者声明一个队列并为相关属性。如是否排他、是否持久化、是否自动删除等
- 生产者通过路由键(RoutingKey)将交换器(Exchange)和队列绑定起来
- 生产者发送消息至RabbitMQ Broker,其中包含路由键、交换器等信息
- 相应的交换器根据接收到的路由键查找相匹配的队列。
- 如果找到,刚将从生产者发送过来的消息存入相应的队列中
- 如果没有找到,则根据生产者配置的属性选择丢弃还是退回给生产者
-
关闭信道(channel.close)
10.关闭连接 (connection.close)
消费者接收消息的过程
:
1.消费者连接到RabbitMQ Broker ,建立一个连接(Connection),开启一个信道(Channel)。
2.消费者向RabbitMQ Broker 请求消费相应队列中的消息,可能会设置相应的回调函数,以及做一些准备工作
3.等待RabbitMQ Broker 回应并投递相应队列中的消息 ,消费者接收消息。
4.消费者确认(ack)接收到消息
5.RabbitMQ 从队列中删除相应已经被确认的消息
6.关闭信道。
7.关闭连接。
版权声明:本文为qq_40124920原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。