AMQP是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制。
header(exchange, id, persistence) + body
生产者将消息发送到指定的队列,Rabbit将队列中的消息依次推送给消费者。 依次推送设置:prefetch_count=1 消息持久化:delivery_mode = 2 队列持久化:durable=True 消息通知:auto_ack=False / no_ack=True
即广播模式 交换机:fanout 交换机持久化:durable=True
交换机:direct
交换机:topic
客户端向服务端发送新消息,客户端收到消息后回复消息给客户端 Reply to:回调队列 Correlation id:每个请求的唯一标识
参考:https://pulse.mozilla.org/api/