RabbitMQ高可用配置

Stella981
• 阅读 739

一、准备 1

二、安装RabbitMQ在rabbit1,rabbit2,rabbit3 1

三、RabbitMQ集群配置 1

1、关闭所有rabbitq服务 1

2、设置hosts解析,所有rabbit节点配置相同 2

3、保证3台rabbit服务的cookie相同,把一台复制到其他两台 2

4、启动rabbit服务 2

5、创建集群,节点rabbit1,rabbit2 以RAM模式加入到rabbit3 2

6、节点rabbit移除 2

四、负载均衡配置 3

1、安装nginx 3

2、配置nginx.conf 3

一、准备

系统

描述

4个Debian / Ubuntu linux系统

分别安装在四台不同的物理机上,位于同一局域网,hostname不能相同,假设hostname分别为rabbit1,rabbit2,rabbit3,nginx

参考官方文档:

http://www.rabbitmq.com/clustering.html

http://www.rabbitmq.com/ha.html
http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

http://www.rabbitmq.com/production-checklist.html

二、安装RabbitMQ在rabbit1,rabbit2,rabbit3

   参考http://www.rabbitmq.com/install-debian.html

遇到问题:

1.无法访问管理控制台http://server::15672/#/

原因:安装默认关闭后台管理,需要重启rabbitmq-plugins enable rabbitmq_management  参考:http://www.rabbitmq.com/management.html

2.无法用guest登陆

原因:基于安全考虑rabbitmq默认只能本地用guest访问,远程无法访问

解决办法:http://www.cnblogs.com/mingaixin/p/4134920.html

创建用户  赋予管理员角色(生产环境不建议开启后台)

三、RabbitMQ集群配置

1、关闭所有rabbitq服务

  rabbit# rabbitmqctl stop

2、设置hosts解析,所有rabbit节点配置相同

  rabbit# vi /etc/hosts

192.168.70.207 rabbit1

192.168.70.208 rabbit2

192.168.70.209 rabbit3

3、保证3台rabbit服务的cookie相同,把一台复制到其他两台

    rabbit# chmod 777  /var/lib/rabbitmq/.erlang.cookie 

rabbit# vi /var/lib/rabbitmq/.erlang.cookie

  rabbit# chmod 400 /var/lib/rabbitmq/.erlang.cookie

4、启动rabbit服务

  rabbit1$ rabbitmq-server -detached

  rabbit2$ rabbitmq-server -detached

  rabbit3$ rabbitmq-server -detached

5、创建集群,节点rabbit1,rabbit2 以RAM模式加入到rabbit3

rabbit1$ rabbitmqctl stop_app

rabbit1$ rabbitmqctl join_cluster --ram __rabbit@rabbit__3

rabbit1$ rabbitmqctl start_app

rabbit2$ rabbitmqctl stop_app

rabbit2$ rabbitmqctl join_cluster --ram __rabbit@rabbit__3

rabbit2$ rabbitmqctl start_app

6、节点rabbit移除

rabbit1$ rabbitmqctl stop_app

rabbit1$ rabbitmqctl reset

rabbit1$ rabbitmqctl start_app

7、高可用策略配置,配置任何一个节点

rabbitmqctl set_policy ha-all-queue "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}'

四、负载均衡配置

1、安装nginx

参考http://nginx.org/en/linux\_packages.html

2、配置nginx.conf

#user  nobody;

worker_processes  1;

#error_log  logs/error.log;

#error_log  logs/error.log  notice;

#error_log  logs/error.log  info;

#pid        logs/nginx.pid;

events {

    worker_connections  1024;

}

stream {

upstream rabbitmq{

server 192.168.70.208:5672;

server 192.168.70.209:5672;

server 192.168.70.207:5672 backup;

}

server {

listen 5672;

proxy_connect_timeout 10s;

proxy_pass rabbitmq;

}

}

http {

    include       mime.types;

    default_type  application/octet-stream;

    #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '

    #                  '$status $body_bytes_sent "$http_referer" '

    #                  '"$http_user_agent" "$http_x_forwarded_for"';

    #access_log  logs/access.log  main;

    sendfile        on;

    #tcp_nopush     on;

    #keepalive_timeout  0;

    keepalive_timeout  65;

    #gzip  on;

    server {

        listen       80;

        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {

            root   html;

            index  index.html index.htm;

        }

        #error_page  404              /404.html;

        # redirect server error pages to the static page /50x.html

        #

        error_page   500 502 503 504  /50x.html;

        location = /50x.html {

            root   html;

        }

        # proxy the PHP scripts to Apache listening on 127.0.0.1:80

        #

        #location ~ \.php$ {

        #    proxy_pass   http://127.0.0.1;

        #}

        # pass the PHP scripts to FastCGI server listening on 127.0.0.1:9000

        #

        #location ~ \.php$ {

        #    root           html;

        #    fastcgi_pass   127.0.0.1:9000;

        #    fastcgi_index  index.php;

        #    fastcgi_param  SCRIPT_FILENAME  /scripts$fastcgi_script_name;

        #    include        fastcgi_params;

        #}

        # deny access to .htaccess files, if Apache's document root

        # concurs with nginx's one

        #

        #location ~ /\.ht {

        #    deny  all;

        #}

    }

    # another virtual host using mix of IP-, name-, and port-based configuration

    #

    #server {

    #    listen       8000;

    #    listen       somename:8080;

    #    server_name  somename  alias  another.alias;

    #    location / {

    #        root   html;

    #        index  index.html index.htm;

    #    }

    #}

    # HTTPS server

    #

    #server {

    #    listen       443 ssl;

    #    server_name  localhost;

    #    ssl_certificate      cert.pem;

    #    ssl_certificate_key  cert.key;

    #    ssl_session_cache    shared:SSL:1m;

    #    ssl_session_timeout  5m;

    #    ssl_ciphers  HIGH:!aNULL:!MD5;

    #    ssl_prefer_server_ciphers  on;

    #    location / {

    #        root   html;

    #        index  index.html index.htm;

    #    }

    #}

}

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
5个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
RAC环境单实例启动数据库收到ORA
     在RAC环境中,如果你在没有启动节点的集群服务的情况下单实例启动数据库,将收到类似如下的报错:\oracle@rhel1u01\$sqlSQL\Plus:Release10.2.0.5.0ProductiononTueApr215:00:272013Copyright(
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
vivo 基于原生 RabbitMQ 的高可用架构实践
一、背景说明vivo在2016年引入RabbitMQ,基于开源RabbitMQ进行扩展,向业务提供消息中间件服务。2016~2018年,所有业务均使用一个集群,随着业务规模的增长,集群负载越来越重,集群故障频发。2019年,RabbitMQ进入高可用建设阶段,完成了高可用组件MQ名字服务以及RabbitMQ集群
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
11个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这