Spring Boot 项目应用消息服务器RabbitMQ（简单介绍）

一、背景

本章讲述的是在用户下单环节，消息服务器RabbitMQ 的应用

1.1 消息服务器的应用

在写一个电商项目的小demo，在电商项目中，消息服务器的应用：

1、订单状态通知：当用户下单、支付成功、订单发货、订单完成等关键节点时，可以通过消息服务器向用户发送相应的订单状态通知。

2、消息推送：通过消息服务器，可以向用户推送个性化的推荐商品、促销活动等消息，以提高用户参与度和购买率。

3、异步处理：在一些涉及到耗时操作的场景中，比如库存扣减、物流跟踪等，可以将任务交给消息服务器进行异步处理，以提高系统的并发性和响应速度。

4、实时聊天：如果你的电商系统支持在线客服或用户之间的实时沟通，消息服务器可以用于实现即时通讯功能。

5、消息队列：消息服务器还可以作为消息队列的承载者，实现系统内不同模块之间的解耦和异步通信。

消息服务器的选择可以考虑使用开源的消息队列中间件，比如RabbitMQ、Apache Kafka、ActiveMQ等，或者云服务提供商提供的消息队列服务，比如阿里云的消息队列RocketMQ、腾讯云的消息队列CMQ等。

需要注意的是，在使用消息服务器时，确保数据的安全性和可靠性，并合理设计消息的格式和传输方式，以确保系统的正常运行和用户体验。

1.2 下单这个环节，消息服务器应用场景

用户下单这个环节，应用消息服务器有以下几个常见的应用场景：

1、异步处理订单：当用户下单后，可以将订单信息发送到消息服务器中，由消息服务器异步处理。这样可以减少用户等待时间，并提高系统的并发能力。消息服务器可以负责处理订单的各种业务逻辑，比如库存扣减、生成物流单号等操作。

2、订单状态通知：在用户下单后，可以通过消息服务器向用户发送订单状态的通知，比如订单已提交、支付成功、订单发货、订单完成等。消息服务器可以实时地将通知推送给用户，提供良好的用户体验。

3、订单状态跟踪：在整个订单生命周期中，消息服务器可以记录和跟踪订单的状态变化。当用户查询订单状态时，可以通过消息服务器获取最新的订单状态信息，确保订单状态的准确性和实时性。

4、消息队列：消息服务器可以作为消息队列的组件，对订单相关的消息进行队列化处理。这样可以解耦订单模块与其他模块之间的依赖关系，提高系统的稳定性和可扩展性。

二、RabbitMQ 的下载与安装

2.1 RabbitMQ的官网地址：

RabbitMQ的官网地址：

RabbitMQ: easy to use, flexible messaging and streaming — RabbitMQ

2.2. 使用brew安装

1、安装

brew install rabbitmq

安装结果：

 rabbitmq 的安装路径：

/opt/homebrew/opt/rabbitmq

2、配置环境变量

vi ~/.bash_profile
export RABBIT_HOME=${PATH}:/opt/homebrew/opt/rabbitmq
export PATH=${PATH}:$RABBIT_HOME/sbin
source ~/.bash_profile


2.3 启动RabbitMQ


1、前台运行
rabbitmq-server

2、后台运行
rabbitmq-server -detached

3、查看运行状态
rabbitmqctl status

4、开始 Web插件
rabbitmq-plugins enable rabbitmq_management

5、重启
rabbitmq-server restart

5、关闭
rabbitmqctl stop

2.4、访问MQ


1、浏览器地址
http://localhost:15672/
默认用户名和密码为guest

添加用户
rabbitmqctl add_user miaojiang 123

设置用户为管理员
rabbitmqctl set_user_tags miaojiang administrator

配置用户可以远程登录
rabbitmqctl set_permissions -p "/" miaojaing ".*" ".*" ".*"

查看新添加的账户

rabbitmqctl list_users

查看用于的权限
rabbitmqctl list_permissions -p /

三、Spring Boot 项目应用RabbitMQ

3.1、添加Maven依赖：

在你的项目的pom.xml文件中添加RabbitMQ客户端库的依赖

<!--AMQP依赖，包含RabbitMQ-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

3.2、配置RabbitMQ连接：

在Spring Boot的配置文件(application.properties 或 application.yml)中添加RabbitMQ的连接信息。

application.properties:

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

 

在application.yml配置mq的参数：

