环球热议:使用 Spring Cloud Bus 在微服务之间传递消息示例

发布时间:2023-04-19 19:00:01     来源:腾讯云


(资料图片仅供参考)

下面是一个完整的示例,演示如何使用 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

标签:

精彩推送

乘用车市场信息联席会发布数据 10月乘用车市场零售为184万辆

11月8日,乘用车市场信息联席会发布数据显示,今年前10个月乘用车市场零售达1671 6万辆,同比增长3%,...

2022-11-09

至正股份发布公告 拟1.19亿元收购苏州桔云51%股权

11月8日晚间,至正股份(603991)发布公告称,公司与SUCCESS FACTORS LIMITED签署了《购买资产协议》,...

2022-11-09

旅游合同暗藏猫腻 中消协点评这些属于不公平条款

11月8日,中国消费者协会官网发布《不公平格式条款点评系列九:旅游领域不公平格式条款点评》,其中针对...

2022-11-09

天键股份IPO排队近11个月 天键股份冲A胜算几何

在同行业企业迪芬尼、豪恩声学IPO告败后,电声产品制造商天键电声股份有限公司(以下简称天键股份)也向A...

2022-11-09

MSCI入摩“三步走” 三年MSCI主题基金不断涌现

自2019年11月8日,美国明晟公司(又称摩根士丹利资本国际公司,MorganStanleyCapitalInternational,以下...

2022-11-09

北京约有2.45亿平米存量建筑需更新,城市更新是长线投资需“耐心资本”

北京约有2 45亿平米存量建筑需更新,城市更新是长线投资需“耐心资本”,运营,北京市,存量建筑,长线投资,专项规划

环球热议:使用 Spring Cloud Bus 在微服务之间传递消息示例

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

环球关注:定了!南通这里即将拆迁!

定了!南通这里即将拆迁!,拆迁,新盘,安置房,老城区,商品房,南通市,商品住房

天天热点评!重磅!南京主城六区房票安置新政,拆迁直接给房票!

重磅!南京主城六区房票安置新政,拆迁直接给房票!,棚改,拆迁,南京,安置房,商品房,房票安置新政

谦寻杭州拿地,薇娅却上热搜,这本不该成为新闻

谦寻杭州拿地,薇娅却上热搜,这本不该成为新闻,薇娅,杭州,马云,拍地,新闻,谦寻,网红,住宅用地

环球热推荐:德国健身房持刀袭击事件致4人重伤

德国西部城市杜伊斯堡一家健身房18日发生持刀袭击事件,导致4人受重伤,嫌疑人在逃。杜伊斯堡市警方说,警方18日17时40分左右接到报警,事发“

新《小飞侠》电视预告:黑人精灵泼洒奇怪粉末

迪士尼的新“小飞侠”电影《彼得·潘与温蒂》发布电视预告,探索魔法,开启冒险,4月28日上线Disney+。

全球最资讯丨在一线城市活着有多贵?统计了1w人的月开销,我想回老家...

在一线城市活着有多贵?统计了1w人的月开销,我想回老家 ,存款,房租,广州,月支出,月开销,一线城市,三线城市

世界今日讯!谦寻购地是因企业发展,非薇娅个人投资

谦寻购地是因企业发展,非薇娅个人投资,购地,滨江,谦寻,薇娅,网红,房地产,工业用地,个人投资

今日热议:阳光房地产基金(00435):第三季物业组合的租用率为92.1%

阳光房地产基金(00435):第三季物业组合的租用率为92 1%,物业,租金,租赁,写字楼,阳光房地产基金

网贷逾期十年暂时还不起有什么影响

1、产生罚息这是金钱上的损失。如果信用贷款出现逾期,贷款机构会先电话催收贷款,提醒借款人还款,同时利率还会上浮,作为每天的罚息。虽然每

广元市苍溪县市场监管局全面开通经营主体信用修复“绿色通道”

为进一步优化营商环境,精准落实省、市开展信用提升行动助力经营主体纾困解难的若干措施,苍溪县市场监管局全面下放经营主体信用修复权至各基

全球快播:绩效工资如何计算_绩效工资怎么计算

1、7个人的绩效总系数是6 5,每个系数点的绩效数额是5000 6 5=769 2所以系数是1 0的应该拿到不到770

【全球独家】狂舞弹球官网在哪下载 最新官方下载安装地址

狂舞弹球怎么下载?想要比别人更加抢先抢快的玩到这款游戏,那么你获取游戏开测消息是关键,能够获取到第一手信息,你才能在最快的时间内容体

新资讯:广元市市场监管局开展药械化基层监管能力提升培训

为进一步加强药械化安全监管队伍建设,不断提升基层监管人员综合素养,4月10日至14日,广元市市场监管局组织全市系统79名药械化监管人员,赴四

观热点:【机会挖掘】八部门联合印发中医药文化弘扬工程实施方案 相关产业链或受关注

央视新闻消息,日前,国家中医药管理局、中央宣传部、教育部、商务部、文化和旅游部、国家卫生健康委、国家广电总局、国家文物局联合印发《...

视点!房企的商业生意| 龙湖商业:2022年商场收租94.3亿元,今年要“逐步把出租率抓上来”

房企的商业生意|龙湖商业:2022年商场收租94 3亿元,今年要“逐步把出租率抓上来”,天街,出租率,写字楼,龙湖商业,商业地产

大探索时代,青年不应躺平

筚路蓝缕、栉风沐雨、奋楫笃行,改革开放用四十年走完了西方世界三百年的历史进程,我国经济、政治、文化、社会、生态各方面极大发展、昌盛

世界时讯:市区四大安置房工程,全面开建!

市区四大安置房工程,全面开建!,区块,安置房,鹿城区,启动区,新城建设

精彩看点:桃田贤斗瞄准巴黎奥运会

日本羽毛球名将桃田贤斗日前表示,尽管面临年轻选手强有力的挑战,但他决心获得参加明年巴黎奥运会的资格。这位曾经的世界男单头

【报资讯】眉山市东坡区通惠街道儿童之家开展“收纳整理让生活更美好”主题活动

4月16日,眉山市东坡区通惠街道办事处蓬莱社区儿童之家开展了“收纳整理,让生活更美好”主题活动。此次活动的主要目的是教育引导小孩子如...

环球观察:美媒:美国枪支暴力达到创纪录水平 对更多人造成心理负面影响

海外网4月19日电据美国有线电视新闻网(CNN)4月17日报道,随着美国枪支暴力达到创纪录的水平,越来越多的社区受到大规模枪击事件的影响,美国

世界关注:国联证券给予宁德时代买入评级,重磅发布凝聚态电池,践行零碳发展战略

国联证券04月19日发布研报称,给予宁德时代(300750 SZ,最新价:410 37元)买入评级。评级理由主要包括:1)发布凝聚态电池,兼顾高比能与高

