RabbitMQ学习系列教程四：Exchange 交换机及直连交换机简单使用
- RabbitMQ学习系列教程
- 时间：2019-07-12 21:46
- 2899人已阅读
🔔🔔好消息!好消息!🔔🔔
如果您需要注册ChatGPT，想要升级ChatGPT4。凯哥可以代注册ChatGPT账号，代升级ChatGPT4
有需要的朋友👉:微信号
Exchange 交换机及直连交换机简单使用
Exchange的定义：
接收消息，并根据路由键转发消息所绑定的队列。
交换机属性：
Name：交换机名称
Type：交换机类型 direct、topic、fanout、headers
Durability:是否需要持久化，true为持久化
Auto Delete：当最后一个绑定到exchange上的队列删除后，自定删除该exchange
Internal:当前exchange是否用于rabbitmq内部使用，默认为false
交换机类型详解：
Direct Exchange-直连交换机：
所有发送到Direct Exchange的消息被转发到routeKey中指定的queue.
注意：Direct模式可以使用RabbitMq自带的Exchange(default Exchange)，所以不需要将Exchange进行任何绑定(binding)操作，消息传递时，RouteKey必须完全匹配才会被队列接收，否则该消息会被抛弃掉的。
官网这么描述Default Exchange的：
Direct exchange示意图：
我们可以看到，每一个routing_key都指向一个消费者。
我们来看看代码：
生产者代码：
在生产者代码中，我们添加了交换机名称及routingkey这两个信息。
接着我们来看看消费者代码：
在消费者端代码中，我们同样添加了exchangeName及routingkey同时还添加了队列名称及exhanggeType属性。
启动后，在浏览器中查看：
查看exchange:
发现已经绑定的：To指向的时
Queue:
点击查看queue:
发现已经绑定了test_direct_exchange了。
运行结果：
本节总结：
Direct Exchange类型的，简称直连方式。其实rabbitmq默认的就是此种方式。使用此种方式要求很简单：
如果指定了exchangeName则会在指定exchangeName上查找指定routingkey的。
在生产者中，设置channel属性时添加路由名称及key;
在消费者中，同样在channel设置属性的时，需要交换机名称及key保持也生产者一致。就可以正常接收消息了。
下节预告：在下节课中我们将讲解topic exchange
上一篇： idea下使用JavaDoc生产帮助文档
下一篇： 你为什么那么努力