spring:rabbitmq:#设置RabbitMQ的IP地址host: localhost#设置rabbitmq服务器用户名username: guest#设置rabbitmq服务器密码password: guest#设置rabbitmq服务器连接端口port: 5672

3.3 创建交换机

自定义交换机名称

创建名为“myExchange”的交换机

package com.example.usermanagement.mq;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQConfig {/*使用 @Configuration 注解创建一个配置类，并通过 @Bean 注解创建了一个名为 declareExchange 的方法，用于声明创建交换机。请根据实际情况修改交换机名称、类型和持久化设置。*/public static final String EXCHANGE_NAME = "myExchange";@Beanpublic Exchange declareExchange() {return ExchangeBuilder.directExchange(EXCHANGE_NAME).durable(true).build();}
}

3.4 创建消息发送者

创建消息发送者：创建一个消息发送者的类，用于发送消息到RabbitMQ

package com.example.usermanagement.mq;import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class MessageSender{private final AmqpTemplate amqpTemplate;private final String exchangeName = "myExchange"; // 自定义交换机名称@Autowiredpublic MessageSender(AmqpTemplate amqpTemplate) {this.amqpTemplate = amqpTemplate;}public void sendMessage(Object message) {amqpTemplate.convertAndSend(exchangeName, "", message); // 发送消息到默认交换机和空路由键}
}

注意：

 sendMessage 类型使用的是Object类型

3.5 RabbitMQ管理后台添加对列

步骤：

  1. 打开浏览器，输入RabbitMQ管理后台的URL。默认情况下，该URL为http://localhost:15672/。请确保你的RabbitMQ服务器正在运行，并且端口号正确。

  2. 输入用户名和密码以登录到RabbitMQ管理后台。默认情况下，用户名为guest，密码也为guest。如果你修改过用户名和密码，请使用你的自定义凭据进行登录。

  3. 成功登录后，你将看到RabbitMQ管理后台的主界面。在顶部导航栏中，选择Queues选项卡。

  4. 在Queues页面上，你将看到已经存在的队列列表。如果你想要创建一个新队列，请点击Add a new queue按钮。

  5. 在添加队列的页面上，填写以下信息：

    • Name：队列的名称。为队列提供一个唯一的名称。（如myQueue)
    • Durability：队列的持久性。选择是或否，以指定队列是否应该在RabbitMQ服务重启后保留。
    • Auto delete：队列的自动删除。选择是或否，以指定当最后一个消费者断开连接后，是否删除队列。
    • Arguments：队列的其他参数。这是可选的，你可以为队列设置一些特定的参数。

  6. 填写完队列信息后，点击Add queue按钮以创建队列。

  7. 创建成功后，你将在Queues页面上看到新添加的队列。你可以在该页面上查看队列的详细信息，包括消息数量、消费者数量等。

http://localhost:15672/#/queues

只需要添加队列名称就可以 

 

3.6 调用生产者

1、注入MessageSender实例

@Autowired
private MessageSender messageSender;

2、在需要发送消息的地方调用messageSender.sendMessage方法。根据你的业务逻辑，你可以在合适的位置调用该方法。例如，在订单创建成功后，你可以添加以下代码：

messageSender.sendMessage("订单已创建：" + order.getOrderId());

3.7 创建消息接收者

创建消息接收者：创建一个消息接收者的类，用于处理接收到的RabbitMQ消息。

这里就直接写处理RabbitMQ消息的逻辑。

