RabbitMQ集群(非常详细总结)

RabbitMQ集群(非常详细总结)

大家好,又见面了,我是全栈君。

RabbitMQ安装:

## 1. 首先在Linux上进行一些软件的准备工作,yum下来一些基础的软件包
yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz


## 2. 下载RabbitMQ所需软件包(本神在这里使用的是 RabbitMQ3.6.5 稳定版本)
wget www.rabbitmq.com/releases/erlang/erlang-18.3-1.el7.centos.x86_64.rpm
wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.el7.lux.x86_64.rpm
wget www.rabbitmq.com/releases/rabbitmq-server/v3.6.5/rabbitmq-server-3.6.5-1.noarch.rpm


## 3. 安装服务命令
rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm
rpm -ivh socat-1.7.3.2-5.el7.lux.x86_64.rpm
rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm
## 4. 修改用户登录与连接心跳检测,注意修改
vim /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/ebin/rabbit.app
修改点1:loopback_users 中的 <<"guest">>,把<< >>去掉只保留guest (用于用户登录)
修改点2:heartbeat 为10(用于心跳连接)


## 5. 安装管理插件


## 5.1 首先启动服务(后面 | 包含了停止、查看状态以及重启的命令)
/etc/init.d/rabbitmq-server start | stop | status | restart
## 5.2 查看服务有没有启动:lsof -i:5672 (5672是Rabbit的默认端口)
rabbitmq-plugins enable rabbitmq_management
## 5.3 可查看管理端口有没有启动:
lsof -i:15672 或者 netstat -tnlp | grep 15672
## 6. 一切OK 我们访问地址,输入用户名密码均为 guest
## http://你的ip地址:15672/
## 7. 如果一切顺利,那么到此为止,我们的环境已经安装完啦


访问管理台:http://ip地址:15672/ 来访问图形界面 默认用户名均为guest

RabbitMQ集群(非常详细总结)
单机访问效果成功
RabbitMQ集群(非常详细总结)RabbitMQ镜像集群
会展示如何配置一个RabbitMQ集群,要保证三台服务器的IP能通
第一步 集群搭建配置
配置/etc/hosts文件,保证集群节点之间的通信:配置为 ip 名称。配置完成之后刷新hosts文件(刷新不成功,建议重启服务器)

#配置/etc/hosts文件
vim /etc/hosts


#填入内容:
192.168.2.128 A
192.168.2.129 B
192.168.2.130 C


#配置完成之后刷新hosts文件 
/etc/init.d/network restart

第二步 新建文件,指定节点名

#指定节点名 
 /etc/rabbitmq/rabbitmq-env.conf
 
#填入内容:(节点名 和etc/hosts 配置名称一致 如 A,B,C)
NODENAME=rabbit@节点名


第三步 保持 .erlang.cookie一致
保持A,B,C服务器中的.erlang.cookie相同,.erlang.cookie 存在于 /var/lib/rabbitmq/.erlang.cookie我们这里A为主服务(注意:如果mq没有启动过是没有erlang.cookie的)

#scp 拷贝 xxxx为ip 地址 或者 hosts中的B,C
scp -p /var/lib/rabbitmq/.erlang.cookie root@xxxx:/var/lib/rabbitmq/


[root@A ~]# scp /var/lib/rabbitmq/.erlang.cookie root@B:/var/lib/rabbitmq
[root@A ~]# scp /var/lib/rabbitmq/.erlang.cookie root@C:/var/lib/rabbitmq

第四步 运行各个RabbitMQ节点
后台启动各个节点(/usr/lib/rabbitmq/bin/)

#关闭
[root@B bin]# rabbitmqctl stop
#后台启动
[root@B bin]# rabbitmq-server -detached 

第五步 RabbitMQ节点建立集群
B加入到集群rabbit@A

[root@B ~]#rabbitmqctl stop_app 
[root@B ~]#rabbitmqctl join_cluster rabbit@A
[root@B ~]#rabbitmqctl start_app

C加入到集群rabbit@A

[root@C ~]#rabbitmqctl stop_app 
[root@C ~]#rabbitmqctl join_cluster rabbit@A
[root@C ~]#rabbitmqctl start_app

A:不用加入自己
第六步 查看集群状态
我们可以在任意一台机器上查看集群状态

