RabbitMQ

作者: 写演 | 来源:发表于2017-09-07 18:55 被阅读0次

1.订阅消息:basic.consum持续的订阅消息;basic.get订阅消息->获得单条消息->取消订阅消息。

2.一个队列多个订阅者,mq轮训发送消息给所有订阅者,一个消息只由一个订阅者消费。

3.订阅者确认:消费者接收的每一条消息都必须进行确认。

消费者收到消息然后断开连接或者取消订阅,MQ会认为此消息没有分发,会重新发给下一个订阅的消费者。

回复basic.ack之前,MQ将不会发送消息给该订阅者。若订阅者发生了无法处理的错误需要其他订阅者处理或延时处理,可以回复basic.reject.requeue=true,MQ会把该消息发送给下一个订阅者。

订阅者若发现该消息格式错误所有订阅者都无法处理,需要回复basic.reject.requeue=false,MQ将删除该消息(将来将会把消息移动到 dead letter队列)。

4.创建队列:

相关文章

网友评论

      本文标题:RabbitMQ

      本文链接:https://www.haomeiwen.com/subject/gbxwjxtx.html