1.什么是Exchanges(交换机):
- 1.RabbitMQ 消息传递模型的核心思想是:
生产者生产的消息从不会直接发送到队列
。实际上,通常生产者甚至都不知道这些消息传递传递到了哪些队列中 - 2.
生产者只能将消息发送到交换机(exchange)
,交换机工作的内容非常简单,一方面它接收来自生产者的消息,另一方面将它们推入队列 - 3.交换机必须确切知道如何处理收到的消息。是应该把这些消息放到特定队列还是说把他们到许多队列中还是说应该丢弃它们。这就的由
交换机的类型来决定
2.Exchanges(交换机)的类型
总共有以下5种类型:
- 1.
扇出(fanout)
:就是发布订阅模式 - 2.
无名类型
:就是默认类型 - 3.
直接(direct)
: 就是路由类型的意思 - 4.
主题(topic)
:就是主题类型 - 5.
标题(headers)
:不太常用了
在RabbitMQ中,我们
依据使用的交换机的类型的不同,可以分别实现RabbitMQ中不同的模式
2.临时队列
- 1.每当我们连接到 Rabbit 时,我们都需要一个全新的空队列,为此我们可以创建一个具有随机名称的队列,或者能让服务器为我们选择一个随机队列名称那就更好了。其次一旦我们断开了消费者的连接,队列将被自动删除。
- 2.创建临时队列的方式如下:
String queueName = channel.queueDeclare().getQueue();
在后面我们为了介绍这几种模式的方便,我们就使用此方式建立个临时的队列来进行测试
3.绑定(bindings)
- 1.bindings就是指的队列与交换机的绑定
- 2.
binding 意思是 exchange 和 queue 之间的桥梁
,它明确了exchange 和哪个队列进行了绑定关系。比如说下面这张图告诉我们的就是 X 与 Q1 和 Q2 进行了绑定
- 3.管理页面上操作交换机与队列的绑定: