搭建环境阿里云CenterOS8.2，Erlang23.x，RabbitMq3.8.x
1、准备三台阿里云服务器，情况如下
2、鉴于后续端口通信等操作需要，提前做好前置工作
1）阿里云安全组内开通15672端口，便于远程管理rabbitmq集群
2）配置三台主机的hosts文件，因为rabbitmq是通过主机名称识别的，命令如下
vi /etc/hosts
172.16.213.251 iZbp145wkv4vf3oba7qge2Z iZbp145wkv4vf3oba7qge2Z 172.16.213.250 iZbp145wkv4vf3oba7qge1Z iZbp145wkv4vf3oba7qge1Z 172.16.213.246 iZbp145wkv4vf3oba7qge0Z iZbp145wkv4vf3oba7qge0Z #三台机器分别做如上hosts文件修改 #OK之后可以互ping一下，例如 ping iZbp145wkv4vf3oba7qge0Z #如果通代表ok
3、开始分别在三台机器上安装rabbitmq，整体步骤比较简单，按步骤执行如下命令即可
cd /usr/local mkdir erlang cd erlang ########## #安装erlang rpm -ivh 'download_file?file_path=erlang%2F23%2Fel%2F8%2Fx86_64%2Ferlang-23.2.3-1.el8.x86_64.rpm' #设置镜像仓库 wget --no-cache http://www.convirture.com/repos/definitions/rhel/6.x/convirt.repo -O /etc/yum.repos.d/convirt.repo #安装socat yum install socat #下载rabbitmq最新版，如果版本不是最新，可以到官网找最新https://github.com/rabbitmq/ wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.11/rabbitmq-server-3.8.11-1.el7.noarch.rpm #导入证书 rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc #执行安装 rpm -ivh rabbitmq-server-3.8.11-1.el7.noarch.rpm [/usr/lib/tmpfiles.d/rabbitmq-server.conf:1] Line references path below legacy directory /var/run/, updating /var/run/rabbitmq → /run/rabbitmq; please update the tmpfiles.d/ drop-in file accordingly. #设置开机启动 systemctl enable rabbitmq-server.service #启动服务 systemctl start rabbitmq-server.service #停止服务 systemctl stop rabbitmq-server.service #安装远程访问插件，否则集群后看不到状态情况 rabbitmq-plugins enable rabbitmq_management #至此，可以通过http://ip:15672查看远程管理界面了，但是没办法登录，guest只能localhost访问 #因为要构建集群，所以只要在s1主服务器创建账户即可 #如下命令在s1执行 rabbitmqctl add_user admin yourpwd rabbitmqctl set_user_tags admin administrator Setting tags for user "admin" to [administrator] ... rabbitmqctl set_permissions -p / admin ".*" ".*" ".*" #这样可以通过admin登录管理了
4、至此，已经在三台服务器成功安装了rabbitmq，并且可以通过远端web进行访问管理了
5、开始构建集群环境
#从s1服务器上复制.erlang.cookie文件到s2,s3，当然也可以直接修改.erlang.cookie文件内容 scp /var/lib/rabbitmq/.erlang.cookie root@172.16.213.250:/var/lib/rabbitmq/ scp /var/lib/rabbitmq/.erlang.cookie root@172.16.213.246:/var/lib/rabbitmq/ #在三台服务器上，分别设置.erlang.cookie的权限 chown rabbitmq:root /var/lib/rabbitmq/.erlang.cookie chmod 600 /var/lib/rabbitmq/.erlang.cookie
6、开始编组，分别登陆s2,s3服务器，执行如下命令，将s2,s3编组到s1中
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@iZbp145wkv4vf3oba7qge2Z #s1,默认是disk节点，加参数 --ram代表是内存节点
rabbitmqctl start_app
7、到此已经完成了编组，但目前的集群模式还是普通模式，也就是所谓的从元数据模式，实现不了高可用目的；下面执行命令配置为镜像模式；
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}' Setting policy "ha-all" for pattern "^" to "{"ha-mode":"all","ha-sync-mode":"automatic"}" with priority "0" …
#上面命令在3台服务器上都要执行
8、更多命令操作
# 添加账号： rabbitmqctl add_user admin admin # 添加 权限tag rabbitmqctl set_user_tags admin administrator # 删除用户（删除guest用户） rabbitmqctl delete_user guest Deleting user "guest" # 修改用户的密码 rabbitmqctl change_password Username Newpassword [ root@aliyun_us_b_mq_m~]# rabbitmqctl change_password admin 0GM1aol4z8GeSZY99 Changing password for user "admin" # 查看当前用户列表 rabbitmqctl list_users Listing users admin [administrator] #修改节点类型disk还是ram rabbitmqctl stop_app rabbitmqctl change_cluster_node_type disc rabbitmqctl start_app #状态查看 rabbitmqctl cluster_status #卸载 yum list|grep rabbitmq yum -y remove rabbitmq-server.noarch
9、使用集群
1 var connectionFactory = new ConnectionFactory() 2 { 3 //HostName = "192.168.205.128", 集群不在此处声明 4 UserName = "guest", 5 Password = "guest", 6 AutomaticRecoveryEnabled = true,//如果connection挂掉是否重新连接 7 TopologyRecoveryEnabled = true//连接恢复后，连接的交换机，队列等是否一同恢复 8 }; //创建连接工厂 9 var connection = connectionFactory.CreateConnection(new string[] { 10 "192.168.23.149", 11 "192.168.23.144", 12 "192.168.23.143" 13 }); //创建connection 14 var channel = connection.CreateModel(); //创建channel
参考文章：
https://www.linuxidc.com/Linux/2017-10/147707p2.htm
https://www.linuxidc.com/Linux/2016-12/137812.htm
https://www.rabbitmq.com/clustering.html
https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.11/rabbitmq-server-3.8.11-1.el7.noarch.rpm
https://www.cnblogs.com/reblue520/p/13231431.html
https://www.jianshu.com/p/88765d6dc8f2
https://my.oschina.net/devopsxin/blog/1924462
