使用 Spring Cloud Bus 在微服务之间传递消息示例

2023-04-23 08:36:48 来源: 腾讯云


【资料图】

下面是一个完整的示例,演示如何使用 Spring Cloud Bus 在微服务之间传递消息。该示例包含两个微服务,一个是消息发送者,另一个是消息接收者。

首先,我们需要创建一个 Spring Boot 项目,并添加 Spring Cloud Bus 和 RabbitMQ 的依赖。在 pom.xml 文件中添加以下依赖:

    org.springframework.cloud    spring-cloud-starter-bus-amqp    2.2.1.RELEASE    org.springframework.boot    spring-boot-starter-web    2.2.1.RELEASE    org.springframework.boot    spring-boot-starter-amqp    2.2.1.RELEASE

在创建的项目中,我们定义了一个消息类型 MyMessage,该类型包含一个字符串类型的 content 属性。

javaCopy codepublic class MyMessage implements Serializable {    private static final long serialVersionUID = 1L;    private String content;    public MyMessage(String content) {        this.content = content;    }    public String getContent() {        return content;    }    public void setContent(String content) {        this.content = content;    }}

然后,我们创建了一个消息发送者,该发送者使用 Spring Cloud Bus 发送消息。

@RestControllerpublic class MyController {    @Autowired    private MessageSender messageSender;    @PostMapping("/send")    public void sendMessage(@RequestBody MyMessage message) {        messageSender.sendMessage(message);    }}@Servicepublic class MessageSender {    private static final Logger LOGGER = LoggerFactory.getLogger(MessageSender.class);    @Autowired    private MessageChannel output;    public void sendMessage(MyMessage message) {        LOGGER.info("Sending message: {}", message.getContent());        output.send(MessageBuilder.withPayload(message).build());    }}@Servicepublic class MessageListener {    private static final Logger LOGGER = LoggerFactory.getLogger(MessageListener.class);    @StreamListener(target = Sink.INPUT, condition = "headers["type"]=="MyMessage"")    public void handleMessage(MyMessage message) {        LOGGER.info("Received message: {}", message.getContent());    }}

在这个例子中,我们创建了一个 MyController 类,该类定义了一个发送消息的 API 接口,接收一个 MyMessage 类型的参数,将参数传递给 MessageSender 类的 sendMessage() 方法。

MessageSender 类定义了一个 sendMessage() 方法,该方法使用 Spring Cloud Stream 的 output 消息通道发送消息。

MessageListener 类定义了一个 handleMessage() 方法,该方法使用 @StreamListener 注解监听 Spring Cloud Stream 的 input 消息通道,并根据消息类型过滤消息。当有符合条件的消息到达时,handleMessage() 方法会被自动调用,处理接收到的消息。

在以上代码中,我们使用了 @Autowired 注解自动注入了 MessageSender 和 MessageListener 类,这是 Spring Boot 自带的依赖注入功能。

运行应用程序后,我们可以使用 Postman 工具或其他 HTTP 工具发送 HTTP POST 请求,将消息发送到消息发送者的 API 接口,如下所示:

POST http://localhost:8080/send HTTP/1.1Content-Type: application/json{    "content": "Hello, World!"}

当消息到达时,消息接收者会打印消息内容,如下所示:

2023-04-19 09:24:47.836  INFO 29740 --- [afka-listener-1] com.example.demo.M

关键词:

精选 导读

为什么显示版本不兼容(网页会提示版本不兼容的原因) 环球

为什么显示版本不兼容,网页会提示版本不兼容的原因很多人还不知道,现在让我们一起来看看吧!解答:1、因

发布时间: 2023-04-23 08:33
要闻   2023-04-23

体育节|最资讯

1942年,在抗日战争的艰苦时期,南京国民政府设置了全国性的体育节。在中国历史上,体育活动的开展堪称久远

发布时间: 2023-04-23 08:07
要闻   2023-04-23

备孕前三个月饮食列表_备孕前三个月吃什么好

1、在怀孕的前3个月多吃一些维生素比较丰富的食物,因为维生素可以帮助女人卵子和受精卵的发育和成长,也要

发布时间: 2023-04-23 07:33
要闻   2023-04-23

法硕考研培训班哪个好_法硕考研 速看

