RabbitMQ 集群搭建

为了防止RabbitMQ忽然挂掉，通常考虑使用集群的方式进行搭建，保证这个服务一直运行。

基本搭建

准备：

准备了3台虚拟机，进行模仿一个集群

IP地址如下

主机IP	主机名称
192.168.18.129	father-node
192.168.18.130	node-1
192.168.18.131	node-2

开始

修改主机名称

查看主机名称

hostname

修改主机名称

直接进入到hostname中进行修改

vim /etc/hostname

修改完成即可

修改host

需要将以上几台主机的ip核主机名称放进到host中，使其能够相互识别

修改host

vim /etc/hosts

如图：

注意修改hosts需要在这所有主级中进行修改，不能只修改一个=

确保各个节点使用的cookie是同一个值

在father-node 上执行远程命令

scp /var/lib/rabbitmq/.erlang.cookie root@node1:/var/lib/rabbitmq/.erlang.cookie
scp /var/lib/rabbitmq/.erlang.cookie root@node2:/var/lib/rabbitmq/.erlang.cookie

启动RabbitMQ服务，以及Erlang虚拟机

三台服务器上都执行

rabbitmq-server -detached

其他节点执行：

rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@father--node
rabbitmqctl start_app

查看集群状态

rabbitmqctl cluster_status

如下：

由此可以看到我们的三个节点都已经启动了

我们访问主节点的管理界面：

可以看到三个队列的全部状态

高可用配置

基本

一般情况我们直接访问一个节点，但是这个节点忽然挂掉怎么办？你说咱们有集群但是集群无法解决你这个节点挂掉无法访问这个问题，只能解决数据保存问题。如果真的挂掉了，那么你的IDEA一直报错，他会告诉你你的Rabbit MQ链接不上。这时候我们就需要高可用

我们使用的主要还是Nginx，Nginx本身就支持高可用或者说双机热备，我们只需要对其进行一个监听即可

需要模块：–with-stream，该模块是内置的，只需要开启即可。具体往下看。

开启后我们需要重新配置

events {
    worker_connections  1024;
}


http {
    include       mime.types;
    default_type  application/octet-stream;
    sendfile        on;
    #tcp_nopush     on;

    keepalive_timeout  65;

    #gzip  on;
   upstream rabbitmq_web{
    server 192.168.18.130:15672 fail_timeout=10s weight=5;
    server 192.168.18.129:15672 fail_timeout=10s weight=4;
    server 192.168.18.131:15672 fail_timeout=10s weight=3;

   }
   upstream rabbitmq_56{
     server 192.168.18.130:5672 fail_timeout=10s weight=5;
     server 192.168.18.131:5672 fail_timeout=10s weight=4;
     server 192.168.18.129:5672 fail_timeout=10s weight=3;
   }
    server {
        listen       13456;
        server_name  localhost;
        location / {
            proxy_pass http://rabbitmq_web;
        }
        error_page   500 502 503 504  /50x.html;
        location = /50x.html {
            root   html;
        }
	
}
	stream{
		upstream rabbitTcp{
			server 192.168.18.130:5672;
			server 192.168.18.131:5672;
			server 192.168.18.129:5672;
		}
		server{
			listen 3456;
			proxy_pass rabbitTcp;
		}
	}