1.交换机属性
交换机属性:
name:交换机名称
type:交换机类型 direct，topic，fanout，headers
durability:是否需要持久化，true为持久化
auto delete:当最后一个绑定到exchange上的队列被删除后，exchange没有绑定的队列了，自动删除该exchange
internal:当前exchange是否用于rabbitMQ内部使用，默认为false
arguments:扩展参数，用于扩展AMQP协议自制定化使用
2.direct exchange类型
direct exchange:所有发送到direct exchange的消息被转发到routing key中指定的queue
注意:direct模式可以使用rabbitMQ自带的exchange:default exchange，所以不需要将exchange进行任何绑定(binding)操作，消息传递时，routingkey必须完全匹配才会被队列接收，否则该消息会被抛弃。
流转示意图如下
代码地址： https://github.com/hmilyos/rabbitmq-api-demo
代码示例：
消费端代码：
启动消费端
上管控台查看交换机和队列是否成功创建
点击进去查看绑定情况
生产端代码
然后把生产端run一下
再查看消费端的日志
该消费端只接收 routingkey 为 test.direct 的消息，证明direct exchange类型的，routingkey 必须完全匹配才会被队列接收，否则该消息会被抛弃。
3.topic exchange类型
topic exchange:所有发送到topic exchange的消息被转发到所有关心routingkey中topic的queue上
exchange将routingkey和某topic进行模糊匹配，此时队列需要绑定一个topic。
注意:topic可以使用通配符进行模糊匹配
#匹配一个或多个词，注意是词
*只能匹配一个词
例如“log.#”能匹配到“log.info.oa”
“log.*”只能匹配到“log.erro”这种格式
具体示例图如下图，usa.news能被usa.#，#.news所消费，usa.weather能被usa.#,#.weather所消费...
代码示例：
消费端：
启动消费端，上管控台查看创建、绑定是否成功
确认成功后，编写生产端代码
启动生产端
消费端接收到的
routingKey3 ="user.delete.abc" 的未被接收，符合 user.* 的规则
这时候在消费端把 routingKey 修改一下， routingKey ="user.#"，重启消费端，上管控台
发现之前 * 的并没有解绑，需要我们手动解绑一下，然后再启动生产端的代码
发现三条都能接收到了，符合 # 的规则。
4.fanout exchange类型
fanout exchange:不处理路由键，只需要简单的将队列绑定到交换机上，发送到该交换机的消息都会被转发到于该交换机绑定的所有队列上，fanout交换机由于不需要进行routingkey的对比 直接发送所以绑定的queue，所以转发消息是最快的
示意图如下图所示
代码实现：
启动一下消费端
启动生产端
查看消费端的日志
routingkey0-9的都能被就收，也就相当于该交换机上所有的队列都能接收来到该交换机的消息。
headers类型的不常用，就不介绍了
5.binding
binding:绑定exchange和exchange/queue之间的连接关心。binding中可以包含routingkey或者参数
6. Queue
queue:消息队列，实际存储消息数据，durability表示是否持久化，durable表示是，transient表示否。auto delete:如选择yes，表示当最后一个监听被移除后，该queue会被自动删除。
7. Message
message:服务器和应用程序之间传送的数据 本质上就是一段数据，由properties和payload(body)组成
常用属性:delivery mode，headersheaders(自定义属性)，content_type,content_encoding,priority,correlation_id,reply_to,expiration,message_id,timestamp,type,user_id,app_id,cluster_id
代码实现：
生产端
先启动消费端，上管控台确认交换机和队列是否创建和绑定成功，再启动生产端，消费端接收到如下的信息
8.virtual host
virtual host 虚拟主机
虚拟地址，用于进行逻辑隔离，最上层的消息路由，一个virtual host里面可以有若干个exchange和queue，但是里面不能有相同名称的exchange或queue
网友评论