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.hqwc.cn/news/67628.html

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

相关文章

TCP消息传输可靠性保证

TCP消息传输可靠性保证

TCP链接与断开 -- 三次握手&四次挥手 三次握手 TCP 提供面向有连接的通信传输。面向有连接是指在数据通信开始之前先做好两端之间的准备工作。 所谓三次握手是指建立一个 TCP 连接时需要客户端和服务器端总共发送三个包以确认连接的建立。在socket编程中&#xff0c;这一…
阅读更多...
Android布局【GridLayout】

Android布局【GridLayout】

文章目录 GridLayout概述常见属性子控件属性项目结构主要代码 GridLayout概述 GridLayout也名网格布局,该布局与TableLayout类似&#xff0c;但与其相比&#xff0c;GridLayout会更加的灵活&#xff0c;比如 TableLayout不能将两行进行一个合并&#xff0c;只能将两列进行一个…
阅读更多...
Django之定时任务--apscheduler

Django之定时任务--apscheduler

Django--定时任务apscheduler的使用 apscheduler定时任务的使用1、安装包2、配置settings.py3、在manage.py的文件同级目录下创建文件scheduler.py4、在项目的urls.py中调用这个定时计划5、然后启动项目 python manage.py runserver,在admin中查看就能看到你的定时任务及执行的…
阅读更多...
ORB-SLAM2第五节---局部地图跟踪（阶段二）

ORB-SLAM2第五节---局部地图跟踪（阶段二）

保证三种跟踪方式更加准确 1.局部关键帧 当前帧F的局部关键帧包括&#xff1a; 能够观测到当前帧F中地图点的共视关键帧KF1、KF2&#xff0c;称为一级共视关键帧。一级共视关键帧的共视关键帧&#xff08;前10个共视程度最高的关键帧&#xff09;&#xff0c;比如图中的KF1的…
阅读更多...
Dubbo 核心概念和架构

Dubbo 核心概念和架构

以上是 Dubbo 的工作原理图&#xff0c;从抽象架构上分为两层&#xff1a;服务治理抽象控制面 和 Dubbo 数据面 。 服务治理控制面。服务治理控制面不是特指如注册中心类的单个具体组件&#xff0c;而是对 Dubbo 治理体系的抽象表达。控制面包含协调服务发现的注册中心、流量管…
阅读更多...
无需停服！PostgreSQL数据迁移工具-NineData

无需停服！PostgreSQL数据迁移工具-NineData

PostgreSQL 是一种备受开发者和企业青睐的关系型数据库&#xff0c;其丰富的数据类型、地理空间负载和强大的扩展能力等特性使其备受欢迎。然而&#xff0c;在企业使用 PostgreSQL 承载应用的过程中&#xff0c;由于业务需要上云、跨云、下云、跨机房迁移、跨地域迁移、数据库版…
阅读更多...
ElasticSearch安装与介绍

ElasticSearch安装与介绍

Elastic Stack简介 如果没有听说过Elastic Stack&#xff0c;那你一定听说过ELK&#xff0c;实际上ELK是三款软件的简称&#xff0c;分别是Elasticsearch、 Logstash、Kibana组成&#xff0c;在发展的过程中&#xff0c;又有新成员Beats的加入&#xff0c;所以就形成了Elastic…
阅读更多...
【PostgreSQL的CLOG解析】

【PostgreSQL的CLOG解析】

同样还是这张图&#xff0c;之前发过shared_buffer和os cache、wal buffer和work mem的文章&#xff0c;今天的主题是图中的clog&#xff0c;即 commit log&#xff0c;PostgreSQL10之前放在数据库目录的pg_clog下面。PostgreSQL10之后修更名为xact,数据目录变更为pg_xact下面&…
阅读更多...
Scratch 之 制作超丝滑 FNF 推条

Scratch 之 制作超丝滑 FNF 推条

这个教程是不用画笔的&#xff0c;所以不用担心推条是最后一层了&#xff01; 导入素材 你以为真是这样吗&#xff1f;NO&#xff0c;NO&#xff0c;NO&#xff0c;其实是这样的 没错&#xff0c;中间是空的&#xff01;中间是空的&#xff01;中间是空的&#xff01;&#xf…
阅读更多...
构建 LVS-DR 群集、配置nginx负载均衡。

构建 LVS-DR 群集、配置nginx负载均衡。

目录 一、基于 CentOS 7 构建 LVS-DR 群集 1、准备四台虚拟机 2、配置负载调度器&#xff08;192.168.2.130&#xff09; 3、部署共享存储&#xff08;192.168.2.133&#xff09; 4、配置两个Web服务器&#xff08;192.168.2.131、192.168.2.132&#xff09; 测试集群 二…
阅读更多...
（隐性）类型转换和算数转换

（隐性）类型转换和算数转换

类型转换&#xff08;char,short&#xff09; 几个char 类型或者short 类型的数相加&#xff0c;会把他们提升为整形来相加 整型提升的意义&#xff1a; 表达式的整型运算要在CPU的相应运算器件内执行&#xff0c;CPU内整型运算器(ALU)的操作数的字节长度 一般就是int的字节长…
阅读更多...
嵌入式 C 语言程序数据基本存储结构

嵌入式 C 语言程序数据基本存储结构

一、5大内存分区 内存分成5个区&#xff0c;它们分别是堆、栈、自由存储区、全局/静态存储区和常量存储区。 1、栈区(stack)&#xff1a;FIFO就是那些由编译器在需要的时候分配&#xff0c;在不需要的时候自动清除的变量的存储区。里面的变量通常是局部变量、函数参数等。 ​…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023