1、法学硕士考研需要考政治理论、外国语(英、日、俄选一)、专业综合课(含宪法、法学基础理论、中国法制史

发布时间: 2023-04-23 07:04
要闻   2023-04-23

自己写的协议具有法律效力吗|环球快看

一、自己写的协议具有法律效力吗自己写的协议具有法律效力,但需要行为人具有相应的民事行为能力、意思表示

发布时间: 2023-04-23 06:26
要闻   2023-04-23

热点 推荐

使用 Spring Cloud Bus 在微服务之间传递消息示例

下面是一个完整的示例,演示如何使用SpringCloudBus在微服务之间传递消息。该示例包含两个微服务,一个是消

发布时间: 2023-04-23 08:36
IT   2023-04-23

北京西站到大兴机场大巴多少钱(北京西站到大兴机场)|今日

1、52分钟约50 1公里|1 8公里拥堵途经:京开高速、大兴机场高速北京西站(地铁站)莲花池东路700米莲花池东路

发布时间: 2023-04-23 08:50
国内   2023-04-23

为什么显示版本不兼容(网页会提示版本不兼容的原因) 环球

为什么显示版本不兼容,网页会提示版本不兼容的原因很多人还不知道,现在让我们一起来看看吧!解答:1、因

发布时间: 2023-04-23 08:33
要闻   2023-04-23

什么的眼睛填空(什么的眼睛填空)-天天热点评

1、什么的眼睛(填空):(水汪汪)的眼睛、(大大)的眼睛、(一样)的眼睛、(水灵灵)的眼睛、(亮晶晶)的眼睛、(明

发布时间: 2023-04-23 08:19
科技   2023-04-23

美团助力车怎么收费

1、首先打开支付宝,点击查看全部应用,如下图所示。2、2、在应用中找到哈啰出行,如下图所示。3、3、然后

发布时间: 2023-04-23 08:34
IT   2023-04-23

当前最新:北境遗孤

苏 俄海军舰艇一览(二)前言:1 科普内容,不做商业目的。2 仅对服役 退役 非保密装备分类,以2022年公布

发布时间: 2023-04-23 08:01
国内   2023-04-23

体育节|最资讯

1942年,在抗日战争的艰苦时期,南京国民政府设置了全国性的体育节。在中国历史上,体育活动的开展堪称久远

发布时间: 2023-04-23 08:07
要闻   2023-04-23

神态描写精彩片段200字_神态描写精彩片段

1、他真的生气了,双手紧紧握住,微微颤抖着。2、胸脯剧烈地起伏着,仿佛就要爆炸的一个大气球,脖子上的经

发布时间: 2023-04-23 07:55
科技   2023-04-23

周星驰的配音是谁呢_周星驰的配音是谁

1、他的原名叫石兆采,艺名石班瑜,年龄比周星驰略大,差不多有42、43岁。2、1985年开始进入配音界 。本文分享

发布时间: 2023-04-23 08:07
IT   2023-04-23

德国国家旅游局微信公众号21日称,自2023年5月1日起德国将恢

德国国家旅游局微信公众号21日称,自2023年5月1日起德国将恢复开放旅游签证。所有针对从中国赴德游客的入境

发布时间: 2023-04-23 07:57
国内   2023-04-23

天天热文:dnf红眼用什么徽章_dnf徽章怎么用

1、徽章是直接戴不了的,只有镶嵌在装备上才可以戴,2、而镶嵌徽章是在天空那边的达芙妮,40万开2个孔,3、不一

发布时间: 2023-04-23 07:28
国内   2023-04-23

备孕前三个月饮食列表_备孕前三个月吃什么好

1、在怀孕的前3个月多吃一些维生素比较丰富的食物,因为维生素可以帮助女人卵子和受精卵的发育和成长,也要

发布时间: 2023-04-23 07:33
要闻   2023-04-23

施慧达说明书用量_施慧达说明书

1、要是有高血压或者是心绞痛的话是可以用施慧达这个药的,而且一般这个药就是用于这两种疾病之上的,不过

发布时间: 2023-04-23 07:14
科技   2023-04-23

缝针后不能吃什么蔬菜_缝针后不能吃什么|每日聚焦

1、缝针后需要注意休息,可以服用一些活血化瘀,消炎止痛的药物以防止感染发生。2、缝针之后需要定时消毒,

发布时间: 2023-04-23 07:24
IT   2023-04-23

法硕考研培训班哪个好_法硕考研 速看

1、法学硕士考研需要考政治理论、外国语(英、日、俄选一)、专业综合课(含宪法、法学基础理论、中国法制史

发布时间: 2023-04-23 07:04
要闻   2023-04-23

沧州特产礼品专卖_沧州特产

1、答:徐州特产是小儿酥和王集香肠,沧州特产是金丝小枣和泊头鸭梨。2、徐州特产一:小孩酥3、小孩酥是江苏

发布时间: 2023-04-23 06:56
科技   2023-04-23

与桥有关的俗语_与母亲有关的俗语

1、娘,老妈,妈妈。2、妈咪,妈,阿妈。以上就是【与桥有关的俗语,与母亲有关的俗语】相关内容。

发布时间: 2023-04-23 06:51
IT   2023-04-23

焦点快播:掷铁饼者是什么时期的作品(掷铁饼者是什么流派作

《掷铁饼者》中,艺术家把握住了从一种状态转换到另一种状态的关键环节,达到了使观众心理上获得“运动感”

发布时间: 2023-04-23 06:42
国内   2023-04-23

自己写的协议具有法律效力吗|环球快看

一、自己写的协议具有法律效力吗自己写的协议具有法律效力,但需要行为人具有相应的民事行为能力、意思表示

发布时间: 2023-04-23 06:26
要闻   2023-04-23

高速上撞死人要坐牢吗 环球热推荐

一、高速上撞死人要坐牢吗高速上撞死人是否需要坐牢,要看是否承担主要责任或者全部责任。具体是:开车在高

发布时间: 2023-04-23 06:19
科技   2023-04-23