搭建RabbitMQ消息服务，整合SpringBoot实现收发消息

作者主页：Designer 小郑
作者简介：3年JAVA全栈开发经验，专注JAVA技术、系统定制、远程指导，致力于企业数字化转型，CSDN博客专家，蓝桥云课认证讲师。

目录

  • 一、前言
    • 1.1 什么是消息队列
    • 1.2 RabbitMQ 是什么
    • 1.3 为什么需要用到 RabbitMQ
    • 1.4 RabbitMQ 相比 Kafka 的优势
  • 二、搭建 RabbitMQ 环境
    • 2.1 安装 Erlang
      • 2.1.1 下载
      • 2.1.2 安装
      • 2.1.3 环境变量配置
    • 2.2 安装 RabbitMQ
      • 2.2.1 下载
      • 2.2.2 安装
      • 2.2.3 初始化
      • 2.2.4 验证
    • 2.3 配置外网访问
      • 2.3.1 添加新用户
      • 2.3.2 Virtual Host 配置
  • 三、整合 RabbitMQ 消息服务
    • 3.1 创建新的 SpringBoot 项目
    • 3.2 引入依赖
    • 3.3 配置文件
    • 3.4 创建消息发送工具类
    • 3.5 发消息功能测试
    • 3.6 创建消息接收工具类
    • 3.7 收消息功能测试
  • 四、总结

一、前言

1.1 什么是消息队列

消息队列是一种在应用程序之间传递数据的通信机制，它基于 发布-订阅 模式，将消息发送者（发布者）和消息接收者（订阅者）解耦，使得它们可以独立地进行消息的发送和接收。

在消息队列中，消息发送者将消息发送到队列中，而消息接收者则从队列中获取消息进行处理。消息队列提供了一种异步的通信方式，即发送者发送消息后不需要等待接收者的回复，而可以立即继续执行其他操作。同时，消息队列还可以实现消息的持久化存储，确保消息在发送和接收过程中的可靠性。

消息队列的应用场景非常广泛，例如：

  • 在分布式系统中，可以用消息队列来实现不同模块之间的解耦；
  • 在高并发系统中，可以利用消息队列来缓解系统压力；
  • 在实时数据处理中，可以将数据存储在消息队列中，再由数据处理模块进行处理。

在这里插入图片描述

1.2 RabbitMQ 是什么

RabbitMQ是一个开源的消息队列中间件，它实现了高级消息队列协议），并提供了可靠的消息传递机制。

RabbitMQ使用Erlang语言编写，具有高度可靠、可扩展、灵活和可插拔的特性，被广泛应用于分布式系统、微服务架构、异步任务处理等场景。

RabbitMQ基于生产者和消费者模型工作。生产者将消息发送到RabbitMQ的交换机，然后交换机将消息路由到一个或多个队列，消费者从队列中获取消息并进行处理。

RabbitMQ 支持多种消息传递模式，同时还提供了消息的持久化、消息优先级、消息确认机制等特性，确保消息的可靠性和可靠传输。

RabbitMQ是一个成熟、可靠的消息队列中间件，提供了强大的消息传递机制和丰富的特性，被广泛应用于分布式系统和异步消息处理中。

在这里插入图片描述

1.3 为什么需要用到 RabbitMQ

  1. 解耦：RabbitMQ通过消息队列实现了生产者和消费者的解耦。生产者将消息发送到队列中，而消费者从队列中获取消息并进行处理。这种解耦使得系统中的不同模块能够独立进行开发和部署，提高了系统的灵活性和可维护性。

  2. 异步通信：RabbitMQ提供了一种异步通信机制。生产者发送消息到队列后，不需要等待消费者立即处理，而可以继续执行其他操作。这种异步通信能够提升系统的并发性能和响应速度。

  3. 缓冲和削峰：RabbitMQ可以作为一个缓冲区，用于存储来自生产者的消息。这样可以避免生产者和消费者之间的直接耦合，同时也能够应对瞬时的高并发请求，减轻系统压力。

  4. 可靠性和可恢复性：RabbitMQ提供了持久化消息的功能，即使在消息队列或消费者故障的情况下，消息也可以得到保留和恢复。这种可靠性保证了消息的不丢失和可靠传递。

  5. 扩展性：RabbitMQ是一个可扩展的消息队列中间件，可以在需要的时候增加更多的消息队列和消费者节点，以应对不断增长的业务需求。

  6. 多语言支持：RabbitMQ提供了多种编程语言的客户端，如Java、Python、C#等，使得开发者可以选择合适自己的编程语言与RabbitMQ进行交互。

在这里插入图片描述

1.4 RabbitMQ 相比 Kafka 的优势

RabbitMQ 提供了简单易用的 API 和管理界面,使得开发者可以快速上手并进行配置和管理，相比之下，Kafka 的配置和管理相对复杂一些。

