品索智能

RabbitMQ-java客户端-Fonout交互机

原创时间:2024-05-11 15:12 作者:AI智能浏览量:1069

java客户端-Fonout交互机

1，在控制台中创建队列和交换机

fanout.queue1
fanout.queue2

hamll.fanout

交换机

绑定队列

3，创建消费者

@Slf4j
@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "fanout.queue1")
    public void listenSimpleQueueMessage1(String msg){
        System.out.println("消费者1 收到了 fanout.queue1：" + msg);
    }

    @RabbitListener(queues = "fanout.queue2")
    public void listenSimpleQueueMessage2(String msg){
        System.out.println("消费者2 收到了 fanout.queue2：" + msg);
    }
}

4，创建生产者发送广播

@Test
void testFanout() {
    String exchangeNme = "hamll.fanout";
    String msg = "hello,hamll.fanout";
    rabbitTemplate.convertAndSend(exchangeNme,null,msg);
}

可以看见发送广播后，交换机下面绑定的队列都能收到消息。

交换机的作用是什么?