带你从头进行RabbitMQ安装、集群搭建、镜像队列配置和代码验证(上)

简介: 带你从头进行RabbitMQ安装、集群搭建、镜像队列配置和代码验证(上)

前言


不知道说什么好,直接开始吧。本来想采用最新版本的,一想到生产和测试必须版本保持一致,不能随便升级,就只好去下载指定版本的rabbitmq的rpm。


RabbitMQ概念


Broker消息中间件的服务节点,RabbitMQ的一个服务实例,也可以看做是RabbitMQ的一台服务器


Queue 队列:用于存储消息。kafka不一样,它的消息存在在topic逻辑层面,而队列存储的只是topic中实际存储文件中的编译标识。多个消费者可以同时订阅一个队列,平均分摊(Round-robin轮询)处理消息


Exchange 交换器:生产者将消息发送到交换器,由交换器路由到一个或者多个队列中


  • directexchangequeue进行bingding时会设置相应的routingkey生产者发送消息到交换器时会设定相应的routingkey,如果这两个routingkey相同,消息都会投放到绑定的队列上。
  • topicdirect一样,但是支持routingkey的通配符模式,可以有通配符:* , # 其中 * 表示匹配一个单词, #则表示匹配没有或者多个单词
  • fanout 直接将发送到该交换器的消息路由到它绑定的一个或者多个队列
  • header 根据添加的header来判断
  • x-match == all,匹配所有header
  • x-match == any, 只需要匹配其中的一个header的值


Routingkey 路由键: 生产者将消息发给交换器的时候, 一般会指定一个 RoutingKey ,用 来指定这个消息的路由规则,而这个 RoutingKey 需要与交换器类型和绑定键 (BindingKey) 合起来使用才能最终生效。在交换器类型和绑定键 (BindingKey) 固定的情况下,生产者可以在发送消息给交换器时, 通过指定 RoutingKey 来决定消息流向哪里


Bindingkey 绑定:通过绑定将交换器与队列关联起来,在绑定的时候一般会指定一绑定键 BindingKey ,这样 RabbitMQ 就知何正确将消息路由到队列了。BindingKey只针对特定交换器才有效。


Producer消息生产者


Consumer消息消费者


安装条件


环境


Centos 7.4 3台虚机8c16g


用户权限


需要有sudo权限


安装文件


下载的文件统一在/home/lazasha/download目录下, rabbitmq和erlang对应的版本关系可以参考:


https://www.rabbitmq.com/which-erlang.html


epel: epel-release-7-12.noarch.rpm


下载地址:https://mirrors.tuna.tsinghua.edu.cn/epel/7/x86_64/Packages/e/epel-release-7-12.noarch.rpm


erlang:erlang-22.1.8-1.el7.x86_64.rpm


下载地址:https://github.com/rabbitmq/erlang-rpm/releases


rabbitmq: rabbitmq-server-3.8.2-1.el7.noarch.rpm


下载地址:https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.8.2/


key: rabbitmq-release-signing-key.asc (我好像后面没有用到)


下载地址:https://github.com/rabbitmq/signing-keys/releases


image.png


步骤


epel安装


sudo yum -y install epel-release-7-12.noarch.rpm


erlang安装


sudo yum -y install erlang-22.1.8-1.el7.x86_64.rpm


image.png


检查是否安装成功:


image.png


rabbitmq安装


image.png

image.png

image.png


在他两台机器上同样操作. 服务缺省端口是5672.


集群搭建


在3台机器上/etc/hosts文件中添加IP和节点名称的对应


10.156.13.92 lchod1392
10.156.13.93 lchod1393
10.156.13.94 lchod1394


把lchod1392上的 cookie文件,赋值到lchod1393、lchod1394节点上,集群环境下各个


节点的cookie必须一致。rpm安装的cookie 文件默认路 径为

/var/lib/rabbitmq/.erlang.cookie


注意:.erlang.cookie可能有权限问题,可以使用下面的操作:


sudo chmod -R 600 /var/lib/rabbitmq/.erlang.cookie


注意: 拷贝到另外两台机器上后,不管怎么样执行一下下面的命令,改一下.erlang.cookie的owner:


sudo chown -R rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie


image.png

image.png


通过Rabbitmqctl来配置集群,集群内部通讯端口是25672


1.首先启动3个节点上的RabbitMQ服务


sudo systemctl start rabbitmq-server


可以使用rabbitmqctl cluster_status 查看各个节点的集群状态


2.以lchod1392为基准,将lchod1393、lchod1394加入到集群中,把3个节点都设置为

硬盘节点了。


lchod1393



sudo rabbitmqctl stop_app                    //只关闭rabbitmq服务,不关闭erlang服务
    sudo rabbitmqctl reset                       //这个命令我在加集群时没有执行
    sudo rabbitmqctl join_cluster rabbit@lchod1392   //--ram这个参数是内存节点模式,不是就是硬盘节点
    sudo rabbitmqctl start_app


lchod1394


sudo rabbitmqctl stop_app                    //只关闭rabbitmq服务,不关闭erlang服务
    sudo rabbitmqctl reset                       //这个命令我在加集群时没有执行
    sudo rabbitmqctl join_cluster rabbit@lchod1392   //--ram这个参数是内存节点模式,不是就是硬盘节点
    sudo rabbitmqctl start_app


image.png


3.检查集群状态


sudo rabbitmqctl cluster_status



image.png


注意点: 如果关闭了集群中的所有节点,确保启动时最后一个关闭的节点第一个启动,否则会有问题。



相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
1月前
|
消息中间件 Java RocketMQ
RocketMQ实战教程之RocketMQ安装
这是一篇关于RocketMQ安装的实战教程,主要介绍了在CentOS系统上使用传统安装和Docker两种方式安装RocketMQ。首先,系统需要是64位,并且已经安装了JDK 1.8。传统安装包括下载安装包,解压并启动NameServer和Broker。Docker安装则涉及安装docker和docker-compose,然后通过docker-compose.yaml文件配置并启动服务。教程还提供了启动命令和解决问题的提示。
|
4天前
|
消息中间件 Linux
Centos安装RabbitMQ
Centos安装RabbitMQ
11 3
|
3天前
|
消息中间件 存储 缓存
RocketMQ4.2 最佳实践之集群搭建
RocketMQ4.2 最佳实践之集群搭建
|
4天前
|
消息中间件 Ubuntu 数据安全/隐私保护
Ubuntu上安装RabbitMQ
Ubuntu上安装RabbitMQ
8 1
|
6天前
|
消息中间件 RocketMQ
Centos7.6安装RocketMQ4.9.2并配置开机自启
Centos7.6安装RocketMQ4.9.2并配置开机自启
12 0
|
18天前
|
消息中间件 存储 Java
RocketMQ下载安装、集群搭建保姆级教程
RocketMQ下载安装、集群搭建保姆级教程
31 0
|
20天前
|
消息中间件 网络安全 网络虚拟化
消息队列 MQ操作报错合集之如何实现公网访问内网RocketMQ集群
在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。
|
1月前
|
消息中间件 Shell
rabbitmq安装erlang环境后没生效
rabbitmq安装erlang环境后没生效
977 7
|
25天前
|
关系型数据库 应用服务中间件 nginx
docker基础,docker安装mysql,docker安装Nginx,docker安装mq,docker基础命令
docker基础,docker安装mysql,docker安装Nginx,docker安装mq,docker基础命令
|
1月前
|
消息中间件 Java API
MQ产品使用合集之RocketMQ dledger集群模式的dledgerpeers端口是集群之间通讯吗
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。