『RabbitMQ』入门指南（安装，配置，应用）

news2024/11/16 3:35:54

前言

RabbitMQ 是在 AMQP（Advanced Message Queuing Protocol） 协议标准基础上完整的，可复用的企业消息系统。它遵循 Mozilla Public License 开源协议，采用 Erlang 实现的工业级的消息队列(MQ)服务器，建立在 Erlang OTP 平台上（因为采用 Erlang 开发，所以 RabbitMQ 稳定性和可靠性比较高）

其他主流 MQ 产品

  • ActiveMQ：Apache 出品，最流行的，能力强劲的开源消息总线，基于 JMS（Java Message Service）规范
  • RocketMQ：阿里低延迟、高并发、高可用、高可靠的分布式消息中间件，基于 JMS，目前由 Apache 基金会维护
  • Kafka：分布式，分区的，多副本的，多订阅者的消息发布订阅系统（分布式 MQ 系统），可以用于搜索日志，监控日志，访问日志等

本文为 RabbitMQ 入门教程，主要将会讲解 RabbitMQ 安装配置（Windows），相关概念，及项目中具体应用

image.png

安装

Erlang

官网下载链接：Downloads - Erlang/OTP

RabbitMQ 服务器必须首先安装 Erlang 运行环境，同时安装时需要注意 RabbityMQ 所依赖的 Erlang 版本，我们可以查看下方官方版本对应信息

版本对应：RabbitMQ Erlang Version Requirements — RabbitMQ

本次使用版本 Erlang OTP 25.3（点击跳转下载链接）

image.png

双击执行 exe 安装程序，除了安装路径其他都按照默认即可

然后配置环境变量

ERLANG_HOME = D:\Erlang\Erlang\Erlang OTP

并且添加 /bin 目录到 Path 环境变量中，即添加 %ERLANG_HOME%\bin 到 Path 中

安装配置之后，打开 CMD，输入 erl 然后回车键，会弹出版本信息，表示 Erlang 安装成功

RabbitMQ

官方下载页面：RabbitMQ Changelog — RabbitMQ

下载链接： RabbitMQ 3.12.0

安装 exe 文件，执行安装包，同样除了安装路径外其他保持默认

配置环境变量

RABBITMQ_SERVER = D:\RabbitMQ\RabbitMQ\rabbitmq_server-3.12.0

然后添加 %RABBITMQ_SERVER%\sbin 到 Path 环境变量中

查看所有插件

rabbitmq-plugins list

注：如果出现问题请参考最后一章 彻底卸载

image.png

之后我们需要安装 rabbitmq_management 插件，可以使用可视化的方式查看 RabbitMQ 服务器实例的状态，以及操控 RabbitMQ 服务器

# 安装插件
rabbitmq-plugins enable rabbitmq_management

访问管理界面： http://localhost:15672/ （账号密码：guest / guest）

image.png

前期安装配置完毕，下面可以配合官方入门文档学习

官方文档：RabbitMQ Tutorials — RabbitMQ

消息队列

定义

消息指的是两个应用间传递的数据。数据的类型有很多种形式，可能只包含文本字符串，也可能包含嵌入对象。

“消息队列(Message Queue)”是在消息的传输过程中保存消息的容器。在消息队列中，通常有生产者和消费者两个角色。生产者只负责发送数据到消息队列，谁从消息队列中取出数据处理，他不管。消费者只负责从消息队列中取出数据处理，他不管这是谁发送的数据

image.png

作用

解耦。如图所示。假设有系统 B、C、D 都需要系统 A 的数据，于是系统 A 调用三个方法发送数据到 B、C、D。这时，系统 D 不需要了，那就需要在系统 A 把相关的代码删掉。假设这时有个新的系统 E 需要数据，这时系统 A 又要增加调用系统 E 的代码。为了降低这种强耦合，就可以使用 MQ，系统 A 只需要把数据发送到 MQ，其他系统如果需要数据，则从 MQ 中获取即可

