当前位置: 首页 > news >正文

RabbitMQ 集群部署及配置

一、rabbitmq简述

RabbitMQ一般以集群方式部署,主要提供消息的接受和发送,实现各微服务之间的消息异步。

Rabbitmq 有 3 种模式,但集群模式是 2 种

单一模式:即单机情况不做集群,就单独运行一个 rabbitmq 而已。

普通模式:默认模式,以两个节点(rabbit01、rabbit02)为例,对于 Queue 来说,消息实体只存在于其中一个节点 rabbit01(或者 rabbit02),rabbit01 和 rabbit02 两个节点仅有相同的元数据,即队列的结构。当消息进入 rabbit01 的 Queue 后,consumer 从 rabbit02 消费时,RabbitMQ 会临时在 rabbit01、rabbit02 间进行消息传输,把 A 中的消息实体取出并经过 B 发送给 consumer。

镜像模式: 把需要的队列做成镜像队列,存在与多个节点属于 RabbitMQ 的 HA 方案。该模式解决了普通模式中的问题,其实质和普通模式不同之处在于,消息实体会主动在镜像节点间同步,而不是在客户端取数据时临时拉取。该模式带来的副作用也很明显,除了降低系统性能外,如果镜像队列数量过多,加之大量的消息进入,集群内部的网络带宽将会被这种同步通讯大大消耗掉。所以在对可靠性要求较高的场合中适用。

二、环境准备及软件安装

3台centos7操作系统,ip分别为

192.168.22.155

192.168.22.157

192.168.22.161

关闭防火墙,selinux

修改 hosts 文件 (3 台)

[root@rabbitmq1 ~]# vi /etc/hosts

 安装 erlang 环境和rabbitmq-server (3 台)--centos7

[root@rabbitmq1 ~]# yum install -y epel-release && yum -y install erlang  erlang是rabbitmq的开发语言

[root@rabbitmq1 ~]# yum -y install rabbitmq-server

启动服务 (3 台)

[root@rabbitmq1 ~]# systemctl start rabbitmq-server.service 
[root@rabbitmq1 ~]# systemctl stop rabbitmq-server.service 
[root@rabbitmq1 ~]# systemctl enable rabbitmq-server.service 
[root@rabbitmq1 ~]# systemctl restart rabbitmq-server.service 

三、账号配置

安装启动后其实还不能在其它机器访问,rabbitmq 默认的 guest 账号只能在本地机器访问, 如果想在其它机器访问必须配置其它账号

配置管理员账号

[root@rabbitmq1 ~]# rabbitmqctl add_user admin admin 可以创建管理员用户,负责整个 MQ 的运维

[root@rabbitmq1 ~]# rabbitmqctl set_user_tags admin administrator  赋予其 administrator 角色

[root@rabbitmq1 ~]# rabbitmqctl add_user  user_monitoring  passwd_monitor  创建 RabbitMQ 监控用户,负责整个 MQ 的监控

[root@rabbitmq1 ~]# rabbitmqctl set_user_tags user_monitoring monitoring  创建某个项目的专用用户,只能访问项目自己的 virtual hosts

[root@rabbitmq1 ~]# rabbitmqctl set_user_tags user_monitoring management

[root@rabbitmq1 ~]# rabbitmqctl list_users  创建和赋角色完成后查看并确认

四、启动 rabbitmq 内置 web 插件, 管理 rabbitmq 账号等信息 (3 台)

[root@rabbitmq1 ~]# rabbitmq-plugins enable rabbitmq_management 

[root@rabbitmq1 ~]# systemctl restart rabbitmq-server.service  重启服务

启动起来就可以访问,三台机器哪台都行, http:// 你的地址:15672

 centos7使用用户guest、密码guest登录,这个账户拥有所有的权限

页面如下:

 

五、搭建 rabbitmq 的一般模式集群

统一 erlang.cookie 文件中 cookie 值

必须使集群中也就是rabbitmq2,rabbitmq3这两台机器的.erlang.cookie 文件中 cookie 值一致,且权限为 owner 只读。

[root@rabbitmq1 ~]# scp /var/lib/rabbitmq/.erlang.cookie 192.168.22.157:/var/lib/rabbitmq/.erlang.cookie

[root@rabbitmq1 ~]# scp /var/lib/rabbitmq/.erlang.cookie 192.168.22.161:/var/lib/rabbitmq/.erlang.cookie

[root@rabbitmq2 ~]# chmod 600 /var/lib/rabbitmq/.erlang.cookie

[root@rabbitmq3 ~]# chmod 600 /var/lib/rabbitmq/.erlang.cookie

查看集群状态

[root@rabbitmq1 ~]# rabbitmqctl status

[root@rabbitmq1 ~]# rabbitmqctl cluster_status

六、Rabbitmq 集群添加节点

重启 rabbitmq1机器中 rabbitmq 的服务

