消息队列服务 RabbitMQ

Rabbitmq是一个消息代理。它的核心思想非常简单:接收并转发消息。你可以把它想象成一个邮局:当你把邮件丢进邮箱时,你非常确定邮递员先生会把它送到收件人手中。在这个比喻中,RabbitMQ就是邮箱、邮局和邮递员。

RabbitMQ和邮局的主要区别是它处理的不是纸张。它接收、存储并转发二进制数据块,也就是message,消息。

术语

RabbitMQ和消息传递中会用到一些术语:

生产者

在现实生活中就好比制造商品的工厂,他们是商品的生产者。生产者只意味着发送。发送消息的程序称之为一个生产者。我们用“P”表示

列队

队列就像存放商品的仓库或者商店,是生产商品的工厂和购买商品的用户之间的中转站。队列就像是一个仓库或者流水线。在RabbitMQ中,信息流从你的应用程序出发,来到RabbitMQ的队列,所有信息可以只存储在一个队列中。队列可以存储很多的消息,因为它基本上是一个无限制的缓冲区,前提是你的机器有足够的存储空间。多个生产者可以将消息发送到同一个队列中,多个消费者也可以只从同一个队列接收数据。这就是队列的特性。队列用下面的图表示,图上面是队列的名字:

消费者

消费者就好比是从商店购买或从仓库取走商品的人,消费的意思就是接收。消费者是一个程序,主要是等待接收消息。我们的用“C”表示

注意: producer、consumer和消息代理不需要生活在同一台机器上,事实上大多数应用中它们会分开住。

安装

#yum -y install epel-release
#yum install erlang #先安装 Erlang
#rpm --import https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc
#yum install rabbitmq-server

1.设置未开机启动

systemctl enable rabbitmq-server

2.启动

systemctl start rabbitmq-server

配置端口

确保可以打开以下端口:

4369:epmd,RabbitMQ节点和CLI工具使用的对等发现服务
5672,5671:由AMQP 0-9-1和1.0客户端使用,没有和使用TLS
25672:由Erlang分配用于节点间和CLI工具通信,并且从动态范围(默认情况下限于单个端口,计算为AMQP端口+20000)分配。详情请参阅联网指南。
15672:HTTP API客户端和rabbitmqadmin(仅当管理插件启用时)
61613,61614:STOMP客户端没有和使用TLS(只有STOMP插件已启用)
1883年,8883:(MQTT客户端没有和TLS,如果MQTT插件已启用
15674:STOMP-over-WebSockets客户端(仅在启用了Web STOMP插件的情况下)
15675:MQTT-over-WebSockets客户端(仅在启用了Web MQTT插件的情况下)

查看状态

[root@centos ~]# rabbitmqctl status
Status of node rabbit@centos ...
[{pid,40209},
 {running_applications,[{rabbit,"RabbitMQ","3.3.5"},
                        {mnesia,"MNESIA  CXC 138 12","4.11"},
                        {os_mon,"CPO  CXC 138 46","2.2.14"},
                        {xmerl,"XML parser","1.3.6"},
                        {sasl,"SASL  CXC 138 11","2.3.4"},
                        {stdlib,"ERTS  CXC 138 10","1.19.4"},
                        {kernel,"ERTS  CXC 138 10","2.16.4"}]},
 {os,{unix,linux}},
 {erlang_version,"Erlang R16B03-1 (erts-5.10.4) [source] [64-bit] [async-threads:30] [hipe] [kernel-poll:true]\n"},
 {memory,[{total,35004392},
          {connection_procs,2720},
          {queue_procs,5440},
          {plugins,0},
          {other_proc,13305792},
          {mnesia,58336},
          {mgmt_db,0},
          {msg_index,33936},
          {other_ets,781728},
          {binary,13344},
          {code,16713450},
          {atom,602729},
          {other_system,3486917}]},
 {alarms,[]},
 {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]},
 {vm_memory_high_watermark,0.4},
 {vm_memory_limit,741048320},
 {disk_free_limit,50000000},
 {disk_free,18375475200},
 {file_descriptors,[{total_limit,924},
                    {total_used,3},
                    {sockets_limit,829},
                    {sockets_used,1}]},
 {processes,[{limit,1048576},{used,124}]},
 {run_queue,0},
 {uptime,326}]
...done.
[root@centos ~]#

配置文件

cp /usr/share/doc/rabbitmq-server-3.3.5/rabbitmq.config.example /etc/rabbitmq/
cp /etc/rabbitmq/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
vim /etc/rabbitmq/rabbitmq.config

修改

%%{loopback_users, []},

{loopback_users, []}    

开启web管理插件

rabbitmq-plugins enable rabbitmq_management

重启

service rabbitmq-server restart

开通端口

sudo iptables -I INPUT -p tcp -m tcp –dport 15672 -j ACCEPT
sudo iptables -I INPUT -p tcp -m tcp –dport 5672 -j ACCEPT

访问

创建用户

[root@centos ~]# rabbitmqctl add_user admin admin
Creating user "admin" ...
...done.

赋予admin 管理员权限

[root@centos ~]# rabbitmqctl set_user_tags admin administrator
Setting tags for user "admin" to [administrator] ...
...done.

列出用户

[root@centos ~]# rabbitmqctl list_users
Listing users ...
admin    [administrator]
guest    [administrator]
...done.

登录后界面