image.png

异步。如图所示。一个客户端请求发送进来，系统 A 会调用系统 B、C、D 三个系统，同步请求的话，响应时间就是系统 A、B、C、D 的总和，也就是 800ms。如果使用 MQ，系统 A 发送数据到 MQ，然后就可以返回响应给客户端，不需要再等待系统 B、C、D 的响应，可以大大地提高性能。对于一些非必要的业务，比如发送短信，发送邮件等等，就可以采用 MQ

image.png

削峰。如图所示。这其实是 MQ 一个很重要的应用。假设系统 A 在某一段时间请求数暴增，有 5000 个请求发送过来，系统 A 这时就会发送 5000 条 SQL 进入 MySQL 进行执行，MySQL 对于如此庞大的请求当然处理不过来，MySQL 就会崩溃，导致系统瘫痪。如果使用 MQ，系统 A 不再是直接发送 SQL 到数据库，而是把数据发送到 MQ，MQ 短时间积压数据是可以接受的，然后由消费者每次拉取 2000 条进行处理，防止在请求峰值时期大量的请求直接发送到 MySQL 导致系统崩溃

image.png

特点

可靠性：通过支持消息持久化，支持事务，支持消费和传输的 ack 等来确保可靠性

路由机制：支持主流的订阅消费模式，如广播，订阅，headers 匹配等

扩展性：多个 RabbitMQ 节点可以组成一个集群，也可以根据实际业务情况动态地扩展集群中节点

高可用性：队列可以在集群中的机器上设置镜像，使得在部分节点出现问题的情况下队仍然可用

多种协议：RabbitMQ 除了原生支持 AMQP 协议，还支持 STOMP，MQTT 等多种消息中间件协议

多语言客户端：RabbitMQ 几乎支持所有常用语言，比如 Java、Python、Ruby、PHP、C#、JavaScript 等

管理界面：RabbitMQ 提供了易用的用户界面，使得用户可以监控和管理消息、集群中的节点等

插件机制：RabbitMQ 提供了许多插件，以实现从多方面进行扩展，当然也可以编写自己的插件

应用

本章将会集成 rabbitmq 到 SpringBoot 中，并使用 rabbitmq-provider （生产者）和 rabbitmq-consumer（消费者） 两个项目进行具体讲解, 也可以在父项目中创建这两个模块（本文采用父子模块方式）

所有代码示例已经上传到 GitHub 仓库

仓库地址：ReturnTmp/rabbitmq-demo: rabbitmq 实例代码 (github.com)

生产者

配置

创建子模块 rabbitmq-provider

依赖配置（也可以 IDEA 初始化模块直接勾选）

        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

application.yml

server:  
  port: 8021  
spring:  
  application:  
    name: rabbitmq-provider  
  rabbitmq:  
    host: 127.0.0.1  
    port: 5672  
    username: root  
    password: 111111  
    virtual-host: RootHost

其中虚拟 host 配置项不是必须的，需要自行创建 vhost，如果未自行创建，默认为 virtual-host: /

注：vhost 可以理解为虚拟 broker，即 mini-RabbitMQ server，其内部均含有独立的 queue、bind、exchange 等，最重要的是拥有独立的权限系统，可以做到 vhost 范围内的用户控制。当然，从 RabbitMQ 全局角度，vhost 可以作为不同权限隔离的手段

可以按照如下步骤创建 vhost

image.png

然后创建用户（管理员）

image.png

然后我们需要为用户分配权限，指定使用我们刚刚创建的 vhost

image.png

代码

创建直连交换机配置类

注：RabbitMQ 共有四种交换机，分别为：直连交换机，扇形交换机，主题交换机，首部交换机。这里使用直连交换机演示，其他读者可以自行尝试

@Configuration
public class DirectRabbitConfig {