资讯:合金弹头觉醒零氪能玩吗?合金弹头觉醒零氪玩法攻略

合金弹头觉醒零氪能玩吗?不少玩家目前玩这款游戏还不打算氪金,需要先尝试一下再决定要不要花钱,为此下面带来了合金弹头觉醒零氪玩法攻略,

头条:公积金热问|全款购买二手房申请公积金贷款 请备好这些材料

公积金热问|全款购买二手房申请公积金贷款请备好这些材料,结清,二手房,公积金贷款,住房公积金

【天天快播报】广元剑阁:开展林业有害生物飞防作业 保护森林资源安全

为有效控制林业有害生物的蔓延及危害,18日,剑阁县开展2023年林业有害生物飞防作业,确保全县森林资源安全。(开展飞防作业)本次飞防作业共

全球热门:万科37.8265亿元底价竞得松江广富林商住地块 成交楼板价15170元/平方米

万科37 8265亿元底价竞得松江广富林商住地块成交楼板价15170元 平方米,万科,楼板价,商住地块,恒大集团,住宅用地,中国交通运输公司

不止封杀老头乐!北京将试点在外卖快递车上加装芯片:实时检测轨迹

不止封杀老头乐!北京将试点在外卖快递车上加装芯片:实时检测轨迹

旁边石阳+八中!楼面价4353.7元/㎡,溢价55%!吉安市老城区40亩地块成交!

旁边石阳+八中!楼面价4353 7元 ㎡,溢价55%!吉安市老城区40亩地块成交!,配建,楼面价,老城区,吉安市,住宅用地

【全球新要闻】十六岁的我作文怎么写?十六岁的我作文范文?

十六岁的我作文(通用20篇)在日复一日的学习、工作或生活中,大家都经常看到作文的身影吧,通过作文可以把我们那些零零散散的

世界快资讯丨海南岛旅游有哪些好玩的地方?海南岛旅游注意事项?

海南岛旅游注意事项美丽的海南岛,阳光明媚,碧海蓝天,椰风海韵醉游人。当您准备启程时,请带上我们的温馨提示。1、长夏无冬

