RabbitMQ学习系列教程四:Exchange 交换机及直连交换机简单使用

简介 Exchange交换机及直连交换机简单使用Exchange的定义:    接收消息,并根据路由键转发消息所绑定的队列。交换机属性:Name:交换机名称Type:交换机类型direct、topic、fanout、headersDurability:是否需要持久化,true为持久化AutoDelete:当最后一个绑定到exchange上的队列删除后,自定删除该e

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


Top Top