centos6.x在線搭建RabbitMQ集群

1 環(huán)境

兩個(gè)節(jié)點(diǎn)

172.17.164.17 rabbitmq-node1 #centos6.4
172.17.164.18 rabbitmq-node2 #centos6.4
1.1 修改hostname

修改3個(gè)地方

/etc/hosts
172.17.164.17 rabbitmq-node1
172.17.164.18 rabbitmq-node2
/etc/sysconfig/network
HOSTNAME=rabbitmq-node1
HOSTNAME=rabbitmq-node2
如果不想重啟,直接修改hostname,重新登陸即可
[root@localhost ~]# hostname rabbitmq-node1

2 安裝erlang和mq

2.1 安裝erlang依賴的基本環(huán)境
yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel
2.2 導(dǎo)入erlang源,并安裝erlang
[root@localhost ~]# rpm --import http://binaries.erlang-solutions.com/debian/erlang_solutions.asc
[root@localhost ~]# wget -O /etc/yum.repos.d/erlang_solutions.repo http://binaries.erlang-solutions.com/rpm/centos/erlang_solutions.repo
 [root@localhost ~]# wget http://apt.sw.be/redhat/el6/en/x86_64/rpmforge/RPMS/rpmforge-release-0.5.2-2.el6.rf.x86_64.rpm
[root@localhost ~]# rpm --import http://apt.sw.be/RPM-GPG-KEY.dag.txt
[root@localhost ~]# rpm -i rpmforge-release-0.5.2-2.el6.rf.*.rpm
[root@localhost ~]# yum update
[root@localhost ~]# yum update --skip-broken
[root@localhost ~]# yum install erlang
2.3 安裝rabbitmq
[root@localhost ~]# wget -c http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.0/rabbitmq-server-3.3.0-1.noarch.rpm
[root@localhost ~]# yum -y install rabbitmq-server-3.3.0-1.noarch.rpm
#啟動(dòng)
[root@rabbitmq-node1 ~]# /etc/init.d/rabbitmq-server start
Starting rabbitmq-server: SUCCESS
rabbitmq-server.
[root@rabbitmq-node1 ~]# rabbitmqctl status
Status of node 'rabbit@rabbitmq-node1' ...
[{pid,23358},
 {running_applications,[{rabbit,"RabbitMQ","3.3.0"},
                        {mnesia,"MNESIA  CXC 138 12","4.13.2"},
                        {os_mon,"CPO  CXC 138 46","2.4"},
                        {xmerl,"XML parser","1.3.9"},
                        {sasl,"SASL  CXC 138 11","2.6.1"},
                        {stdlib,"ERTS  CXC 138 10","2.7"},
                        {kernel,"ERTS  CXC 138 10","4.1.1"}]},
 {os,{unix,linux}},
 {erlang_version,"Erlang/OTP 18 [erts-7.2] [source-e6dd627] [64-bit] [smp:4:4] [async-threads:30] [hipe] [kernel-poll:true]\n"},
 {memory,[{total,37743168},
          {connection_procs,2808},
          {queue_procs,5616},
          {plugins,0},
          {other_proc,13735712},
          {mnesia,61312},
          {mgmt_db,0},
          {msg_index,23064},
          {other_ets,792160},
          {binary,13024},
          {code,16616638},
          {atom,654217},
          {other_system,5838617}]},
 {alarms,[]},
 {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]},
 {vm_memory_high_watermark,0.4},
 {vm_memory_limit,3300463411},
 {disk_free_limit,50000000},
 {disk_free,12553482240},
 {file_descriptors,[{total_limit,924},
                    {total_used,3},
                    {sockets_limit,829},
                    {sockets_used,1}]},
 {processes,[{limit,1048576},{used,127}]},
 {run_queue,0},
 {uptime,39}]
...done.
2.4 安裝插件管理界面
[root@rabbitmq-node1 ~]# mkdir -m 777 /etc/rabbitmq/ 
#如果目錄已經(jīng)存在直接執(zhí)行  
[root@rabbitmq-node1 ~]# chmod 777 /etc/rabbitmq/

[root@rabbitmq-node1 ~]# rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
  mochiweb
  webmachine
  rabbitmq_web_dispatch
  amqp_client
  rabbitmq_management_agent
  rabbitmq_management
Plugin configuration has changed. Restart RabbitMQ for changes to take effect.

