【代码】RabbitMQ学习笔记
前言
RabbitMQ快速入门
简单模式
生产者
- 向消息队列发送消息
1 | public class Producer { |
消费者
- 从消息队列获取消息
1 | public class Consumer { |
工作模式
生产者
1 | public class Producer { |
消费者
1 | public class Consumer { |
合理分发
- 通过回执,通知服务器消息处理完成
- 每次只从服务器获取一条消息,没处理完成不进行下一条
1 | public class Consumer { |
持久化
- 已经创建的队列不能修改为持久队列
生产者
1 | public class Producer { |
消费者
1 | public class Consumer { |
发布和订阅模式
- fanout
生产者
1 | public class Producer { |
消费者
1 | public class Consumer { |
路由模式
direct
通过路由键匹配绑定键发送消息
交换机不存储消息,如果没有匹配的队列,消息直接丢弃
生产者
1 | public class Producer { |
消费者
1 | public class Consumer { |
主题模式
topic
提供一种关键词规则的路由模式
代码与路由模式大同小异
每个消费者匹配到多个相同数据,只接收一条
交换机不存储消息,如果没有匹配的队列,消息直接丢弃
绑定键的格式
- 以
.
连接的多个关键词 *
关键字表示任意一个关键词#
关键字表示任意一个关键词
1 | aa.bb.cc |
生产者
1 | public class Producer { |
消费者
1 | public class Consumer { |
RPC模式
- 略