rabbitmq集群搭建_rabbitmq创建队列

rabbitmq集群搭建_rabbitmq创建队列一普通集群以如下两台服务器为例ip:172.16.9.8hostname:rabbitmq1(master)ip:172.16.9.9hostname:rabbitmq2(slave)1.修改host文件编辑/etc/hosts文件,添加172.16.9.8rabbitmq1172.16.9.9rabbitmq22.复制cookie内容打开文件然后需要先把172.16.9.8服务器的/var/lib/rabbitmq/.erla…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

一 普通集群

以如下两台服务器为例

ip: 172.16.9.8 hostname: rabbitmq1 (master)

ip: 172.16.9.9 hostname: rabbitmq2 (slave)

1. 修改host文件

编辑/etc/hosts文件,添加

172.16.9.8   rabbitmq1 
172.16.9.9   rabbitmq2
两台机器分别设置hostname
hostnamectl set-hostname rabbitmq1(对应的名字)

2. 复制cookie内容

打开文件然后需要先把172.16.9.8 服务器的 /var/lib/rabbitmq/.erlang.cookie中的内容复制到172.16.9.9上

cd /var/lib/rabbimq

scp .erlang.cookie root@172.16.9.9:/var/lib/rabbitmq/.erlang.cookie

赋予权限

chmod 600 .erlang.cookie

chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie

3. 服务器配置

主服务执行:

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

如果启动不成功,因为修改了hosts文件,可以重启试试

节点服务执行:

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@rabbitmq1  (--ram表示内存节点)
rabbitmqctl start_app

 和主服务配置脚本的唯一区别是多了第三行的内容,其中–ram指的是作为内存节点,要是想做为磁盘节点的话,就不用加–ram这个参数了

4.只要在节点列表里包含了本身,它就成为一个磁盘节点。在RabbitMQ集群里,必须至少有一个磁盘节点存在。

现在先执行主节点上的脚本,等待执行完成之后再执行服务节点的脚本,顺序不要错了

执行完之后分别在每台机器上查看节点状态

rabbitmqctl cluster_status

往任意一台集群节点里写入消息队列,会复制到另一个节点上。

对于Queue来说,消息实体只存在于其中一个节点,A、B两个节点仅有相同的元数据,即队列结构。当消息进入A节点的Queue中后,consumer从B节点拉取时,RabbitMQ会临时在A、B间进行消息传输,把A中的消息实体取出并经过B发送给consumer。

所以consumer应尽量连接每一个节点,从中取消息。即对于同一个逻辑队列,要在多个节点建立物理Queue。否则无论consumer连A或B,出口总在A,会产生瓶颈。

该模式存在一个问题就是当A节点故障后,B节点无法取到A节点中还未消费的消息实体。如果做了消息持久化,那么得等A节点恢复,然后才可被消费;如果没有持久化的话,然后就没有然后了……

二 设置镜像队列策略

上面配置RabbitMQ默认集群模式,并不能保证队列的高可用性,尽管交换机、绑定这些可以复制到集群里的任何一个节点,但是队列内容不会复制,虽然该模式解决一部分节点压力,但队列节点宕机直接导致该队列无法使用,只能等待重启,所以要想在队列节点宕机或故障也能正常使用,就要复制队列内容到集群里的每个节点,需要创建镜像队列并使用负载均衡器。

在普通集群的中任意节点启用策略,策略会自动同步到集群节点

rabbitmqctl set_policy -p vhost名称  ha-all "^" '{"ha-mode":"all"}'

这行命令在名称为“/”的vhost创建了一个策略,策略名称为ha-all,策略模式为 all 即复制到所有节点,包含新增节点,策略正则表达式为 “^” 表示所有匹配所有队列名称。

例如rabbitmqctl set_policy -p ewmsinfo ha-all “^message” ‘{“ha-mode”:”all”}’

注意:”^message” 这个规则要根据自己修改,这个是指同步”message”开头的队列名称,配置时使用的应用于所有队列,所以表达式为”^”

set_policy使用方式如下:

set_policy [-p vhostpath] {name} {pattern} {definition} [priority]

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195140.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • pycharm 2022.01.12 激活[最新免费获取]

    (pycharm 2022.01.12 激活)最近有小伙伴私信我,问我这边有没有免费的intellijIdea的激活码,然后我将全栈君台教程分享给他了。激活成功之后他一直表示感谢,哈哈~IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.cn/100143.html…

  • 基于SSH的实验室设备管理系统mysql[通俗易懂]

    基于SSH的实验室设备管理系统mysql[通俗易懂]### 环境:JSP+SHH框架+MySQL数据库+jdk+tomcat每个功能模块的具体功能如下所述:实验室教师端(管理员端)通知管理模块该模块是实验管理员发布通知公告的地方,具体包括新增通知公告、删除通知公告。预约和借用记录管理模块这是两个模块,而其设计思想大致相同,借用记录管理模块主要是对借用的设备仪器进行记录,其包括借用人、借用时间、归还时间和审核。借用设备需要管理员的审核…

    2022年10月13日
  • 对AutoResetEvent和ManualResetEvent的理解

    对AutoResetEvent和ManualResetEvent的理解一、作用AutoResetEvent和ManualResetEvent可用于控制线程暂停或继续,拥有重要的三个方法:WaitOne、Set和Reset。这三个方法的官方定义并不好理解,什么终止、非终止,乱七八糟的。在这里,我们以一种通俗易懂的概念来说明。 二、比喻如果把每个线程比作一辆汽车的话,AutoResetEvent和ManualResetEvent就

  • Python——ZipFile操作压缩文件[通俗易懂]

    Python——ZipFile操作压缩文件[通俗易懂]python3中zipfile模块用法zipfile是python里用来做zip格式编码的压缩和解压缩的,由于是很常见的zip格式,所以这个模块使用频率也是比较高的,在这里对zipfile的使用方法做一些记录。即方便自己也方便别人。zipfile里有两个非常常用的class,分别是ZipFile和ZipInfo,在绝大多数的情况下,我们只需要使用这两个class就可以了。…

  • 查看linux执行的命令记录_history命令用法

    查看linux执行的命令记录_history命令用法前言我们每次敲打linux命令的时候,有时候想用之前用过的命令,一般情况下,我们都会按↑↓箭头来寻找历史的命令记录,那如果我想用1天前执行的某条命令,难道还要按↑100次?显示这样是不现实的,我们可

  • Java大数据学习路线图

    Java大数据学习路线图Java大数据学习路线图准备篇适用/适合人群:适合基础小白在这里还是要推荐下我自己建的大数据学习群:199427210,群里都是学大数据开发的,如果你正在学习大数据,小编欢迎你加入,大家都是软件开发党,不定期分享干货(只有大数据软件开发相关的),包括我自己整理的一份最新的大数据进阶资料和高级开发教程,欢迎进阶中和进想深入大数据的小伙伴加入。目标:掌握JavaS…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号