package com.example.usermanagement.mq;import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class MessageReceiver {@RabbitListener(bindings = @QueueBinding(value = @Queue("your_queue_name"),exchange = @Exchange(value = RabbitMQConfig.EXCHANGE_NAME)
//            key = "your_routing_key"))public void receiveMessage(Object message) {System.out.println("Received message: " + message);// 处理消息逻辑}
}

注意：

 sendMessage 类型使用的是Object类型

your_queue_name 替换为你要监听的队列的名称,（如myQueue)

将 your_routing_key 替换为适当的路由键（如果使用）

 

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

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

相关文章

如何使用CSS实现一个模态框（Modal）效果？

如何使用CSS实现一个模态框（Modal）效果？

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ 使用CSS实现模态框&#xff08;Modal&#xff09;效果⭐ HTML 结构⭐ CSS 样式⭐ JavaScript⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎…
阅读更多...
在 React+Typescript 项目环境中创建并使用组件

在 React+Typescript 项目环境中创建并使用组件

上文 ReactTypescript清理项目环境 我们将自己创建的项目环境 好好清理了一下 下面 我们来看组件的创建 组件化在这种数据响应式开发中肯定是非常重要的。 我们现在src下创建一个文件夹 叫 components 就用他专门来处理组件业务 然后 我们在下面创建一个 hello.tsx 注意 是t…
阅读更多...
【Linux命令详解 | du命令】 du命令用于查看文件或目录的磁盘使用情况，帮助管理存储空间。

【Linux命令详解 | du命令】 du命令用于查看文件或目录的磁盘使用情况，帮助管理存储空间。

文章标题 简介一&#xff0c;参数列表二&#xff0c;使用介绍1. 基本用法2. 以人类可读的格式显示大小3. 显示总计磁盘使用量4. 包括每个文件的大小5. 限制显示的目录深度6. 排除特定文件或目录7. 指定块大小总结 简介 在Linux操作系统中&#xff0c;存储空间管理是至关重要的…
阅读更多...
【C++深入浅出】初识C++上篇（关键字，命名空间，输入输出，缺省参数，函数重载）

【C++深入浅出】初识C++上篇（关键字，命名空间，输入输出，缺省参数，函数重载）

目录 一. 前言 二. 什么是C 三. C关键字初探 四. 命名空间 4.1 为什么要引入命名空间 4.2 命名空间的定义 4.3 命名空间使用 五. C的输入输出 六. 缺省参数 6.1 缺省参数的概念 6.2 缺省参数的分类 七. 函数重载 7.1 函数重载的概念 7.2 函数重载的条件 7.3 C支…
阅读更多...
PSM-DID方法stata操作详解：命令代码、样例数据、参考文献

PSM-DID方法stata操作详解：命令代码、样例数据、参考文献

PSM-DID方法stata操作详解&#xff1a;命令、数据、文献 1、内容&#xff1a;PSM-DID方法的Stata数据、命令、文献&#xff1b;传统DID的Stata数据、命令代码、文献&#xff1b;倾向得分匹配的stata数据、命令代码、DID方法需要满足的五个条件检验代码 2、方法说明&#xff1…
阅读更多...
PS出现的问题——为什么PS另存的格式少了很多

PS出现的问题——为什么PS另存的格式少了很多

在WIN11系统里面新安装的22和23版本PS会出现另存格式少的情况 解决方式&#xff1a;编辑——首选项——文件处理——开启旧版储存为 解决
阅读更多...
反序列化与序列化过程分析

反序列化与序列化过程分析

前言 在学习反序列化的漏洞时,大致都是了解了一些知识,比如序列化就是写入对象,反序列化就是读取文件恢复对象,在这个过程中会自动调用一些方法,readObject,writeObject,静态代码块等,但是从来没有了解过这个过程是怎么样的,一直很模糊,所以在这篇文章里面会记录整个学习过程,…
阅读更多...
python爬虫——爬取天气预报信息

python爬虫——爬取天气预报信息

在本文中&#xff0c;我们将学习如何使用代理IP爬取天气预报信息。我们将使用 Python 编写程序&#xff0c;并使用 requests 和 BeautifulSoup 库来获取和解析 HTML。此外&#xff0c;我们还将使用代理服务器来隐藏我们的 IP 地址&#xff0c;以避免被目标网站封禁。 1. 安装必…
阅读更多...
7-3 查询水果价格

7-3 查询水果价格

分数 15 全屏浏览题目 切换布局 作者 C课程组 单位 浙江大学 给定四种水果&#xff0c;分别是苹果&#xff08;apple&#xff09;、梨&#xff08;pear&#xff09;、桔子&#xff08;orange&#xff09;、葡萄&#xff08;grape&#xff09;&#xff0c;单价分别对应为3.00…
阅读更多...
YOLOv5算法改进（1）— 如何去改进YOLOv5算法

YOLOv5算法改进（1）— 如何去改进YOLOv5算法

前言&#xff1a;Hello大家好&#xff0c;我是小哥谈。YOLOv5基础知识入门系列、YOLOv5源码中的参数超详细解析系列和YOLOv5入门实践系列学习完成之后&#xff0c;接着就进入YOLOv5进阶改进算法系列了。&#x1f389;为了让大家能够清楚地了解如何去改进YOLOv5算法以及从哪几方…
阅读更多...
Android Framework 动态更新插拔设备节点执行权限

Android Framework 动态更新插拔设备节点执行权限

TF卡设备节点是插上之后动态添加&#xff0c;所以不能通过初始化设备节点权限来解决&#xff0c;需要监听TF插入事件&#xff0c;在init.rc 监听插入后动态更新设备节点执行权限 添加插拔TF卡监听 frameworks/base/services/core/java/com/android/server/StorageManagerServic…
阅读更多...
到江西赣州ibm维修服务器之旅-联想X3850 x6黄灯故障

到江西赣州ibm维修服务器之旅-联想X3850 x6黄灯故障

2023年08月15日&#xff0c;一位江西赣州工厂客户通过朋友介绍与冠峰售前工程师取得联系&#xff0c;双方对产品故障前后原因沟通的大致情况如下&#xff1a; 服务器型号&#xff1a;Lenovo system x3850 x6 为用户公司erp仓库服务器 服务器故障&#xff1a;正常使用过程中业…
阅读更多...
GET和POST的区别，java模拟postman发post请求

GET和POST的区别，java模拟postman发post请求

目录 一、先说一下get和post1、看一下人畜无害的w3schools怎么说&#xff1a;2、问一下文心你言哥&#xff0c;轻轻松松给你一个标准答案&#xff1a;3、卧槽&#xff0c;懂了&#xff0c;好像又没懂 二、让我们扒下GET和POST的外衣&#xff0c;坦诚相见吧&#xff01;三、我们…
阅读更多...
时序预测 | MATLAB实现基于KNN K近邻的时间序列预测-递归预测未来(多指标评价)

时序预测 | MATLAB实现基于KNN K近邻的时间序列预测-递归预测未来(多指标评价)

时序预测 | MATLAB实现基于KNN K近邻的时间序列预测-递归预测未来(多指标评价) 目录 时序预测 | MATLAB实现基于KNN K近邻的时间序列预测-递归预测未来(多指标评价)预测结果基本介绍程序设计参考资料 预测结果 基本介绍 基于KNN K近邻的时间序列预测-递归预测未来(多指标评价) …
阅读更多...
案例18 基于Spring Boot+MyBatis的图书信息维护案例

案例18 基于Spring Boot+MyBatis的图书信息维护案例

一、案例需求 基于Spring BootMyBatis实现图书信息的新增、修改、删除、查询功能&#xff0c;并实现MySQL数据库的操作。 MySQL数据库创建图书表&#xff08;t_book&#xff09;&#xff0c;图书表有主键、图书名称、图书类别、作者、出版社、简介信息。 二、数据初始化 创建…
阅读更多...
吐血整理，接口自动化测试-接口依赖/上传接口处理（项目实例）

吐血整理，接口自动化测试-接口依赖/上传接口处理（项目实例）

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 常见的两种接口依…
阅读更多...
【Vue-Router】别名

【Vue-Router】别名

后台返回来的路径名不合理&#xff0c;但多个项目在使用中了&#xff0c;不方便改时可以使用别名。可以有多个或一个。 First.vue <template><h1>First Seciton</h1> </template>Second.vue&#xff0c;Third.vue代码同理 UserSettings.vue <tem…
阅读更多...
vue 获取设备指纹

vue 获取设备指纹

import Fingerprint2 from fingerprintjs2 // async 异步请求 async getFingerprint () {return new Promise((resolve, reject) > {Fingerprint2.getV18({}, (result, components) > {resolve(result)})})}, // 获取用户sessionasync getSession () {/* 等待获取设备指纹…
阅读更多...
【C# 基础精讲】继承、封装、多态

【C# 基础精讲】继承、封装、多态

继承&#xff08;Inheritance&#xff09;、封装&#xff08;Encapsulation&#xff09;和多态&#xff08;Polymorphism&#xff09;是面向对象编程中的三大核心概念&#xff0c;它们构成了面向对象编程的基础&#xff0c;有助于创建更加模块化、可扩展和可维护的代码。这三个…
阅读更多...
【教程】零成本将小米净化器改造为无叶风扇

【教程】零成本将小米净化器改造为无叶风扇

某宝某多上&#xff0c;就这么点破塑料&#xff0c;就要买79&#xff1f;&#xff01;&#xff01; 我这枚韭菜可不上当。咱自己做一个&#xff01; 真香~
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023