网站首页> 文章专栏> RabbitMQ-java客户端-Topic
RabbitMQ-java客户端-Topic
原创 时间:2024-05-16 15:45 作者:AI智能 浏览量:1081

Java客户端-Topic交互机

1716277407412.webp

1716277411839.webp



1,创建队列和交换机

topic.queue1
topic.queue2

hmall.topic

1716277453439.webp

1716277456837.webp

1716277460541.webp




2,创建消费者

@Slf4j
@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "topic.queue1")
    public void listenTopicQueueMessage1(String msg){
        System.out.println("china.# topic.queue1:" + msg);
    }

    @RabbitListener(queues = "topic.queue2")
    public void listenTopicQueueMessage2(String msg){
        System.out.println("#.news 收到了 topic.queue2:" + msg);
    }
}


3,创建生产者

@Test
void testSendTopic() {
    String exchangeNme = "hmall.topic";
    String routingkey = "china.weather";
    String msg = "今天天气";
    rabbitTemplate.convertAndSend(exchangeNme,routingkey,msg);
}


1716277498860.webp


动动小手 !!!
来说两句吧
最新评论
  • 代码王子
    文章干货满满!作者在阐述每个知识点时,都力求详尽且清晰,使得读者可以轻松理解并掌握。此外,文章中还引用了一些具有代表性的代码片段,这些代码既展示了编程的魅力,也使得读者能够更好地理解相关概念和技巧

  • 掌灯师
    学会了,同学现在已经崇拜我了

  • 首席先森
    大佬牛呀,太实用了!

  • 我本帅哥
    真牛

  • 火影AI
    有趣、好文,博主真的是热爱技术的人,支持大佬!

  • 冷风
    很容易看进去,学到了很多知识,感谢博主分享,支持博主