说明：
几个概念说明： Broker：简单来说就是消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue：消息队列载体，每个消息都会被投入到一个或多个队列。 Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。 Routing Key：路由关键字，exchange根据这个关键字进行消息投递。 vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。 producer：消息生产者，就是投递消息的程序。 consumer：消息消费者，就是接受消息的程序。 channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。 消息队列的使用过程大概如下： （1）客户端连接到消息队列服务器，打开一个channel。 （2）客户端声明一个exchange，并设置相关属性。 （3）客户端声明一个queue，并设置相关属性。 （4）客户端使用routing key，在exchange和queue之间建立好绑定关系。 （5）客户端投递消息到exchange。 exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。 exchange也有几个类型，完全根据key进行投递的叫做Direct交换机，例如，绑定时设置了routing key为”abc”，那么客户端提交的消息，只有设置了key为”abc”的才会投递到队列。
对key进行模式匹配后进行投递的叫做Topic交换机，符号”#”匹配一个或多个词，符号”*”匹配正好一个词。例如”abc.#”匹配”abc.def.ghi”，”abc.*”只匹配”abc.def”。
还有一种不需要key的，叫做Fanout交换机，它采取广播模式，一个消息进来时，投递到与该交换机绑定的所有队列。 RabbitMQ支持消息的持久化，也就是数据写在磁盘上，为了数据安全考虑，我想大多数用户都会选择持久化。消息队列持久化包括3个部分： （1）exchange持久化，在声明时指定durable => 1 （2）queue持久化，在声明时指定durable => 1 （3）消息持久化，在投递时指定delivery_mode => 2（1是非持久化） 如果exchange和queue都是持久化的，那么它们之间的binding也是持久化的。如果exchange和queue两者之间有一个持久化，一个非持久化，就不允许建立绑定。
安装：
下载： wget www.rabbitmq.com/releases/erlang/erlang-18.3-1.el7.centos.x86_64.rpm wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.el7.lux.x86_64.rpm wget www.rabbitmq.com/releases/rabbitmq-server/v3.6.5/rabbitmq-server-3.6.5-1.noarch.rpm 安装： rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm rpm -ivh socat-1.7.3.2-1.1.el7.x86_64.rpm 配置文件： vim /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/ebin/rabbit.app 比如修改密码、配置等等，例如：loopback_users 中的 <<"guest">>,只保留guest 服务启动和停止： 启动 rabbitmq-server start & 停止 rabbitmqctl app_stop rabbitmqctl start_app rabbitmq-plugins enable rabbitmq_management rabbitmqctl stop 管理插件：rabbitmq-plugins enable rabbitmq_management 访问地址：http://192.168.11.76:15672/
本地测试环境移除所有数据：
rabbitmqtl reset 移除所有数据 要在 rabbitmqctl stop_app之后使用
[root@localhost ~]# rabbitmq rabbitmqctl rabbitmq-plugins rabbitmq-server
[root@localhost soft]# rabbitmqctl list_queues Listing queues ... task_queue123 0 [root@localhost soft]# rabbitmqctl list_vhosts Listing vhosts ... / /sunlong
[root@localhost soft]# rabbitmqctl list_exchanges
Listing exchanges ...
amq.fanout fanout
amq.match headers
direct
amq.rabbitmq.trace topic
amq.headers headers
amq.direct direct
amq.rabbitmq.log topic
amq.topic topic
1 [root@localhost soft]# rabbitmqctl status 2 Status of node rabbit@localhost ... 3 [{pid,2521}, 4 {running_applications, 5 [{rabbitmq_management,"RabbitMQ Management Console","3.6.5"}, 6 {rabbitmq_management_agent,"RabbitMQ Management Agent","3.6.5"}, 7 {rabbit,"RabbitMQ","3.6.5"}, 8 {os_mon,"CPO CXC 138 46","2.4"}, 9 {rabbitmq_web_dispatch,"RabbitMQ Web Dispatcher","3.6.5"}, 10 {webmachine,"webmachine","1.10.3"}, 11 {mochiweb,"MochiMedia Web Server","2.13.1"}, 12 {compiler,"ERTS CXC 138 10","6.0.3"}, 13 {ssl,"Erlang/OTP SSL application","7.3"}, 14 {public_key,"Public key infrastructure","1.1.1"}, 15 {ranch,"Socket acceptor pool for TCP protocols.","1.2.1"}, 16 {amqp_client,"RabbitMQ AMQP Client","3.6.5"}, 17 {asn1,"The Erlang ASN1 compiler version 4.0.2","4.0.2"}, 18 {inets,"INETS CXC 138 49","6.2"}, 19 {rabbit_common,[],"3.6.5"}, 20 {xmerl,"XML parser","1.3.10"}, 21 {mnesia,"MNESIA CXC 138 12","4.13.3"}, 22 {syntax_tools,"Syntax tools","1.7"}, 23 {crypto,"CRYPTO","3.6.3"}, 24 {sasl,"SASL CXC 138 11","2.7"}, 25 {stdlib,"ERTS CXC 138 10","2.8"}, 26 {kernel,"ERTS CXC 138 10","4.2"}]}, 27 {os,{unix,linux}}, 28 {erlang_version, 29 "Erlang/OTP 18 [erts-7.3] [source] [64-bit] [async-threads:64] [hipe] [kernel-poll:true]\n"}, 30 {memory, 31 [{total,59824960}, 32 {connection_readers,0}, 33 {connection_writers,0}, 34 {connection_channels,0}, 35 {connection_other,2680}, 36 {queue_procs,19328}, 37 {queue_slave_procs,0}, 38 {plugins,1009776}, 39 {other_proc,18123920}, 40 {mnesia,70096}, 41 {mgmt_db,750320}, 42 {msg_index,43856}, 43 {other_ets,1399424}, 44 {binary,28720}, 45 {code,27824046}, 46 {atom,1000601}, 47 {other_system,9552193}]}, 48 {alarms,[]}, 49 {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]}, 50 {vm_memory_high_watermark,0.4}, 51 {vm_memory_limit,768196608}, 52 {disk_free_limit,50000000}, 53 {disk_free,16176914432}, 54 {file_descriptors, 55 [{total_limit,65435}, 56 {total_used,2}, 57 {sockets_limit,58889}, 58 {sockets_used,0}]}, 59 {processes,[{limit,1048576},{used,229}]}, 60 {run_queue,0}, 61 {uptime,95}, 62 {kernel,{net_ticktime,60}}]