RabbitMQ中的虚拟主机、交换机、消息队列、绑定、消息

虚拟主机（virtual host ）
虚拟地址，用于进行逻辑隔离，最上层的消息路由，一个 virtual host 里面可以有若干个 exchange 和 queue，但是里面不能有相同名称的 exchange 或 queue。搭建好的rabbitmq中有一个默认的虚拟主机“/”。

交换机（Exchanges）
接收消息,并根据路由键转发消息到绑定的队列

属性
name: 交换机名称

type: 交换机类型direct，topic，fanout，headers

direct：直连交换机，转发消息到routigKey指定的队列
topic：扇形交换机，转发消息到所有绑定队列（速度最快）)，
fanout：主题交换机，按规则转发消息（最灵活），
headers：首部交换机
durability: 是否需要持久化，true 为持久化
auto delete: 当最后一个绑定到 exchange 上的队列被删除后，exchange 没有绑定的队列了，自动删除该 exchange
internal: 当前 exchange 是否用于 rabbitMQ 内部使用，默认为 false
arguments: 扩展参数，用于扩展 AMQP 协议自制定化使用

消息队列（Queue）
实际存储消息数据

durability 表示是否持久化，
durable 表示是，
transient 表示否。
auto delete: 如选择 yes，表示当最后一个监听被移除后，该 queue 会被自动删除。
绑定（binding）
绑定 交换机和队列之间的连接关系。binding 中可以包含 routingkey 或者参数，交换机通过routingkey 将消息发送到绑定的队列上。

消息（Message）
服务器和应用程序之间传送的数据 本质上就是一段数据，由 properties 和 payload(body) 组成。

Delivery mode：消息是否持久化，1：否，2：是
Headers：头信息，是由一个或多个键值对组成的（hashtable）

自定义属性：自定义属性一般放到Headers中，进行发送
content_type ： 消息内容的类型
content_encoding： 消息内容的编码格式
priority： 消息的优先级，它的值一般是0-9,9的优先级最高
correlation_id：关联id，在我们实际的工作中，一般把他作为消息的唯一Id
reply_to: 用于指定回复的队列的名称，比如某条消息发送失败了让它回到指定的队列中
expiration： 消息的失效时间（毫秒）
message_id： 消息id
timestamp：消息的时间戳
type： 类型
user_id: 用户id
app_id： 应用程序id
cluster_id: 集群id


提问：如何保证消息不丢失？

保证消息的不丢失
1：Exchange需要持久化
2：Queue需要持久化
3：Message需要持久化
————————————————
www.jiyingyun.com qq 300881195八


本文地址：http://www.wangzhan.org.cn/thread-4731-1-1.html