官网文档:    http://www.rabbitmq.com/getstarted.html

个人demo测试   https://github.com/youmustbekiddingme/springboot

1.simple模式

2.rabbitmq 的几种队列模型

  即简单的点对点消息模型。开启mq服务,开启进程P 生产者向mq 写消息,进程C消费者监听mq,消费消息。

2.work 模式

2.rabbitmq 的几种队列模型

   一个生产者P,对应了多个消费者C。这些多个C,消费的消息各自不同,C1和C2 消费的消息,构成所有消息的一个全集。

可以开启C的消费竞争 channel.basicQos(1);C1和C2 能者多劳。

3.发布/订阅模式

a.广播模式---fanout

2.rabbitmq 的几种队列模型

 生产者P将消费发送到X(Exchange交换机),队列RQ6和As8绑定到交换机X。C1对应RQ6,C2对应As8.这样,同一条消息,被C1和C2 同时消费。C1和C2各自拥有对消息全集的消费。比如C1写数据库,C2写搜索引擎,二者写入的数据都完全相同。

先要在P声明交换机,不然C的绑定失败。交换机无存储消息能力,若未绑定队列,则消息丢失。

交换机:

2.rabbitmq 的几种队列模型

绑定关系:

2.rabbitmq 的几种队列模型

队列:

2.rabbitmq 的几种队列模型

 

b.路由模式--direct

    在普通路由模式基础上,指定type=direct ,P生产者发消息的时候需要指定路由名称,如下:指定orange 则发送到Q1

2.rabbitmq 的几种队列模型

c.主题模式--topic

type=topic  ;  * 表示一个或多个词,#表示一个词

    2.rabbitmq 的几种队列模型

相关文章: