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交换机存在主题，该接口有多个基于主题的实现类。

基于注解

4.7 信息转换器

5.业务改造