消息队列之RabbitMQ

为什么要使用消息队列

1. 实现异步

2. 实现解耦

串行任务的并行化

3.流量削峰

高负载任务的负载均衡，高并发流量先放到消息队列中，进行异步处理

4.实现广播

发布/订阅模式，比如下图中，要增加积分系统，只需要积分系统绑定监听即可

RabbitMQ的工作模型

1. 直连类型 Direct Exchange

2.主题类型 Topic Exchange

3.广播类型 Fanout Exchange

1. 配置类:创建交换机，创建队列，创建绑定关系

2. 消费者: 监听队列 @RabbitListener

3. 生产者: AmqpTemplate 或者RabbitTemplate 已经封装好了

4. 服务器信息配置:生产者和消费者都要配置

1. 使用Rabbit的事务模式，channel.txSelect()等等，类似于数据库事务，不过这种模式是同步阻塞的

2.另外使用confirm的模式，使用异步的方式

1. 可以在channel上绑定监听器，无法找到的时候会有反馈

2. 指定收到无法路由的消息时候，发送到制定的队列

最后编辑于：2018.11.12 21:20:46

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。