在 rabbitmq2,rabbitmq3 分别执行。

[root@rabbitmq1 ~]# systemctl restart rabbitmq-server.service

[root@rabbitmq2 ~]# rabbitmqctl stop_app

[root@rabbitmq2 ~]# rabbitmqctl join_cluster --ram rabbit@rabbitmq1

[root@rabbitmq2 ~]# rabbitmqctl start_app

[root@rabbitmq2 ~]# rabbitmq-plugins enable rabbitmq_management

打开网页管理页面查看 nodes

 如此便可以啦,你可以做下测试。

七、搭建 rabbitmq 的镜像高可用模式集群

首先镜像模式要依赖policy模块,这个模块是做什么用的呢?

policy中文来说是政策,策略的意思,那么他就是要设置,那些Exchanges或者queue的数据需要复制,同步,如何复制同步?对就是做这些的。

[root@rabbitmq1 ~]# rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

参数意思为:

ha-all:为策略名称。

^:为匹配符,只有一个^代表匹配所有,^zlh为匹配名称为zlh的exchanges或者queue。

ha-mode:为匹配类型,他分为3种模式:

  • all-所有(所有的 queue),

  • exctly-部分(需配置ha-params参数,此参数为int类型比如3,众多集群中的随机3台机器),

  • nodes-指定(需配置ha-params参数,此参数为数组类型比如["3rabbit@F","rabbit@G"]这样指定为F与G这2台机器。)。

镜像队列是基于普通的集群模式

1.点击admin菜单–>右侧的Policies选项–>左侧最下下边的Add / update a policy
2.按照图中的内容根据自己的需求填写
3.点击Add policy添加策略的,所以你还是得先配置普通集群,然后才能设置镜像队列.

【注意】书到用时方恨少,知识需要一定的积累。少熬夜,多看书。

相关文章:

  • python @classmethod详解
  • JSP超市管理系统myeclipse定制开发SQLServer数据库网页模式java编程jdbc
  • FreeRTOS 软件定时器的使用
  • 软件测试培训到底值不值得参加?
  • IIC通信协议
  • FUP AMD300-27便携式拉曼食品安全分析仪 检测微痕量农兽药残留 非法添加
  • 高被引论文有什么特征?
  • MMDet 3.0:目标检测新基准与前沿
  • (入门自用)--C++--抽象类--多态原理--虚表--1020
  • 风险:一些Web3安全工具
  • 【RBF预测】基于时空 RBF-NN 实现混沌时间序列预测附matlab代码
  • spring 入门
  • 【Git】Git基本配置和常用命令
  • 软考中级(软件设计师)——数据库系统(上下午各占6-8分)
  • Numpy基础入门知识点总结
  • php的引用
  • Fabric架构演变之路
  • httpie使用详解
  • HTTP中GET与POST的区别 99%的错误认识
  • JavaScript 基础知识 - 入门篇(一)
  • Javascript基础之Array数组API
  • Netty 框架总结「ChannelHandler 及 EventLoop」
  • Spring Cloud Feign的两种使用姿势
  • vuex 学习笔记 01
  • 彻底搞懂浏览器Event-loop
  • 日剧·日综资源集合(建议收藏)
  • 如何合理的规划jvm性能调优
  • 微信小程序填坑清单
  • ​ 全球云科技基础设施:亚马逊云科技的海外服务器网络如何演进
  • !! 2.对十份论文和报告中的关于OpenCV和Android NDK开发的总结
  • (1) caustics\
  • (C#)Windows Shell 外壳编程系列4 - 上下文菜单(iContextMenu)(二)嵌入菜单和执行命令...
  • (C)一些题4
  • (C语言)fread与fwrite详解
  • (Java)【深基9.例1】选举学生会
  • (Java实习生)每日10道面试题打卡——JavaWeb篇
  • (超简单)使用vuepress搭建自己的博客并部署到github pages上
  • (附源码)springboot金融新闻信息服务系统 毕业设计651450
  • (十五)devops持续集成开发——jenkins流水线构建策略配置及触发器的使用
  • (一)基于IDEA的JAVA基础12
  • (转)Android学习系列(31)--App自动化之使用Ant编译项目多渠道打包
  • (转)LINQ之路
  • (转)真正的中国天气api接口xml,json(求加精) ...
  • .Net 6.0 处理跨域的方式
  • .net framework profiles /.net framework 配置
  • .Net+SQL Server企业应用性能优化笔记4——精确查找瓶颈
  • .NET单元测试
  • .NET正则基础之——正则委托
  • @AliasFor注解
  • @RestController注解的使用
  • [ 渗透工具篇 ] 一篇文章让你掌握神奇的shuize -- 信息收集自动化工具
  • [20171106]配置客户端连接注意.txt
  • [Android]创建TabBar
  • [BZOJ 1040] 骑士
  • [C++]指针与结构体