    //队列 起名：TestDirectQueue
    @Bean
    public Queue TestDirectQueue() {
        // durable:是否持久化,默认是false,持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效
        // exclusive:默认也是false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable
        // autoDelete:是否自动删除，当没有生产者或者消费者使用此队列，该队列会自动删除。
        //   return new Queue("TestDirectQueue",true,true,false);

        //一般设置一下队列的持久化就好,其余两个就是默认false
        return new Queue("TestDirectQueue", true);
    }

    //Direct交换机 起名：TestDirectExchange
    @Bean
    DirectExchange TestDirectExchange() {
        //  return new DirectExchange("TestDirectExchange",true,true);
        return new DirectExchange("TestDirectExchange", true, false);
    }

    //绑定  将队列和交换机绑定, 并设置用于匹配键：TestDirectRouting
    @Bean
    Binding bindingDirect() {
        return BindingBuilder.bind(TestDirectQueue()).to(TestDirectExchange()).with("TestDirectRouting");
    }


    @Bean
    DirectExchange lonelyDirectExchange() {
        return new DirectExchange("lonelyDirectExchange");
    }

}

然后写简单的接口进行消息推送（可以视情况写为定时任务）

@RestController
public class SendMessageController {

    @Autowired
    RabbitTemplate rabbitTemplate;  //使用RabbitTemplate,这提供了接收/发送等等方法

    @GetMapping("/sendDirectMessage")
    public String sendDirectMessage() {
        String messageId = String.valueOf(UUID.randomUUID());
        String messageData = "test message, hello!";
        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        Map<String, Object> map = new HashMap<>();
        map.put("messageId", messageId);
        map.put("messageData", messageData);
        map.put("createTime", createTime);
        //将消息携带绑定键值：TestDirectRouting 发送到交换机TestDirectExchange
        rabbitTemplate.convertAndSend("TestDirectExchange", "TestDirectRouting", map);
        return "ok";
    }
}

启动项目，调用接口： http://localhost:8021/sendDirectMessage

查看 RabbitMQ 管理页面查看是否推送成功

image.png

image.png

消费者

配置

创建子模块 rabbitmq-consumer

依赖配置

        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

application.yml

server:  
  port: 8022  
spring:  
  application:  
    name: rabbitmq-consumer  
  rabbitmq:  
    host: 127.0.0.1  
    port: 5672  
    username: root  
    password: 111111  
    virtual-host: RootHost
代码

创建消息接收监听类

@Component
@RabbitListener(queues = "TestDirectQueue")
public class DirectReceiver {

    @RabbitHandler
    public void process(Map testMessage) {
        System.out.println("DirectReceiver receive message: " + testMessage.toString());
    }
}

之后启动项目，查看消费者接收情况

image.png

序列化

发送接收消息可能出现 Failed to convert message 问题，可以通过使用 JSON 序列化传输信息方式解决

生产者
@Configuration
public class RabbitMQConfig implements InitializingBean {

    /**
     * 自动注入RabbitTemplate模板
     */
    @Resource
    private RabbitTemplate rabbitTemplate;

    /**
     * 发送消息JSON序列化
     */
    @Override
    public void afterPropertiesSet() {
        //使用JSON序列化
        rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
    }
}
消费者
@Configuration
public class RabbitMQConfig {

    @Bean
    public MessageConverter jsonMessageConverter(ObjectMapper objectMapper) {
        return new Jackson2JsonMessageConverter(objectMapper);
    }
}

彻底卸载

我们安装中可能出现各种问题，一般情况下是 RabbitMQ 和 Erlang 版本不对应，需要完全卸载 RabbitMQ 和 Erlang，可以按照如下步骤卸载

注：博主首次安装使用的是 Erlang 20.3 Rabbit 3.7.15 ，之后似乎小版本不对应，出现问题，需要重新卸载安装

（1）打开 Windows 控制面板，双击“程序和功能”。

（2）在当前安装的程序列表中，右键单击 RabbitMQ Server，然后单击“卸载”。

