使用 Spring Cloud Bus 和 Spring Cloud Stream 集成实现基于消息的事件驱动 每日快播
基于消息的事件驱动是一种常见的微服务架构设计模式,它将不同的微服务之间通过消息进行通信,实现松耦合、高可伸缩性和高可靠性。在这种架构下,每个微服务都是独立的,它们可以在消息传递的过程中进行异步操作,这使得整个系统的性能得到了很大的提升。
【资料图】
在 Spring Cloud 中,我们可以使用 Spring Cloud Bus 和 Spring Cloud Stream 集成来实现基于消息的事件驱动。Spring Cloud Bus 是一个消息总线,它可以在微服务之间传递消息,可以将所有微服务视为一个整体,向所有微服务广播消息或向指定的微服务发送消息。Spring Cloud Stream 是一个消息驱动的微服务框架,它可以轻松地将消息通道与微服务进行集成。
准备工作
首先,我们需要在 pom.xml 文件中添加以下依赖:
org.springframework.cloud spring-cloud-starter-bus-amqp org.springframework.cloud spring-cloud-stream-binder-rabbit
这些依赖将会引入 Spring Cloud Bus 和 Spring Cloud Stream 的相关库,并且使用 RabbitMQ 作为消息代理。如果你想使用其他消息代理,可以根据实际需求进行修改。
创建消息通道
在这个例子中,我们将创建一个名为 myChannel 的消息通道,用于在微服务之间传递消息。在创建消息通道之前,我们需要在 application.yml 文件中添加以下配置:
spring: cloud: stream: bindings: myChannel: destination: myChannel
这个配置将创建一个名为 myChannel 的消息通道,并将它绑定到 RabbitMQ 的 myChannel 队列上。现在,我们可以在代码中使用 @Input 和 @Output 注解来定义输入和输出消息通道了。
public interface MyChannel { String INPUT = "myInput"; String OUTPUT = "myOutput"; @Input(INPUT) SubscribableChannel input(); @Output(OUTPUT) MessageChannel output();}
这个接口定义了一个名为 MyChannel 的消息通道,其中包括一个名为 myInput 的输入消息通道和一个名为 myOutput 的输出消息通道。
发布消息
在这个例子中,我们将创建一个名为 MyController 的控制器类,该类将发布一个名为 MyMessage 的消息到 myOutput 消息通道上。
@RestControllerpublic class MyController { @Autowired private MessageChannel output; @PostMapping("/send") public void sendMessage(@RequestBody MyMessage message) { output.send(MessageBuilder.withPayload(message).build()); }}
这个控制器类注入了名为 output 的 MessageChannel,用于向 myOutput 消息通道发送消息。在 sendMessage 方法中,我们通过 MessageBuilder 创建一个名为 message 的 MyMessage 消息,然后通过 output.send 方法将这个消息发送到 myOutput 消息通道上。
处理消息
在这个例子中,我们将创建一个名为 MyListener 的监听器类,该类将监听 myInput 消息通道上的消息,并将消息打印到控制台上。
@EnableBinding(MyChannel.class)public class MyListener { @StreamListener(MyChannel.INPUT) public void handleMessage(MyMessage message) { System.out.println("Received message: " + message); }}
这个监听器类使用 @EnableBinding 注解将 MyChannel 消息通道绑定到 Spring Cloud Stream 上。在 handleMessage 方法中,我们使用 @StreamListener 注解监听 myInput 消息通道上的消息,当有消息到来时,Spring Cloud Stream 将自动将消息转换为 MyMessage 类型,并将其传递给 handleMessage 方法进行处理。在这个例子中,我们只是简单地将消息打印到控制台上,你可以根据实际需求进行修改。
运行测试
现在,我们已经创建了消息通道、发布了消息和处理了消息,我们可以启动应用程序并测试它了。首先,我们需要在终端窗口中启动 RabbitMQ,执行以下命令:
cssCopy codedocker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
这个命令将启动一个名为 rabbitmq 的容器,并将其映射到本地主机的 5672 和 15672 端口上。现在,我们可以启动应用程序并访问 http://localhost:8080/send发送消息了。在控制台中,你应该可以看到类似下面的输出:
Received message: MyMessage{id=1, content="Hello, world!"}
这表明消息已经成功传递到了 myInput 消息通道,并被 MyListener 监听到并处理了。
关键词:
- 使用 Spring Cloud Bus 和 Spring Cloud Stream 集成实现基于消息的事件驱动 每日快播(2023-04-21 16:04:35)
- NYMEX鍘熸补鏂欒穼鐮?6.19缇庡厓 天天新要闻(2023-04-21 16:13:42)
- 环球即时:身上长癣是什么原因引起的_身上长癣是什么原因(2023-04-21 16:08:33)
- 港股异动 | 黄金股走低 国际金价午后跌超1%_全球观察(2023-04-21 15:55:52)
- 高盛:企业能承受银行收紧贷款标准 继续看好美国信贷市场(2023-04-21 16:00:28)
- 【世界聚看点】金价又涨啦!2023年4月21日各大金店黄金价格多少钱一克?(2023-04-21 15:58:47)
- 天天热讯:嘉祥农商银行发放首笔“带押过户”贷款(2023-04-21 15:44:48)
- 金融纵览 | 银行业周报(4.14—4.21)(2023-04-21 15:42:43)
- 高端化能扭转中国啤酒业吗?_当前速读(2023-04-21 15:56:58)
- 装作开发者就能“骗”ChatGPT作恶?日本专家:这是一个风险点(2023-04-21 15:59:41)
- 世界即时:日本核心通胀率正以40年来最快增速扩大 面临空前物价压力(2023-04-21 15:45:01)
- 环球消息!因发布GPT不准确信息或误导投资者 ST信通及时任董事被上交所监管警示(2023-04-21 15:53:09)
- 苏文电能2022年营收23.57亿 净利2.56亿 董事长施小波薪酬14.07万 简讯(2023-04-21 15:37:11)
- 出租率高达97%,星河的“产城融投”实践实录(2023-04-21 15:27:06)
- 环球今日讯!延吉空港区打造区域氢能经济产业集群(2023-04-21 15:19:36)
- 不超30人!云南师大附中普通高中基础学科英才培养基地今年首招_世界通讯(2023-04-21 15:17:43)
- 国际收支数据乐观,汇丰预测欧元数月内将涨至1.15! 世界观点(2023-04-21 15:19:45)
- 天天动态:“仰望”国产车!多位保时捷高管围观比亚迪展台(2023-04-21 15:08:07)
- 世界热头条丨ETF追踪:昨日ETF净申购8.51亿元 资金加仓上证50ETF(2023-04-21 14:54:04)
- 二手房交易格式合同藏猫腻(2023-04-21 14:53:43)
- 护理工作年终总结范文(合集3篇) 前沿热点(2023-04-21 15:08:15)
- 最新:取款又面临新政策!现已实施,有存款的朋友快看看(2023-04-21 14:50:54)
- 最新:建设银行存款利率公布,存10万可以拿8250元,想存钱的看看_今日热文(2023-04-21 14:46:41)
- 最新:农村信用社存款利率更新,利率高达4.5%,是真的吗? 世界新要闻(2023-04-21 14:59:25)
- 最新:建设银行大额存单来了,3年利息很高,存100万拿9万利息|热头条(2023-04-21 14:59:47)
- 世界即时看!中国全力印钞,国人疯狂存款,存款是普通人最大的底气!(2023-04-21 14:48:35)
- 4月21日证券之星午间消息汇总(2023-04-21 14:59:57)
- 世界快报:艾柯医疗冲刺科创板上市:拟募资10亿元,已初步商业化(2023-04-21 14:42:28)
- 看热讯:晋商银行房地产不良贷两年狂飙34倍 贷款集中度达65.4%超监管红线(2023-04-21 14:54:47)
- 【世界速看料】底部三线交叉短线买入法(2023-04-21 14:42:09)
-
苏文电能2022年营收23.57亿 净利2.56亿
苏文电能2022年营收23 57亿净利2 56亿董事长施小波薪酬14 07万2023 4 2110:18:03...
-
出租率高达97%,星河的“产城融投”实践实录
作者|刘玉娇编辑|夏县明、梁秀杰视觉|刘玉娇责编|韩玮烨据联合资信发布的星河实业2022...
-
环球今日讯!延吉空港区打造区域氢能经济产
总投资5 5亿元的延吉空港区吉浙对口合作产业基地建设项目预计今年11月底完工。项目建...
-
不超30人!云南师大附中普通高中基础学科英
不超30人!云南师大附中普通高中基础学科英才培养基地今年首招
-
国际收支数据乐观,汇丰预测欧元数月内将涨
汇丰控股HSBC预测欧元兑美元汇率将走高分析师表示欧元区最新的一组国际收支数据巩固了...
-
天天动态:“仰望”国产车!多位保时捷高管
备受关注的2023上海车展正在如火如荼的进行中,在此次上海车展上,比亚迪正式带来了旗...
-
世界热头条丨ETF追踪:昨日ETF净申购8.51亿
4月20日,两市成交额11387亿,较上个交易日放量561亿。东方财富Choice数据显示,当日场...
-
二手房交易格式合同藏猫腻
本文转自:中国市场监管报案件简介2022年10月25日,河南省济源示范区市场监管局在检查...
-
护理工作年终总结范文(合集3篇) 前沿热点
护理工作年终总结范文第1篇20xx年将要过去,在这一年来,在院长的正确领导下,在医护人...
-
最新:取款又面临新政策!现已实施,有存款
随着科技的不断进步,我们的生活也在发生着翻天覆地的变化。现如今,人们大多数都会通...
- 滚动
- 综合
- 房产