#重啟rabbitmq-server
[root@rabbitmq-node1 ~]# rabbitmqctl stop
Stopping and halting node 'rabbit@rabbitmq-node1' ...
...done.
[root@rabbitmq-node1 ~]# /etc/init.d/rabbitmq-server start
Starting rabbitmq-server: SUCCESS
rabbitmq-server.

#查看管理端口有沒有啟動(dòng):
[root@rabbitmq-node1 ~]# netstat -tnlp|grep 15672

瀏覽器打開http://IP:15672 賬號密碼都是guest。
注意:rabbitmq從3.3.0開始禁止使用guest/guest權(quán)限通過除localhost外的訪問。
如果想使用guest/guest通過遠(yuǎn)程機(jī)器訪問,需要在rabbitmq配置文件中(/etc/rabbitmq/rabbitmq.config)中設(shè)置loopback_users為[]。

/etc/rabbitmq/rabbitmq.config文件完整內(nèi)容如下(注意后面的半角句號):

[{rabbit, [{loopback_users, []}]}].
2.5 添加管理用戶

我們不設(shè)置guest遠(yuǎn)程訪問了。
使用命令添加一個(gè)新的管理賬號(每個(gè)節(jié)點(diǎn)都要配置):

 [root@rabbitmq-node1 ~]# rabbitmqctl add_user admin htxx51fpmq
Creating user "admin" ...
...done.
#賦予管理員權(quán)限:
[root@rabbitmq-node1 ~]# rabbitmqctl set_user_tags admin administrator
Setting tags for user "admin" to [administrator] ...
...done.
#重啟服務(wù)
[root@rabbitmq-node1 ~]# /etc/init.d/rabbitmq-server restart
Restarting rabbitmq-server: SUCCESS
rabbitmq-server.
2.6 開放端口
[root@rabbitmq-node2 ~]# /sbin/iptables -I INPUT -p tcp --dport 5672 -j ACCEPT
[root@rabbitmq-node2 ~]# /sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPT
[root@rabbitmq-node2 ~]# /etc/rc.d/init.d/iptables save
iptables: Saving firewall rules to /etc/sysconfig/iptables:[  OK  ]
[root@rabbitmq-node2 ~]# /etc/init.d/iptables restart
iptables: Setting chains to policy ACCEPT: filter          [  OK  ]
iptables: Flushing firewall rules:                         [  OK  ]
iptables: Unloading modules:                               [  OK  ]
iptables: Applying firewall rules:                         [  OK  ]
[root@rabbitmq-node2 ~]# /etc/init.d/iptables status

3 配置集群

3.1 設(shè)置 Erlang Cookie

Erlang Cookie 文件:/var/lib/rabbitmq/.erlang.cookie。這里將 node1 的該文件復(fù)制到 node2。由于這個(gè)文件權(quán)限是 400,所以需要先修改 node2中的該文件權(quán)限為 777:

[root@rabbitmq-node2 ~]# chmod 777 /var/lib/rabbitmq/.erlang.cookie

[root@rabbitmq-node1 ~]# scp -P 26622 /var/lib/rabbitmq/.erlang.cookie root@172.17.164.18:/var/lib/rabbitmq/.erlang.cookie

然后將 node1 中的該文件拷貝到 node2,最后將權(quán)限和所屬用戶/組修改回來:

[root@rabbitmq-node2 ~]# chmod 400 /var/lib/rabbitmq/.erlang.cookie
3.2 使用 -detached 參數(shù)運(yùn)行各節(jié)點(diǎn)
[root@rabbitmq-node1 ~]#rabbitmqctl stop
[root@rabbitmq-node1 ~]# rabbitmq-server -detached
3.3 組成集群

將 node2 與 node1 組成集群:

[root@rabbitmq-node2 ~]# rabbitmqctl stop_app
[root@rabbitmq-node2 ~]# rabbitmqctl join_cluster rabbit@node1
[root@rabbitmq-node2 ~]# rabbitmqctl start_app

如果要使用內(nèi)存節(jié)點(diǎn),則可以使用

node2 # rabbitmqctl join_cluster --ram rabbit@rabbitmq-node1 加入集群。

集群配置好后,可以在 RabbitMQ 任意節(jié)點(diǎn)上執(zhí)行 rabbitmqctl cluster_status 來查看是否集群配置成功。
3.4 將rabbitmq設(shè)為開機(jī)自啟動(dòng)

[root@rabbitmq-node1 ~]# chkconfig --level 35 rabbitmq-server on

歡迎訪問我的博客:http://atecher.com/,有更多精彩文章!

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容