MQ快速入门
目录
1.同步调用
2.异步调用
3.MQ技术选型
4.Java客户端
4.1简单发送
引入依赖
配置MQ服务端
发送消息
接收消息
4.2 WorkQueue
4.3 Fanouot交换机
4.4 Direct交换机
4.5 Topic交换机
4.6 声明队列和交换机
基于bean
基于注解
4.7 信息转换器
5.业务改造
1.同步调用
2.异步调用
3.MQ技术选型
4.Java客户端
4.1简单发送
引入依赖![]()
配置MQ服务端
发送消息
接收消息
4.2 WorkQueue
发送消息时，默认将消息依次分配给绑定队列的所有消费者，不考虑速度，导致处理慢的消费者占据着大量未处理消息造成消息堆积。
通过配置preFetch的值使得消费者必须处理完当前消息才能获取下一条，能者多劳。
4.3 Fanouot交换机
4.4 Direct交换机
场景：在支付业务中，支付成功需要通知订单服务修改订单状态（已支付），通知短信服务推送用户下单信息，通知积分服务给用户加积分。
支付失败的话，只需要通知订单服务修改订单状态（已取消）。
在这种情况下，Direct的定向路由很实用。
4.5 Topic交换机
4.6 声明队列和交换机
基于bean
由于Exchange交换机存在主题，该接口有多个基于主题的实现类。