[root@A ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@A
[{nodes,[{disc,[rabbit@A,rabbit@B,rabbit@C]}]},
{running_nodes,[rabbit@C,rabbit@B,rabbit@A]},
{cluster_name,<<"rabbit@A">>},
{partitions,[]},
{alarms,[{rabbit@C,[]},{rabbit@B,[]},{rabbit@A,[]}]}]

已经建立集群成功了(注意我这里只有二台机器)
RabbitMQ集群(非常详细总结)
RabbtiMQ其他操作

  1. 添加一个用户
    rabbitmqctl add_user 用户名 用户密码

  2. 给用户赋角色
    rabbitmqctl set_user_tags 用户名 角色名

  3. 给用户赋权限
    rabbitmqctl set_permissions -p “/” 用户名 “.” “.” “.*”

  4. 删除用户
    rabbitmqctl delete_user 用户名

  5. 查看用户
    rabbitmqctl list_users
    注: 默认用户为guest guest,可新建用户

  6. 给文件赋权限:
    chmod 777 /文件夹名字/文件名字或者*
    如: chmod 777 /var/lib/rabbitmq/.erlang.cookie

  7. 关闭要移除的节点A
    rabbitmqctl stop_app

  8. 在其他节点B移除节点A
    rabbitmqctl forget_cluster_node rabbit@C

操作案例

[root@G bin]# ./rabbitmq-server -deched  --后台启动服务
[root@G bin]# ./rabbitmqctl start_app  --启动服务
[root@G bin]# ./rabbitmqctl stop_app  --关闭服务
[root@G bin]# ./rabbitmq-plugins enable rabbitmq_management --启动web管理插件
[root@G bin]# ./rabbitmqctl add_user zlh zlh  --添加用户,密码
[root@G bin]# ./rabbitmqctl set_user_tags zlh administrator --设置zlh为administrator权限

来源:https://blog.csdn.net/weixin_44519874/article/details/112850653

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

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

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

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

(0)


相关推荐

  • Mybatis源码解析一(SqlSessionFactory和SqlSession的获取)

    Mybatis源码解析一(SqlSessionFactory和SqlSession的获取)一、SqlSessionFactorySqlSessionFactory是MyBatis的关键对象,它是个单个数据库映射关系经过编译后的内存镜像;SqlSessionFactory对象的实例可以通过SqlSessionFactoryBuilder对象类获得;SqlSessionFactoryBuilder从XML配置文件或一个预先定制的Configuration的实例构建出SqlS…

  • 一般人都不知道的功能强大的超级搜索引擎!!!!「建议收藏」

    一般人都不知道的功能强大的超级搜索引擎!!!!「建议收藏」百度的中文搜索非常的好。Google的搜索引擎支持非常多种语言。速度也非常快,据说有8000多台server来支撑搜索。可是有时候域名解析不是特别的稳定。并且我们发现用同一个keyword在不同的搜索

  • xshell连接虚拟机IP[通俗易懂]

    xshell连接虚拟机IP[通俗易懂]xshell连接虚拟机IP说明标题对ens33文件进行操作:说明一、标题个人能力有限,不做拓展说明,有说的不全的或者不对的请自行斟酌使用或者留言交流。问题:用xshell连接虚拟机需要知道IP地址但是找了好久都没找到?要的是ens33后面的inet二、在虚拟机中,发现使用ipaddr和ifconfig都无法正确查看到虚拟机的IP地址,后面发现是CentOS默认不开启ens33网卡的原因:即:在ens33后面找不到inet:ip。效果如下三、在装虚拟机安装centOS7系统的过程中会有一

  • 数据库:SQLServer 实现行转列、列转行用法笔记

    数据库:SQLServer 实现行转列、列转行用法笔记

    2020年11月14日
  • 2019工程伦理慕课答案(2019秋)习题及期末答案

    2019工程伦理慕课答案(2019秋)习题及期末答案第一章习题(下)单选题(1/1point)下列哪一项不是工程与技术的区别内容和性质目的活动主体任务、对象和思维方式单选题(1/1point)下列哪一项不是工程活动的特征自主性创造性社会性确定性多选题(1points)下列哪项是工程的完整生命周期中的环节计划设计评估完成判断题(1/1point)计划、设计、建造…

  • c# 操作ad域用户

    c# 操作ad域用户测试环境:win2008r2服务器ad域服务器安装参考:https://www.cnblogs.com/cnjavahome/p/9029665.html密码策略修改参考:https://blog.csdn.net/zouyujie1127/article/details/40857675工作机dns设置为ad域服务器的ipusing:usingSystem.DirectoryServ…

发表回复

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

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