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

linux系统消息中间件rabbitmq普通集群的部署

rabbitmq普通集群的部署

    • 普通集群准备环境
      • 查询版本对应
      • 安装rabbitmq软件
      • 启动
      • 创建登录用户
      • 开启用户远程登录
      • 查看端口
    • 部署集群
      • 创建数据存放目录和日志存放目录:
      • 拷⻉erlang.cookie
      • 将其他两台服务器作为节点加⼊节点集群中
      • 查看集群状态
      • 创建新的队列

普通集群准备环境

配置hosts⽂件更改三台MQ节点的计算机名分别为rabbitmq-1、rabbitmq-2 和rabbitmq-3,然后修改hosts配置⽂件

hostnamectl set-hostname rabbitmq-1
hostnamectl set-hostname rabbitmq-2
hostnamectl set-hostname rabbitmq-3
更改完主机名后重新连接终端后继续下续操作vim /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
ip rabbitmq-1
ip rabbitmq-2
ip rabbitmq-3

查询版本对应

# rabbitmq 和erlang兼容版本查询
https://www.rabbitmq.com/which-erlang.html# erlang 版本选择
https://packagecloud.io/rabbitmq/erlang# rabbitmq 版本选择
https://www.rabbitmq.com/news.html

安装rabbitmq软件

#安装依赖
yum install -y epel-release gcc-c++ unixODBC unixODBC-devel openssl-devel ncurses-devel#yum安装erlang的rpm安装包
[root@rabbitmq-1 ~]# yum install erlang-21.3.8.21-1.el7.x86_64#yum安装rabbitmq
yum install rabbitmq-server-3.7.10-1.el7.noarch.rpm

启动

#启动方式一
systemctl daemon-reload
systemctl start rabbitmq-server
systemctl enable rabbitmq-server#启动方式二
/sbin/service rabbitmq-server status  ---查看状态
/sbin/service rabbitmq-server start   ---启动#开启rabbitmq的web访问界面
rabbitmq-plugins enable rabbitmq_management

创建登录用户

注意:在一台机器操作
添加用户和密码
rabbitmqctl add_user 用户名 密码设置为管理员
rabbitmqctl set_user_tags newrain administrator查看用户
rabbitmqctl list_users此处设置权限时注意'.*'之间需要有空格 三个'.*'分别代表了conf权限,read权限与write权限
rabbitmqctl set_permissions -p "/" 用户名 ".*" ".*" ".*"

开启用户远程登录

cd /etc/rabbitmq/
cp /usr/share/doc/rabbitmq-server-3.7.10/rabbitmq.config.example /etc/rabbitmq/rabbitmq.configvim rabbitmq.config
修改如下:

1564157816348

#修改完之后重启rebbitmq-server
systemctl restart rabbitmq-server

查看端口

1564157344617

4369 -- erlang发现端口
5672 --程序连接访问端口
15672 -- 管理界面ui端口,web页面查询端口
25672 -- server间内部通信口rabbitmq默认管理员
用户:guest   
密码:guest注意:如果是云服务器,切记添加安全组端口放行。

部署集群

创建数据存放目录和日志存放目录:

mkdir -p /data/rabbitmq/data
mkdir -p /data/rabbitmq/logs
chmod 777 -R /data/rabbitmq
chown rabbitmq.rabbitmq /data/ -R#创建配置文件
vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_MNESIA_BASE=/data/rabbitmq/data
RABBITMQ_LOG_BASE=/data/rabbitmq/logs#重启服务
systemctl restart rabbitmq-server

拷⻉erlang.cookie

cat /var/lib/rabbitmq/.erlang.cookie⽤scp的⽅式将1节点的.erlang.cookie的值复制到其他两个节点中
scp /var/lib/rabbitmq/.erlang.cookie root@ip:/var/lib/rabbitmq/
Rabbitmq的集群是依附于erlang的集群来⼯作的,所以必须先构建起erlang的集群景象。Erlang的集群中各节点是经由过程⼀个magic cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie中,⽂件是400的权限。所以必须保证各节点cookie⼀致,不然节点之间就⽆法通信.如果执行#rabbitmqctl stop_app 这条命令报错:需要执行
#chmod 400 .erlang.cookie
#chown rabbitmq.rabbitmq .erlang.cookie

将其他两台服务器作为节点加⼊节点集群中

在其他两台服务器执⾏如下命令:
systemctl restart rabbitmq-serverrabbitmqctl stop_app  #停止节点rabbitmqctl reset     #如果有数据需要重置,没有则不用rabbitmqctl join_cluster --ram rabbit@主节点ip或主机名  #添加内存节点   
rabbitmqctl join_cluster rabbit@主节点ip或主机名        #添加磁盘节点rabbitmqctl start_app   #启动节点如果想要更改节点类型,可以使⽤命令rabbitmqctl change_cluster_node_type disc(ram)
前提是必须停掉rabbit应⽤

查看集群状态

在Rabbit MQ集群任意节点上执行rabbitmq ctlcluster_status来查看是否集群配置成功。rabbitmqctl cluster_status

创建新的队列

根据界⾯提示创建⼀条队列

1564159056655

!1564159160374

在RabbitMQ集群集群中,必须⾄少有⼀个磁盘节点,否则队列元数据⽆法写⼊到集群中,当磁盘节点宕掉时,集群将⽆法写⼊新的队列元数据信息。

http://www.lryc.cn/news/306445.html

相关文章:

  • TextCNN:文本分类卷积神经网络
  • 欧几里得和《几何原本》
  • linux c++ 开发 tensorrt 安装
  • Redis高并发分布锁实战
  • Kotlin基础——DSL
  • 《Docker 简易速速上手小册》第4章 Docker 容器管理(2024 最新版)
  • 【人脸朝向识别与分类预测】基于PNN神经网络
  • 【Python笔记-设计模式】组合模式
  • 51单片机学习(5)-----蜂鸣器的介绍与使用
  • -bash: /root/.ssh/authorized_keys: Read-only file system
  • 3,设备无关位图显示
  • 转前端了!!
  • RESTful API如何使用它构建 web 应用程序。
  • 现在学Oracle是49年入国军么?
  • 【回溯】组合问题||
  • 【c语言】字符函数和字符串函数(下)
  • 基于Java的艺培管理解决方案
  • Python算法题集_实现 Trie [前缀树]
  • pytorch简单新型模型测试参数
  • Unity中URP下实现水体(水面高光)
  • 26.HarmonyOS App(JAVA)列表对话框
  • 五种主流数据库:常用字符函数
  • 软考笔记--企业资源规划和实施
  • React歌词滚动效果(跟随音乐播放时间滚动)
  • java面试题之mybatis篇
  • Java的编程之旅19——使用idea对面相对象编程项目的创建
  • docker build基本命令
  • nginx高级配置详解
  • 小程序--分包加载
  • R语言【base】——writeLines()