焦点报道:最新家装设计师怎么谈单?最新家装设计师谈单注意事项?

2017最新家装设计师谈单注意事项对于家装设计师来说,谈单技巧是一个非常重要的方面,是和设计功底并驾的双翼,那么家装设计

电气专业实习日记怎么写?电气专业实习日记范文?

【精华】电气专业实习日记3篇一天终于结束了,一定有不少感想,是时候静下心来好好写写日记了。好的日记都具备一些什么特点呢?

快乐的中秋节作文怎么写?快乐的中秋节作文范文?

快乐的中秋节作文6篇“喜迎中秋庆团圆,欢乐笑语万里传”,每年农历八月十五是一年一度的中秋节,是我国的传统节日之一,每逢中

当前热门:没想到我如此浮躁学生作文怎么写?没想到我如此浮躁作文范文?

没想到我如此浮躁学生作文3篇浮躁,是一种不明智,浮躁,是一种蒙昧,浮躁,误人误己。学会在浮躁中思考,这样你才知道在喧嚣中

帮父母做家务的心得体会怎么写?帮父母做家务的心得体会范文?

帮父母做家务的心得体会15篇当我们积累了新的体会时,就很有必要写一篇心得体会,这样能够培养人思考的习惯。那么心得体会该怎

达和源明星美食系列产品闪耀2023成都糖酒会

成都久违的春糖在春天拥抱变化,在成都感受美食力量2023年4月14日成都春季糖酒会圆满落幕全国糖酒商品交易会拥有66年历史被业界称为规模最

天天新消息丨初三物理内能知识点有哪些?初三物理内能知识点大全?

初三物理内能知识点在平平淡淡的学习中,说起知识点,应该没有人不熟悉吧?知识点就是学习的重点。还在苦恼没有知识点总结吗?以

全球新资讯:建筑施工实习日记怎么写?建筑施工实习日记范文?

建筑施工实习日记4篇一天的时间眼看就要结束了,想必大家都学习了不少新知识,让我们一起认真地写一篇日记吧。相信许多人会觉得

年会总结环节主持词怎么写?年会总结环节主持词范本?

年会总结环节主持词(通用10篇)主持词分为会议主持词、晚会主持词、活动主持词、婚庆主持词等。在如今这个中国,主持词与我们

实时焦点:鹡鸰女神第二季 下载 鹡鸰女神第三季无修版

今天来聊聊关于鹡鸰女神第二季,下载,鹡鸰女神第三季无修版的文章,现在就为大家来简单介绍下鹡鸰女神第二季,下载,鹡鸰女神第

【当前热闻】港元拆息涨跌不一 1个月拆息跌至2.48924厘

港元拆息涨跌不一,隔夜拆息升至2 34348厘;1星期拆息升至2 44909厘,2星期拆息跌至2 48394厘。与楼按相关的1个月拆息跌至2 48924厘;3个

世界信息:23杭州国资SCP003票面利率为2.4600%

23杭州国资SCP003票面利率为2 4600%

【天天播资讯】叙州区房票细则来了!一大片拆迁户即将来袭!

叙州区房票细则来了!一大片拆迁户即将来袭!,征地,购房,拆迁户,叙州区,房票细则

全球快讯:贸易、投资、基建:中国“三驾马车”带动拉美就业

贸易、投资、基建:中国“三驾马车”带动拉美就业,中国,巴西,三驾马车,拉美就业

5500亿中小银行发展专项债披露超60%:辽宁省农商行额度创单笔最大规模30分钟前

5500亿中小银行发展专项债披露超60%:辽宁省农商行额度创单笔最大规模30分钟前:据媒体,记者统计,今年以来,包括大连、内蒙古、黑龙江、宁夏

【天天新视野】高铁落地数币消费场景!农行北分:将发放18万元体验金

高铁落地数币消费场景!农行北分:将发放18万元体验金,农行,高铁,体验金,数币消费

关键数据带你看懂中国经济发展脉动

03:57央视网消息:国家统计局昨天(4月18日)公布的主要经济指标显示,一季度,生产需求企稳回升,就业物价总体平稳,经

世界信息:杭州5月1日起实施房产新政?假的!

杭州5月1日起实施房产新政?假的!,限行,杭州市,大运河,房产新政,杭州楼市,中国文物,中国世界遗产

长峰医院火灾事故系施工过程中火花引燃挥发物所致

00:27北京市消防救援总队副总队长赵洋19日在北京长峰医院火灾事故情况通报会上介绍,经初步调查,事故系医院住院部内部改

精彩推荐