生产流程
- 建立链接(Connection)
- 在链接(Connection)上开启一个信道(Channel)
- 声明一个交换机(Exchange)
- 声明一个队列(Queue)
- 使用路由键(RoutingKey)将队列(Queue)和交换机(Exchange)绑定起来
- 根据路由键(RoutingKey)发送消息到交换机(Exchange)
- [MQ]根据交换机(Exchange)和路由键(RoutingKey),将消息或存放到队列(Queue),或丢弃,或退回给生产者
- 关闭信道(Channel)
- 关闭链接(Connection)
消费流程
- 建立链接(Connection)
- 在链接(Connection)上开启一个信道(Channel)
- 请求消费指定队列(Queue)的消息,并设置回调函数(onMessage)
- [MQ]将消息推送给消费者
- 消费者发送消息确定(Ack[acknowledge])
- [MQ]删除被确认的消息
- 关闭信道(Channel)
- 关闭链接(Connection)
网友评论