产品设计网站制作,网上买手表哪个网站可以买到正品,赚钱游戏无广告无门槛,做百科需要用什么网站做参考作者主页#xff1a;Designer 小郑 作者简介#xff1a;3年JAVA全栈开发经验#xff0c;专注JAVA技术、系统定制、远程指导#xff0c;致力于企业数字化转型#xff0c;CSDN博客专家#xff0c;蓝桥云课认证讲师。 目录 一、前言1.1 什么是消息队列1.2 RabbitMQ 是什么1.… 作者主页Designer 小郑 作者简介3年JAVA全栈开发经验专注JAVA技术、系统定制、远程指导致力于企业数字化转型CSDN博客专家蓝桥云课认证讲师。 目录 一、前言1.1 什么是消息队列1.2 RabbitMQ 是什么1.3 为什么需要用到 RabbitMQ1.4 RabbitMQ 相比 Kafka 的优势 二、搭建 RabbitMQ 环境2.1 安装 Erlang2.1.1 下载2.1.2 安装2.1.3 环境变量配置 2.2 安装 RabbitMQ2.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 解耦RabbitMQ通过消息队列实现了生产者和消费者的解耦。生产者将消息发送到队列中而消费者从队列中获取消息并进行处理。这种解耦使得系统中的不同模块能够独立进行开发和部署提高了系统的灵活性和可维护性。 异步通信RabbitMQ提供了一种异步通信机制。生产者发送消息到队列后不需要等待消费者立即处理而可以继续执行其他操作。这种异步通信能够提升系统的并发性能和响应速度。 缓冲和削峰RabbitMQ可以作为一个缓冲区用于存储来自生产者的消息。这样可以避免生产者和消费者之间的直接耦合同时也能够应对瞬时的高并发请求减轻系统压力。 可靠性和可恢复性RabbitMQ提供了持久化消息的功能即使在消息队列或消费者故障的情况下消息也可以得到保留和恢复。这种可靠性保证了消息的不丢失和可靠传递。 扩展性RabbitMQ是一个可扩展的消息队列中间件可以在需要的时候增加更多的消息队列和消费者节点以应对不断增长的业务需求。 多语言支持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 -v2.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_management2.2.4 验证
打开浏览器输入
http://localhost:15672账号密码都是
guest2.3 配置外网访问
2.3.1 添加新用户
RabbitMQ 默认端口为15672用户名和密码都为guest是不允许外部访问的。 所以我们要添加新用户实现外网访问操作流程如下图所示。 点击添加后输入新用户的账号和密码如下图所示。 2.3.2 Virtual Host 配置 Virtual Host 需要允许添加的用户访问如下图所示。 进入子界面后选择用户后提交如下图所示。 然后我们就完成了外网访问的配置。 三、整合 RabbitMQ 消息服务
3.1 创建新的 SpringBoot 项目 打开 IDEA 工具新建项目如下图所示。 新项目创建完成后如下图所示。 3.2 引入依赖
首先请在 pom.xml 中引入依赖代码如下。
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId
/dependency3.3 配置文件 application.yml 配置如下。 spring:rabbitmq:host: 118.126.82.167port: 5672username: zwzpassword: 123456listener:simple:retry:enabled: truemax-attempts: 5initial-interval: 2s3.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 开发。