（3）在当前安装的程序列表中，右键单击“Erlang OTP”，然后单击“卸载”。

（4）打开 Windows 任务管理器。

（5）在任务管理器中，查找进程 epmd.exe。 如果此进程仍在运行，请右键单击该进程，然后单击“结束进程”。

（6）删除 RabbitMQ 和 Erlang 的所有安装目录。

（7）删除文件 C:\Windows\System32\config\systemprofile.erlang.cookie（如果存在）。

（8）转到用户文件夹：C:\Users\[username]，然后删除文件.erlang.cookie。

（9）同样在 User 文件夹中，转到 AppData \ Roaming \ RabbitMQ。删除 RabbitMQ 文件夹。

（10）删除注册表 HKEY_LOCAL_MACHINE\SOFTWARE\Ericsson\Erlang\ErlSrv 的子项。

（11）打开运行 cmd->sc delete RabbitMQ。

（12）打开运行->regedit 找到 RabbitMQ 节点，删掉即可（如果存在）

参考链接

  • Windows 下安装 RabbitMQ 服务器及基本配置 - 蓝之风 - 博客园 (cnblogs.com)
  • RabbitMQ Windows 安装、配置、使用 - 小白教程-阿里云开发者社区 (aliyun.com)
  • Windows 如何完全卸载 RabbitMQ 和 Erlang 删除注册表
  • windows 下 Erlang 与 RabbitMQ 重新安装时，由于卸载不干净导致各类错误
  • 超详细的 RabbitMQ 入门，看这篇就够了！-阿里云开发者社区 (aliyun.com)
  • RabbitMQ 整合 Spring Boot，实现 Hello World
  • Springboot 整合 RabbitMq ，用心看完这一篇就够了
  • RabbitMq 核心知识点小结 - 知乎 (zhihu.com)
  • RabbitMQ消费消息坑：failed to convert serialized Message content - jiuchengi

本文由博客一文多发平台 OpenWrite 发布！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1243769.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

UML建模图文详解教程01——Enterprise Architect的安装与使用

UML建模图文详解教程01——Enterprise Architect的安装与使用

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl Enterprise Architect概述 官方网站&#xff1a;https://www.sparxsystems.cn/products/ea/&#xff1b;图示如下&#xff1a; Enterprise Architect是一个全功能的、基于…
阅读更多...
ES 万条以外分页检索功能实现及注意事项

ES 万条以外分页检索功能实现及注意事项

背景 以 ES 存储日志&#xff0c;且需要对日志进行分页检索&#xff0c;当数据量过大时&#xff0c;就面临 ES 万条以外的数据检索问题&#xff0c;如何利用滚动检索实现这个需求呢&#xff1f;本文介绍 ES 分页检索万条以外的数据实现方法及注意事项。 需求分析 用 ES 存储数…
阅读更多...
单个视频生成视频二维码，手把手图文教程

单个视频生成视频二维码，手把手图文教程

单个视频生成视频二维码帮助教程&#xff08;图文教程&#xff09;&#xff0c;手把手教程如下&#xff1a; STEP1 注册帐号 使用视频二维码&#xff0c;您需要注册酷播云用户帐号&#xff08;免费5G空间&#xff0c;普通用户够用&#xff09;。 参考如图1-1&#xff0c;按照…
阅读更多...
【数据结构/C++】栈和队列_链栈

【数据结构/C++】栈和队列_链栈

链头 栈顶。 #include<iostream> using namespace std; // 链栈 typedef int ElemType; typedef struct Linknode {ElemType data;struct Linknode *next; } *LiStack; // 初始化 void InitLiStack(LiStack &S) {S (LiStack)malloc(sizeof(struct Linknode));S->…
阅读更多...
安全框架springSecurity+Jwt+Vue-2(后端开发)

安全框架springSecurity+Jwt+Vue-2(后端开发)

