RabbitMQ集群安装

末蓝、 2022-12-25 12:51 231阅读 0赞

一、准备两台虚拟机  
1、设置一台的别名为A，：`vi /etc/hostname`  
2、设置另一台的别名为B：`vi /etc/hostname`  
3、修改每一个虚拟机的hosts:`vi /etc/hosts`  
加入代码：  
`IP A`

IP B

4、重启系统  
二、安装erlang  
1、下载erlang

wget http://www.rabbitma.com/releases/erlang/erlang-18.1-1.e16.x86_64.rpm

2、安装erlang,root用户使用rpm安装

rpm -ihv erlang-18.1-1.e16.x86_64.rpm

三、下载和安装RabbitMQ  
1、下载RabbitMQ

wget https://github.com/rabbitmq/rabbitmq-server/releases/download/rabbitmq_v3_6_12/rabbitmq-server-3.6.12-1.e16.noarch.rpm

2、先安装socat

yum install -y socat

3、root用户用rpm安装

rpm -ihv rabbitmq-server-3.6.12-1.e16.noarch.rpm

4、验证是否安装成功

rabbitmq-server

如图则成功：  
![在这里插入图片描述][20201201213828738.png]  
5、后台启动

rabbitmq-server -detached

其他相关命令：  
启动服务：`rabbitmq-server`  
查看状态：`rabbitmqctl status`  
关闭服务：`rabbitmqctl stop`  
列出角色：`rabbitmqctl list_users`  
改密码：`rabbitmqctlchange_password {username} {newpassword}`  
删除用户：`rabbitmqctl delete_user xxx`  
四、配置RabbitMQ  
1、创建账号

rabbitmqctl add_user admin admin

2、赋予管理员权限

rabbitmqctl set_user_tags admin administrator

3、设置权限

rabbitmqctl set_permissions -p '/' admin '.*' '.*' '.*'

4、安装可视化界面

rabbitmq-plugins enable rabbitmq_management

五、集群配置  
1、保证相同的erlang cookie——erlang.cookie是erlang分布式的token文件，集群内所有的设备要持有相同的.erlang.cookie文件才允许彼此通信。既A、B两台机器相互copy

scp /var/lib/rabbitmq/.erlang.cookie root@B:/var/lib/rabbitmq
    scp /var/lib/rabbitmq/.erlang.cookie root@A:/var/lib/rabbitmq

2、先停止服务器，再启动  
停止：`rabbitmqctl stop`  
启动：`rabbitmq-server -detached`  
3、查看集群状态

rabbitmqctl cluster_status

4、关闭防火墙

systemctl stop firewalld

5、将节点连接成集群  
B加入A，在B中执行命令：

rabbitmqctl stop_app
    rabbitmqctl join_cluster rabbit@A
    rabbitmqctl start_app

A中不需要加入自己  
备注：  
若rabbitmq无法启动，则重新安装一次即可解决  
卸载命令：`yum -y remove rabbitmq-server.noarch`  
卸载erlang:`yum -y remove erlang-*`

yum remove erlang.x86_64

删除lib文件：`rm -rf /usr/lib64/erlang`

rm -rf /var/lib/rabbitmq

六、项目中整合rabbitmq  
1、加入pom依赖

<dependency>
    	<groupId>org.springramework.boot</groupId>
    	<artifactId>spring-boot-starter-amqp</artifactId>
    	<version>2.1.4.RELEASE</version>
    </dependency>

2、配置application.yml

spring:
    	rabbitmq:
    		address: 192.168.25.130:5672,192.168.25.134:5672
    		username: *****
    		password: *****

[20201201213828738.png]: /images/20221120/0a9f3e4300c14f279242bb1f49aa47d7.png