RabbitMQ

知识总览

同步调用

发出信息后，需要等待回复再去做别的事情

同步调用的优势

时效性强，等待到结果后才返回

同步调用的问题

拓展性差
性能下降
级联失败问题

异步调用

例如支付服务不在调用业务关联度低的服务，而是发送消息通知到Broker

异步调用的问题

MQ的技术选型

RabbitMQ的安装

上传mq.tar

docker load -i mq.tar
1
2
3
4
5
6
7
8
9
10
11
12
13

- ```bash
  # 安装容器
  docker run \
   -e RABBITMQ_DEFAULT_USER=itheima \
   -e RABBITMQ_DEFAULT_PASS=123321 \
   -v mq-plugins:/plugins \
   --name mq \
   --hostname mq \
   -p 15672:15672 \
   -p 5672:5672 \
   -d \
   rabbitmq:3.8-management

浏览器打开192.168.186.100:15672,即可访问RabbitMQ的客户端，用户名为itheima,密码为123321

SpringAMQP

使用官方文档的接口太繁琐，SpringAMQP封装好了一层接口

SprinngAMQP入门案例

引入spring-amqp依赖
配置RabbitMQ服务端地址
发送消息

接收消息

工作模型

多个消费者共享消息队列中的消息

模拟工作Queue

消费者消息推送限制

交换机（Exchange）

Fanout交换机

示例

编写消费者方法：

@RabbitListener(queues = "fanout.queue1")
public void listenFanoutQueue1(String msg) throws InterruptedException {
    System.out.println("消费者1收到了fanout.queue1消息.......：【"+msg+"】");
    Thread.sleep(200);
}

@RabbitListener(queues = "fanout.queue2")
public void listenFanoutQueue2(String msg) throws InterruptedException {
    System.out.println("消费者2收到了fanout.queue2消息.......：【"+msg+"】");
    Thread.sleep(200);
}

编写发送者方法：

@Test
public void testSendFanout(){
    String exchangeName = "hmall.fanout";
    String msg = "hello,everyone";
    rabbitTemplate.convertAndSend(exchangeName,null,msg);
}