RabbitMQ模式（发布与订阅）

参考：https://www.cnblogs.com/wuhenzhidu/p/10800239.html

原理

RabbitMq消息模式的核心思想是：一个生产者并不会直接往一个队列中发送消息，事实上，生产者根本不知道它发送的消息将被转发到哪些队列。

实际上，生产者只能把消息发送给一个exchange，exchange只做一件简单的事情：一方面它们接收从生产者发送过来的消息，另一方面，它们把接收到的消息推送给队列。一个exchage必须清楚地知道如何处理一条消息。

有四种类型的交换器，分别是：direct、topic、headers、fanout（广播模式）。

广播模式交换器就是把接收到的消息推送给所有它知道的队列。

RabbitMQ交换机类型介绍参考：https://www.cnblogs.com/stefan-liu/p/5315809.html

理解

生产者将信息发送到exchange交换机,exchange将信息转发到绑定的队列中，当使用fanous（广播模式）时,个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。

Producer-->Exchange

Exchange-->Queue

发送端

@Slf4j
@RequestMapping("/test")
@RestController
public class TestCtl {
    @Value("${rabbitmq.exchange}")
    private String exchange;
    @Autowired
    private AmqpTemplate amqpTemplate;
    /**
     * 生产者将消息直接发送到队列
     * @throws Exception
     */
    @GetMapping("/test")
    public void test() throws Exception {
        amqpTemplate.convertAndSend(exchange,"","exchange log...........");
    }
}

接收端

@Component
@Slf4j
public class MqReceiver {
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = "info",autoDelete = "true"),
            exchange = @Exchange(value = "${rabbitmq.exchange}",type = ExchangeTypes.FANOUT)
    ))
    public void logInfo(String message) {
        log.info("logInfo MqReceiver:{}", message);
    }
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = "error",autoDelete = "true"),
            exchange = @Exchange(value = "${rabbitmq.exchange}",type = ExchangeTypes.FANOUT)
    ))
    public void errorInfo(String message) {
        log.info("errorInfo MqReceiver:{}", message);
    }
}

springboot参数配置

spring:
  rabbitmq:
    virtual-host: /
    host: 192.168.1.31
    port: 5672
    username: admin
    password: admin123
rabbitmq:
  exchange: log.exchange

pom配置

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

RabbitMQ模式（发布与订阅）

原文：https://www.cnblogs.com/code-red-memory/p/12522600.html