rabbitmq学习
消息模型
基本消息模型
一个生产者,一个队列,一个消费者
work消息模型
能者多劳,默认是平均分配
这里是设置的消费者的消费策略,多个消费者消费一个队列
通过 BasicQos 方法设置prefetchCount = 1。这样RabbitMQ就会使得每个Consumer在同一个时间点最多处理1个Message。换句话说,在接收到该Consumer的ack前,他它不会将新的Message分发给它。相反,它会将其分派给不是仍然忙碌的下一个Consumer。
值得注意的是:prefetchCount在手动ack的情况下才生效,自动ack不生效。
————————————————
版权声明:本文为CSDN博主「kavito」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/kavito/article/details/91403659
Publish/subscribe(交换机类型:Fanout,也称为广播 )
Routing 路由模型(交换机类型:direct)
Topics 通配符模式(交换机类型:topics)
交换机类型
Fanout:广播,将消息交给所有绑定到交换机的队列
Direct:定向,把消息交给符合指定routing key 的队列
Topic:通配符,把消息交给符合routing pattern(路由模式) 的队列
Header:header模式与routing不同的地方在于,header模式取消routingkey,使用header中的 key/value(键值对)匹配队列。
————————————————
版权声明:本文为CSDN博主「kavito」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/kavito/article/details/91403659
Exchange(交换机)只负责转发消息,不具备存储消息的能力,因此如果没有任何队列与Exchange绑定,或者没有符合路由规则的队列,那么消息会丢失!


