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