一、创建项目及配置 ①&#xff1a;创建新的项目及常用包 ②&#xff1a;引入依赖和配置 devtools&#xff1a;项目的热加载重启插件 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId&…
阅读更多...
RK3399平台开发系列讲解（内核入门篇）ConfigFS 的核心数据结构

RK3399平台开发系列讲解（内核入门篇）ConfigFS 的核心数据结构

🚀返回专栏总目录 文章目录 一、关键数据结构二、config_item 的结构体三、属性和方法沉淀、分享、成长，让自己和他人都能有所收获！😄 📢虚拟文件系统 ConfigFS 是一个特殊的文件系统，旨在提供一种动态配置 Linux 内核和设备的机制。 一、关键数据结构 ConfigFS 的核…
阅读更多...
[23] 4K4D: Real-Time 4D View Synthesis at 4K Resolution

[23] 4K4D: Real-Time 4D View Synthesis at 4K Resolution

paper | proj | code 提出一种基于K-Planes的4D point cloud Representation&#xff1b;提出一种Hybrid appearance model&#xff0c;包含image blending model和SH model。其中&#xff0c;image blending model将3D点映射回原图中求得&#xff0c;SH model通过模型预测求得…
阅读更多...
机器学习/sklearn笔记：MeanShift

机器学习/sklearn笔记：MeanShift

1 算法介绍 一种基于质心的算法通过更新候选质心使其成为给定区域内点的均值候选质心的位置是通过一种称为“爬山”技术迭代调整的&#xff0c;该技术找到估计的概率密度的局部最大值 1.1 基本形式 给定d维空间的n个数据点集X&#xff0c;那么对于空间中的任意点x的均值漂移…
阅读更多...
HCIP --- HCIA（部分汇总）--- 点对点网络

HCIP --- HCIA（部分汇总）--- 点对点网络

抽象语言 --- 电信号 抽象语言 --- 编码 编码 --- 二进制 二进制 --- 电信号 处理电信号 OSI/RM ---- 开放式系统互联参考模型 --- 1979 --- ISO --- 国际标准化组织 核心思想 --- 分层 应用层 --- 提供各种应用程序&#xff0c;抽象语言转换成编码&#xff0c;人机交互…
阅读更多...
导数、方向导数、梯度方向、梯度

导数、方向导数、梯度方向、梯度

导数&#xff1a;自变量改变一定量时&#xff08;大于或小于0&#xff09;&#xff0c;因变量改变多少 方向导数&#xff1a;限定在某一个方向上&#xff0c;自变量改变一定量时&#xff08;大于0&#xff09;&#xff0c;因变量改变多少 梯度方向&#xff1a;方向导数最大的…
阅读更多...
PHP 语法||PHP 变量

PHP 语法||PHP 变量

PHP 脚本在服务器上执行&#xff0c;然后将纯 HTML 结果发送回浏览器。 基本的 PHP 语法 PHP 脚本可以放在文档中的任何位置。 PHP 脚本以 <?php 开始&#xff0c;以 ?> 结束&#xff1a; <?php // PHP 代码 ?> 值得一提的是&#xff0c;通过设定php.ini的相…
阅读更多...
【MATLAB源码-第87期】基于matlab的Q-learning算法栅格地图路径规划，自主选择起始点和障碍物。

【MATLAB源码-第87期】基于matlab的Q-learning算法栅格地图路径规划，自主选择起始点和障碍物。

操作环境&#xff1a; MATLAB 2022a 1、算法描述 Q-learning是一种无模型的强化学习算法&#xff0c;适用于有限的马尔可夫决策过程&#xff08;MDP&#xff09;。它的核心是学习一个动作价值函数&#xff08;action-value function&#xff09;&#xff0c;即Q函数&#xf…
阅读更多...
YOLO目标检测——泄露检测数据集下载分享【含对应voc、coco和yolo三种格式标签】

YOLO目标检测——泄露检测数据集下载分享【含对应voc、coco和yolo三种格式标签】