RabbitMQ 支持多种消息传递模式和消息的路由选择机制，可以根据需求进行灵活的消息处理，而Kafka更适用于大规模的高吞吐量流式处理,通常使用发布-订阅模式。

RabbitMQ 具备持久化消息、消息确认机制等特性,可以确保消息的可靠传输，而 Kafka 通过多副本机制和消息日志的方式，提供了高度可靠性的消息传递。

RabbitMQ 可以通过设置队列的限流策略和消费者的消费速率来进行流量控制和削峰处理，能够保护消费者免受过多的消息推送，而Kafka则将消费者的消费速率控制交给消费者自身，在高并发场景下可能需要额外处理。

RabbitMQ 提供了多种编程语言的客户端，开发者可以根据自己的编程需求选择合适的客户端进行交互，而Kafka的客户端主要集中在Java语言上，对其他语言的支持相对较少。

RabbitMQ 拥有庞大的开源社区和丰富的生态系统,提供了丰富的插件和集成工具，方便开发者进行扩展和集成，Kafka的生态系统相对较小,但在大数据领域有广泛的应用和支持。

在这里插入图片描述

二、搭建 RabbitMQ 环境

2.1 安装 Erlang

Erlang 是 RabbitMQ 消息服务的基础环境，就像 Java 的 JDK 一样，是必须安装的。

2.1.1 下载

Erlang 官网下载地址：下载地址。

在这里插入图片描述

因为我们要把 RabbitMQ 服务装在服务器上，所以同学们可以在服务器上下载 Erlang 安装包，或者下载后手动上传至服务器。

2.1.2 安装

下载完成后双击安装包，按照提示流程正常安装即可，截图如下所示。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

2.1.3 环境变量配置

变量名如下，变量值是安装的路径，如下图所示。

ERLANG_HOME

在这里插入图片描述

在这里插入图片描述

验证命令如下：

erl -v

在这里插入图片描述

2.2 安装 RabbitMQ

2.2.1 下载

RabbitMQ 需要在 Github 中下载，下载地址。

RabbitMQ 版本需要和 Erlang 对应，本文安装的是 3.9.5 版本。

2.2.2 安装

安装流程如下图所示。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

2.2.3 初始化

安装完成后，使用 cmd 窗口，进入 RabbitMQ 的 sbin 目录，如下图所示。

在这里插入图片描述
接着输入以下命令，完成初始化安装。

rabbitmq-plugins enable rabbitmq_management

在这里插入图片描述

2.2.4 验证

打开浏览器，输入：

http://localhost:15672

账号密码都是：

guest

在这里插入图片描述
在这里插入图片描述

2.3 配置外网访问

2.3.1 添加新用户

RabbitMQ 默认端口为15672，用户名和密码都为guest，是不允许外部访问的。

所以我们要添加新用户，实现外网访问，操作流程如下图所示。

在这里插入图片描述

点击添加后，输入新用户的账号和密码，如下图所示。

在这里插入图片描述

2.3.2 Virtual Host 配置

Virtual Host 需要允许添加的用户访问，如下图所示。

在这里插入图片描述

进入子界面后，选择用户后提交，如下图所示。

在这里插入图片描述

然后，我们就完成了外网访问的配置。

三、整合 RabbitMQ 消息服务

3.1 创建新的 SpringBoot 项目

打开 IDEA 工具，新建项目，如下图所示。

在这里插入图片描述

新项目创建完成后，如下图所示。

在这里插入图片描述

3.2 引入依赖

首先，请在 pom.xml 中引入依赖，代码如下。

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

3.3 配置文件

application.yml 配置如下。

spring:rabbitmq:host: 118.126.82.167port: 5672username: zwzpassword: 123456listener:simple:retry:enabled: truemax-attempts: 5initial-interval: 2s

3.4 创建消息发送工具类

请同学们创建 SimpleProducer 工具类，代码如下。

