AMQP
定义
Advanced Message Queuing Protocol
高级消息队列协议
是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。
核心概念
server:又称broker，接受客户端的连接，实现amqp实体服务
channel:网络信道，几乎所有的操作都在channel中进行，channel是进行消息读写的通道。客户端可建立多个channel，每个channel代表一个会话任务。
message:消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息 修饰，比如消息的优先级、延迟等高级特性，Body则就是消息体内容。
Virtual host:虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual host里面可以有若干个Exchagne和Queue，同一个Virtual host里面不能有相同名称的Exchange或Queue。
Exchange:交换机，接受消息，根据路由键转发消息到绑定的队列。
Binding:Exchange和Queue之间的虚拟连接，binding中可以包含Routing key。
Routing key:一个路由规则，虚拟机可用它来确定如何路由一个特定消息。
Queue:也成为Message Queue，消息队列，保存消息并将它们转发给消费者
启动rabbitmq
abbitmq-server start &
进入/etc/rabbitmq
rabbitmq-plugins enable rabbitmq_management
基础命令
#启动
rabbitmq-server start &
#停止
rabbitmq-server stop
rabbitmqctl stop_app
#重启
rabbitmq-server restart
#状态
rabbitmqctl status
#管理插件
rabbitmq-plugins enable rabbitmq_management
操作
关于应用
rabbitmqctl start_app:
启动应用
rabbitmqctl stop_app:
关闭应用
rabbitmqctl status:
节点状态
rabbitmqctl reset:
移除所有数据，要在rabbitmqctl stop_app之后使用
rabbitmqctl join_cluster <clusternode> [--ram]:
组成集群命令
rabbitmqctl cluster_status:
查看集群状态
rabbitmqctl change_cluster_node_type disc|ram:
修改集群节点的存储形式
rabbitmqctl forget_cluster_node [--offline]:
忘记节点（摘除节点）
rabbitmqctl rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2]:
修改节点名称
关于用户
rabbitmqctl add_user username password:
添加用户
rabbitmqctl list_users:
列出所有用户
rabbitmqctl dekete_user username:
删除用户
rabbitmqctl clear_permissions -p vhostpath username:
清除用户权限
rabbitmqctl list_user_permissions username:
列出用户权限
rabbitmqctl change_password username newpassword:
修改密码
rabbitmqctl set_permissions -p vhostpath username ".*" ".*" ".*":
设置用户权限
关于虚拟主机
rabbitmqctl add_vhost vhostpath:
创建虚拟主机
rabbitmqctl list_vhosts:
列出所有虚拟主机
rabbitmqctl list_permissions -p vhostpath:
列出虚拟主机上所有权限
rabbitmqctl delete_vhost vhostpath:
删除虚拟主机
关于队列
rabbitmqctl list_queues:
查看所有队列信息
rabbitmqctl -p vhostpath purge_queue blue:
清除队列里的消息
exchange交换机
交换机属性
name:
交换机名称
type:
direct,topic,fanout,headers
durability:
是否需要持久化，true为持久化
auto delete:
当最后一个绑定到exchange删的队列删除后，自动删除该exchange
internal:
当前exchange是否用于rabbitmq内部使用，默认为false
arguments:
扩展参数，用于扩展amqp协议自制定化使用
交换机类型
direct exchange
所有发送到direct exchange的消息被转发到RouteKey中指定的queue
注意：direct模式可以使用rabbitmq自带的exchange：default exchange，所以不需要将exchange进行任何绑定（binding）操作，消息传递时，RouteKey必须完全匹配才会被队列接受，否则该消息会被抛弃
topic exchange
所有发送到topic exchange的消息被转发到所有关心RouteKey中指定topic的queue上
exchange将routekey和某topic进行模糊匹配，此时队列需要绑定一个topic
fanout exchange
不处理路由键，只需要见得将队列绑定到交换机上。
发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。
fanout交换机转发消息是最快的
Binding绑定
概述
exchange和exchange、queue之间的连接关系
Binding中可以包含routekey或者参数
Queue消息队列
概述
消息队列，实际存储消息数据
durability：是否持久化，durable：是，transient：否
auto delete：如选yes，代表当最后一个监听被移除之后，该queue会自动被删除
Message消息
概述
服务器应用程序之间传送的数据
本质上就是一段数据，由properties和payload（body）组成
常用属性：delivery mode、headers（自定义属性）
其他属性：
content_type, content_encoding, priority
correlation_id,reply_to,expiration,message_id
timestamp,type,user_id,cluster_id