实际项目应用&#xff1a;泄露检测数据集说明&#xff1a;泄露检测数据集&#xff0c;真实场景的高质量图片数据&#xff0c;数据场景丰富&#xff0c;含多个类别标签说明&#xff1a;使用lableimg标注软件标注&#xff0c;标注框质量高&#xff0c;含voc(xml)、coco(json)和yo…
阅读更多...
Visual Studio(VS) C++程序LNK2005错误，提示“error LNK2005: _XXX已经在xxx.obj中定义”解决方案

Visual Studio(VS) C++程序LNK2005错误，提示“error LNK2005: _XXX已经在xxx.obj中定义”解决方案

1.问题如图 2.出现原因 项目中有多个源文件或头文件&#xff0c;include后导致有些变量重复定义&#xff0c;加上Visual Studio新版版要求更严格 3.解决办法 查询到的解决办法很多不好用&#xff0c;此处记录解决自己问题的一个办法&#xff1a;直接让编译器忽略第二次定义的…
阅读更多...
Linux CentOS7的主机名

Linux CentOS7的主机名

主机名&#xff0c;也称为计算机名&#xff0c;是提供给网络连接的设备&#xff08;如系统、交换机、路由器等&#xff09;的识别名称。同一网络中不能有两个主机名相同的系统。Linux系统给当前主机命名的目的是能够容易记住&#xff0c;尤其是在部署集群的时候更加方便。 一般…
阅读更多...
【C++】POCO学习总结（五）：功能介绍

【C++】POCO学习总结（五）：功能介绍

【C】郭老二博文之&#xff1a;C目录 1、POCO 简介 github&#xff1a;https://github.com/pocoproject/poco 官网&#xff1a;https://pocoproject.org/index.html POCO第一个版本于 2005 年 2 月发布 POCO完全免费&#xff1a;POCO C 库根据 Boost 软件许可证获得许可。非…
阅读更多...
【C语法学习】26 - strcmp()函数

【C语法学习】26 - strcmp()函数

文章目录 1 函数原型2 参数3 返回值4 比较机制5 示例5.1 示例1 1 函数原型 strcmp()&#xff1a;比较str1指向的字符串和str2指向的字符串&#xff0c;函数原型如下&#xff1a; int strcmp(const char *str1, const char *str2);2 参数 strcmp()函数有两个参数str1和str2&a…
阅读更多...
【python爬虫】scrapy在pycharm 调试

【python爬虫】scrapy在pycharm 调试

scrapy在pycharm 调试 1、使用scrapy创建一个项目 scrapy startproject tutorial 2、在朋友pycharm中调试scrapy 2.1 通过文件run.py调试 在根目录下新建一个文件run.py（与scrapy.cfg文件的同一目录下）, debug ‘run’即可 # -*- coding:utf-8 -*- from scrapy import c…
阅读更多...
excel单元格加背景颜色不生效？

excel单元格加背景颜色不生效？

如果在 Excel 中设置单元格背景颜色而发现不生效&#xff0c;可能有几个原因。以下是一些常见的解决方法&#xff1a; 1. **单元格锁定&#xff1a;** 检查所在单元格是否被锁定。如果单元格被锁定&#xff0c;并且工作表被保护&#xff0c;你可能无法更改其背景颜色。在工作表…
阅读更多...
基于51单片机数字电流表数码管显示( proteus仿真+程序+设计报告+讲解视频）

基于51单片机数字电流表数码管显示( proteus仿真+程序+设计报告+讲解视频）

电流表 1. 主要功能&#xff1a;2. 讲解视频&#xff1a;3. 仿真4. 程序代码5. 设计报告6. 设计资料内容清单&&下载链接资料下载链接&#xff1a; 基于51单片机数字电流表数码管显示( proteus仿真程序设计报告讲解视频&#xff09; 仿真图proteus7.8及以上 程序编译器…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023