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.创建队列: