使用 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 集成实现基于消息的事件驱动|微资讯
-
安徽出台“46条”!引导社会资本投向十大新兴产业 焦点热闻
-
天天热讯:炸鸡品牌Popeyes上海所有门店暂停营业
-
法院:浏览记录既是用户个人信息也或是视频发布者个人信息 环球简讯
-
2023中国软件创新发展大会:使能软件创新 共建繁荣生态
-
世界讯息:头顶两份对赌协议,珠海万达商管IPO延期,万达系年内筹资百亿
-
2023年长三角医学创新转化峰会合肥召开 最资讯
-
今日牛里脊是身上哪个部位_牛里脊是哪个部位
-
世界快资讯:王皓错了吗?深度分析:樊振东输勒布伦之战,决胜局该不该暂停?
-
划转与划拨的区别_划转|快资讯
-
通讯!机构调研最新生态!偏爱中大盘蓝筹股 小市值新股也香 大数据来了!
-
提升爱路护路意识 守护铁路沿线安全
-
vuhdo巫毒讲解(vuhdo)
-
全球看点:解酒的最好方式_解酒的最好方法有哪些
-
如何为谷歌助理例程添加延迟
-
女生万岁第2季_女生万岁_环球微资讯
-
安德鲁拜纳姆薪水(安德鲁拜纳姆)-世界今日讯
-
勉县开展全民阅读系列活动_环球热头条
-
无水硫酸钠是元明粉吗_用14 2g无水硫酸钠
-
明日方舟四周年皮肤返场有哪些 明日方舟四周年返场皮肤一览|天天视点
-
天天观热点:工信部等八部门发布推进IPv6演进和应用实施意见
-
两岸道教界在湖北武当山谒祖联谊、文化研讨
-
世界热推荐:他图你身体,你图他钱财,被抓着双马尾时幻想着少奶奶生活吧
-
热讯:俄罗斯外长结束拉美四国访问 各方一致反对部分国家实施霸权主义
-
阔腿裤如何搭配上衣_阔顿_全球滚动
-
知之为知知不知为不知是知也的意思_是知也的意思
-
世界播报:陈梦大战王曼昱,赢得最终的冠军,才是真正的大圆满
-
书山有路“趣”为径 2023“儿童阅力计划”发布《中国儿童阅读发展研究报告》
-
台退将:美国人很清楚“台海战争”不值得打_环球微动态
-
【环球快播报】这个城区四环边板块,人大附落地,也难救起...
-
真相令人吃惊_真相令人唏嘘什么意思-全球微资讯
-
小雄乱入夜干大姐二姐_夜干二姐有声小说_世界热头条
-
树脂纸糊的制作方法_第一次送女友什么礼物比较有意义
-
当前动态:[中职]大众工业学校:上海市第一届职业技能大赛,大众师生在比赛、在服务、在观摩
-
2023全年托福考试时间安排(1-12月考试时间公布)