Spring Cloud 项目中实现推送消息到 RabbitMQ 消息中间件

简介: Spring Cloud 项目中实现推送消息到 RabbitMQ 消息中间件


(注:安装在虚拟机则填虚拟机地址,否则则为本机地址)

用户名和密码都为guest

看到如下页面则为RabbitMQ安装登录成功。

三、依赖注入

导入依赖坐标

四、配置yaml文件

配置yaml配置文件

(注:host为地址,如果安装在虚拟机则为虚拟机地址,安装在本机则本机地址。port为端口号,务必注意的是配置文件里写的是5672,而网页访问的是15672)

五、添加业务层代码

这里的业务逻辑其实很简单。本文的业务环境是用户订阅作者,之后作者发文章,他的粉丝都能够收到消息中间件发送的消息。而本文实现的是,将消息发送至消息中间件中,后续文章将介绍如何将消息中间件中的消息发送给用户

业务层添加rabbit模板

订阅部分,也就是发送消息给消息中间件的前提:创建好交换机,路由键,以及队列,并且用户订阅作者,就相当于将队列绑定到交换机上,并且有路由键作为关联

实现以上业务逻辑之后,粉丝与作者就已经绑定好了,那么当作者发文章之后,程序就像消息中间件发送消息,因此在作者发送文章的方法内,添加如下代码即可

六、测试

首先用户关注某个作者,在用作者的账号发送文章。在消息中间件中即可收到发送的消息

结语:此处难点为发送消息之前需要先创建交换机,之后将队列绑定给交换机,并且关联路由键。


相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
19天前
|
消息中间件 存储 RocketMQ
消息中间件-RocketMQ技术(二)
消息中间件-RocketMQ技术(二)
|
19天前
|
消息中间件 存储 中间件
消息中间件-RocketMQ技术(一)
消息中间件-RocketMQ技术(一)
|
2天前
|
Java 应用服务中间件 Android开发
Eclipse创建Spring项目
本文介绍了在Eclipse中创建Spring项目的步骤,包括如何配置Tomcat服务器、创建项目、部署项目到Tomcat以及添加Spring框架所需的JAR包。
13 1
Eclipse创建Spring项目
|
4天前
|
Java Spring
ij社区版如何创建spring项目
如何在IntelliJ IDEA社区版中创建Spring项目,包括安装Spring Boot Helper插件的步骤和创建过程。
14 1
ij社区版如何创建spring项目
|
3天前
|
前端开发 Java 应用服务中间件
【Spring】Spring MVC的项目准备和连接建立
【Spring】Spring MVC的项目准备和连接建立
16 2
|
3天前
|
XML Java 应用服务中间件
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
36 2
|
3天前
|
前端开发 安全 Java
【Spring】Spring Boot项目创建和目录介绍
【Spring】Spring Boot项目创建和目录介绍
21 2
|
3天前
|
Java 应用服务中间件 Maven
idea+maven+tomcat+spring 创建一个jsp项目
这篇文章介绍了如何在IntelliJ IDEA中使用Maven和Tomcat创建一个JSP项目,包括配置Maven依赖、设置Tomcat服务器、编写JSP页面、创建控制器和配置文件,以及项目的运行结果。
19 0
idea+maven+tomcat+spring 创建一个jsp项目
|
10天前
|
存储 NoSQL Java
Spring Boot项目中使用Redis实现接口幂等性的方案
通过上述方法,可以有效地在Spring Boot项目中利用Redis实现接口幂等性,既保证了接口操作的安全性,又提高了系统的可靠性。
14 0
|
18天前
|
Java Spring
spring boot 启动项目参数的设定
spring boot 启动项目参数的设定