RabbitMQ之Fanout交换器模式开发

Fanout模式，即广播模式，一个发送到交换机的消息会被转发到与该交换机绑定的所有队列上。

一、Provider

配置文件

spring.application.name=provider
spring.rabbitmq.host=192.168.50.30
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbit
spring.rabbitmq.password=rabbit
#设置交换器的名称
mq.config.exchange=order.fanout

代码

@Component
public class Sender {
    @Autowired
    private AmqpTemplate amqpTemplate;

    @Value("${mq.config.exchange}")
    private String exchange;

    public void send(String msg){
        this.amqpTemplate.convertAndSend(this.exchange, "", msg);
    }
}

二、Consumer

配置文件

spring.application.name=consumer
spring.rabbitmq.host=192.168.50.30
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbit
spring.rabbitmq.password=rabbit
#设置交换器的名称
mq.config.exchange=order.fanout
#短信服务队列名称
mq.config.queue.sms=order.sms
#push 服务队列名称
mq.config.queue.push=order.push

代码

SmsReceiver

/**
    @RabbitListener bindings:绑定队列
    @QueueBinding value:绑定队列的名称
        exchange:配置交换器
        key:路由键
    @Queue value:配置队列名称
        autoDelete:是否是一个可删除的临时队列
    @Exchange value:为交换器起个名称
        type:指定具体的交换器类型
*/
@Component
@RabbitListener(
    bindings=@QueueBinding(
        value=@Queue(
            value="${mq.config.queue.sms}",
            autoDelete="true"
        ),
        exchange=@Exchange(
            value="${mq.config.exchange}",
            type=ExchangeTypes.FANOUT
        )
    )
)
public class SmsReceiver {
    @RabbitHandler
    public void process(String msg) {
        System.out.println(msg);
    }
}

PushReceiver

/**
    @RabbitListener bindings:绑定队列
    @QueueBinding value:绑定队列的名称
            exchange:配置交换器
    @Queue value:配置队列名称
            autoDelete:是否是一个可删除的临时队列
    @Exchange value:为交换器起个名称
        type:指定具体的交换器类型
*/
@Component
@RabbitListener(
    bindings=@QueueBinding(
        value=@Queue(
            value="${mq.config.queue.push}",
            autoDelete="true"),
        exchange=@Exchange(
            value="${mq.config.exchange}",
            type=ExchangeTypes.FANOUT
        )
    )
)
public class PushReceiver {
    @RabbitHandler
    public void process(String msg){
        System.out.println("Push receiver: " + msg);
    }
}