package cn.zwz.send;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;public class SimpleProducer {public static void main(String[] args) {//1. 创建连接工程ConnectionFactory connectionFactory = new ConnectionFactory();//1.1 设置连接IPconnectionFactory.setHost("118.126.82.167");//1.2 设置连接端口connectionFactory.setPort(5672);//1.3 设置用户名connectionFactory.setUsername("zwz");//1.4 设置密码connectionFactory.setPassword("123456");//1.5 设置虚拟访问节点，就是消息发送的目标路径connectionFactory.setVirtualHost("/");Connection connection = null;Channel channel = null;try {//2. 创建连接Connectionconnection = connectionFactory.newConnection("ZWZ-Connection");//3. 通过连接获取通道Channelchannel = connection.createChannel();//4. 通过通道创建交换机，声明队列，绑定关系，路由key，发送消息，接收消息String queueName = "ZWZ-TOPIC";/*** channel.queueDeclare有5个参数* params1: 队列的名称* params2: 是否要持久化， false：非持久化 true：持久化* params3: 排他性，是否独占队列* params4: 是否自动删除，如果为true，队列会随着最后一个消费消费完后将队列自动删除，false：消息全部消费完后，队列保留* params5: 携带的附加参数*/channel.queueDeclare(queueName, true, false, false, null);//5. 消息内容String message = "HELLO World!";//6. 将消息发送到队列channel.basicPublish("", queueName, null, message.getBytes());System.out.println("消息发送成功");} catch (Exception e) {e.printStackTrace();} finally {//7. 关闭通道if (channel != null && channel.isOpen()) {try {channel.close();} catch (Exception e) {e.printStackTrace();}}//8. 关闭连接if (connection != null && connection.isOpen()) {try {connection.close();} catch (Exception e) {e.printStackTrace();}}}}
}

3.5 发消息功能测试

发消息很简单，运行 main 函数即可。

在这里插入图片描述

发送成功后，后台可以接收到数据，如下图所示。

在这里插入图片描述
在这里插入图片描述

3.6 创建消息接收工具类

请同学们创建 SimpleConsumer 工具类，代码如下。

package cn.zwz.send;import com.rabbitmq.client.*;import java.io.IOException;public class SimpleConsumer {public static void work() {//1. 创建连接工程ConnectionFactory connectionFactory = new ConnectionFactory();//1.1 设置连接IPconnectionFactory.setHost("118.126.82.167");//1.2 设置连接端口connectionFactory.setPort(5672);//1.3 设置用户名connectionFactory.setUsername("zwz");//1.4 设置密码connectionFactory.setPassword("123456");//1.5 设置虚拟访问节点，就是消息发送的目标路径connectionFactory.setVirtualHost("/");Connection connection = null;Channel channel = null;try {//2. 创建连接Connectionconnection = connectionFactory.newConnection("ZWZ-Connection");//3. 通过连接获取通道Channelchannel = connection.createChannel();//4. 通过通道创建交换机，声明队列，绑定关系，路由key，发送消息，接收消息String queueName = "ZWZ-TOPIC";//5. 接收消息并消费消息channel.basicConsume(queueName, true, new DeliverCallback() {@Overridepublic void handle(String consumerTag, Delivery message) throws IOException {System.out.println("接收到的消息内容是：" + new String(message.getBody(), "UTF-8"));}}, new CancelCallback() {@Overridepublic void handle(String consumerTag) throws IOException {System.out.println("消息接收失败。。。");}});System.out.println("开始接受消息。。。。");//阻断程序System.in.read();} catch (Exception e) {e.printStackTrace();} finally {//7. 关闭通道if (channel != null && channel.isOpen()) {try {channel.close();} catch (Exception e) {e.printStackTrace();}}//8. 关闭连接if (connection != null && connection.isOpen()) {try {connection.close();} catch (Exception e) {e.printStackTrace();}}}}
}

接着在启动类上配置运行，代码如下。

package cn.zwz.send;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class SendApplication {public static void main(String[] args) {new SimpleConsumer().work();SpringApplication.run(SendApplication.class, args);}
}

3.7 收消息功能测试

请同学们运行 SpringBoot 启动类，然后再次发送消息，就可以看到消息内容了，如下图所示。

在这里插入图片描述

四、总结

本文首先简单介绍了 RabbitMQ，然后和 Kafka 等热门消息队列进行对比，最后演示了 RabbitMQ 的完整安装配置整合流程，帮助零基础的小白入门 RabbitMQ 开发。

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

数据挖掘的学习路径

数据挖掘的学习路径

⭐️⭐️⭐️⭐️⭐️欢迎来到我的博客⭐️⭐️⭐️⭐️⭐️ &#x1f434;作者&#xff1a;秋无之地 &#x1f434;简介&#xff1a;CSDN爬虫、后端、大数据领域创作者。目前从事python爬虫、后端和大数据等相关工作&#xff0c;主要擅长领域有&#xff1a;爬虫、后端、大数据…
阅读更多...
Llama-7b-hf和vicuna-7b-delta-v0合并成vicuna-7b-v0

Llama-7b-hf和vicuna-7b-delta-v0合并成vicuna-7b-v0

最近使用pandagpt需要vicuna-7b-v0&#xff0c;重新过了一遍&#xff0c;前段时间部署了vicuna-7b-v3&#xff0c;还是有不少差别的&#xff0c;transforms和fastchat版本更新导致许多地方不匹配&#xff0c;出现很多错误&#xff0c;记录一下。 更多相关内容可见Fastchat实战…
阅读更多...
恒运资本：银行股适合定投吗？为什么银行股适合定投？

恒运资本：银行股适合定投吗？为什么银行股适合定投？

在股票市场上&#xff0c;出资者能够通过手动不断的买入到达基金定投的效果&#xff0c;那么&#xff0c;银行股适合定投吗&#xff1f;为什么银行股适合定投&#xff1f;下面恒运资本为我们准备了相关内容&#xff0c;以供参考。 银行股适合定投&#xff0c;即通过定投不断的买…
阅读更多...
XSS的分析

XSS的分析

目录 1、XSS的原理 2、XSS的攻击类型 2.1 反射型XSS 2.2 存储型XSS 2.3 DOM-based 型 2.4 基于字符集的 XSS 2.5 基于 Flash 的跨站 XSS 2.6 未经验证的跳转 XSS 3、复现 3.1 反射性 3.2 DOM-based型 1、XSS的原理 XSS的原理是恶意攻击者往 Web 页面里插入恶意可执行…
阅读更多...
fastjson漏洞批量检测工具

fastjson漏洞批量检测工具

JsonExp 简介 版本&#xff1a;1.3.5 1. 根据现有payload&#xff0c;检测目标是否存在fastjson或jackson漏洞&#xff08;工具仅用于检测漏洞&#xff09;2. 若存在漏洞&#xff0c;可根据对应payload进行后渗透利用3. 若出现新的漏洞时&#xff0c;可将最新的payload新增至…
阅读更多...
【数据结构】链表C++编写的，它定义了一个链表，并实现了一些基本的链表操作，如创建新节点、插入节点、清空链表、输出链表以及查找节点

【数据结构】链表C++编写的，它定义了一个链表，并实现了一些基本的链表操作，如创建新节点、插入节点、清空链表、输出链表以及查找节点

// 引入标准输入输出流库&#xff0c;用于输出操作 #include <iostream> // 引入标准库中的stdlib&#xff0c;包含了rand()函数和其他相关函数 #include <cstdlib> // 引入标准库中的time&#xff0c;包含了time()函数和其他相关函数 #include <ctim…
阅读更多...
网络编程套接字 | UDP套接字

网络编程套接字 | UDP套接字

前面的文章中我们叙述了网络编程套接字的一些预备知识点&#xff0c;从本文开始我们就将开始UDP套接字的编写。本文中的服务端与客户端都是在阿里云的云服务器进行编写与测试的。 udp_v1 在v1的版本中我们先来使用一下前面讲过得一些接口&#xff0c;简单的构建一个udp服务器…
阅读更多...
自建音乐服务器Navidrome之一

自建音乐服务器Navidrome之一

自建音乐服务器Navidrome之一 1. 前言1.1 官方网站 2. Navidrome 简介2.1 简介2.2 特性 3. 准备工作4. 视频教程5. 界面演示5.1 初始化页5.2 专辑页 1. 前言 之前给大家介绍过 Koel 音频流服务&#xff0c;就是为了解决大家的这个问题&#xff1a;下载下来的音乐&#xff0c;只…
阅读更多...
【Docker】镜像的创建、管理与发布

【Docker】镜像的创建、管理与发布

镜像的获取 镜像可以从以下方式获得&#xff1a; 从远程镜像仓库拉取&#xff0c;可以是公有仓库&#xff0c;也可以是私有仓库从Dockerfile构建从文件导入&#xff08;离线&#xff09;从容器提交 镜像的基本操作 跟镜像相关的命令如下&#xff1a; $ docker image --help…
阅读更多...
算法专题：前缀和

算法专题：前缀和

文章目录 Acwing&#xff1a;前缀和示例2845.统计趣味子数组的数目思路容易理解的写法&#xff1a;前缀和两层循环存在问题&#xff1a;超时 优化写法&#xff1a;两数之和思路&#xff0c;转换为哈希表 前缀和&#xff0c;就是求数组中某一段的所有元素的和。 求子数组中某一…
阅读更多...
嵌入式Linux驱动开发（LCD屏幕专题）（四）

嵌入式Linux驱动开发（LCD屏幕专题）（四）

单Buffer的缺点与改进方法 1. 单Buffer的缺点 如果APP速度很慢&#xff0c;可以看到它在LCD上缓慢绘制图案 即使APP速度很高&#xff0c;LCD控制器不断从Framebuffer中读取数据来显示&#xff0c;而APP不断把数据写入Framebuffer 假设APP想把LCD显示为整屏幕的蓝色、红色 很…
阅读更多...
关于火绒邮件监控引起的扫描任意IP会有25和110端口反馈

关于火绒邮件监控引起的扫描任意IP会有25和110端口反馈

之前测试过公司的外网IP&#xff0c;因为之前一直很注意对外映射的端口&#xff0c;都限制了可以访问的IP地址和端口&#xff0c;所以之前扫描的时候是一个端口都扫描不出来的。最近闲的无事&#xff0c;想着再扫描试试&#xff0c;结果发现居然开放了25和110端口&#xff0c;我…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023