RabbitMQ常用的五种模式

你的名字 2022-01-26 17:25 261阅读 0赞

官方地址：[https://www.rabbitmq.com/getstarted.html][https_www.rabbitmq.com_getstarted.html]  
参考：[https://www.cnblogs.com/Alva-mu/p/9535396.html][https_www.cnblogs.com_Alva-mu_p_9535396.html]  
java可以简单使用springdataRabbit来操作，speing cloud 可以用stream来结合，方便以后可以更换成kafka

1.  简单的生产者消费者模式  
    （就是一个生产者发送消息到队列，由一个消费者消费）  
    ![在这里插入图片描述][20190529155845574.png]
2.  work模式  
    一个生产者对应多个消费者,但是只能有一个消费者获得消息!!!  
    如果不设置channel.basicQos(1);，那么 消息队列会均匀发消息给消费者，造成有些消费者处理不来，有些消费者处于空闲，浪费资源。  
    如果设置了channel.basicQos(1);，表示同一时刻服务器只会发送一条消息给消费者，哪个消费者空闲，哪个就可以进行消费了。  
    ![在这里插入图片描述][20190529160214365.png]
3.  发布/订阅模式  
    图X表示交换器，交换器没有存储消息的能力，消息只能存在队列中。  
    这里的交换器类型是fanout。  
    生产者发送消息到交换器，交换器绑定了多个队列，只要消费者有监听绑定队列的，都会接收到信息，然后进行消费。![在这里插入图片描述][20190529163438350.png]
4.  路由模式  
    生产者将消息发送到direct交换器,在绑定队列和交换器的时候有一个routkey,生产者发送的消息会指定一个routkey,那么消息只会发送到相应routkey相同的队列,接着监听该队列的消费者消费信息.  
    ![在这里插入图片描述][20190529170043814.png]
5.  Topic模式(主题模式，通配符模式)  
    上面的路由模式是根据routkey进行完整的匹配(完全相等才发送消息)，这里的通配符模式通俗的来讲就是模糊匹配。  
    符号"\#“表示匹配一个或多个词,符号”\*"表示匹配一个词。  
    ![在这里插入图片描述][20190529170458435.png]

[https_www.rabbitmq.com_getstarted.html]: https://www.rabbitmq.com/getstarted.html
[https_www.cnblogs.com_Alva-mu_p_9535396.html]: https://www.cnblogs.com/Alva-mu/p/9535396.html
[20190529155845574.png]: /images/20220126/b5d33377cf2f4d58a8901d5ffd24aab5.png
[20190529160214365.png]: /images/20220126/d91d3b181d3645ad9f1ac8cb66820857.png
[20190529163438350.png]: /images/20220126/3fc45d6cacd243368038bc7766337e4b.png
[20190529170043814.png]: /images/20220126/8c6a5218127d499b91a5d567ed4015c8.png
[20190529170458435.png]: /images/20220126/c25e0b3c63c94857acce383a2f2a99f3.png