最新要闻
- 使用 Spring Cloud Bus 在微服务之间传递消息示例
- 北方将现大范围雨雪局地大暴雪:局地冷到破纪录 秋裤快穿回来 全球观点
- 0秒吸水:亚光加厚纯棉大浴巾23.9元(单条450g)
- 【环球时快讯】德宏股份:2022年净利润1107.61万元 同比下降71.54%
- 环球观察:周鸿祎发全员信 确认这类360员工不会被GPT取代!
- 世界快讯:精研“模考”功能
- 观察:罗翔在新东方当过三年老师 俞敏洪:讲课幽默风格是被新东方训练的
- 国内用户无缘!iOS 17将支持三方应用商店或仅限欧洲:苹果准备收费
- 商品日报(4月21日):负反馈担忧加重黑色系全线下跌 乙二醇逆势涨超2%
- 快消息!博敏电子:4月21日融券卖出10.9万股,融资融券余额4.75亿元
- 安徽宁国经开区新型储能项目战略合作签约,预期投资总规模达30亿元
- 【全球播资讯】AI教你玩游戏
- 微资讯!厂商疯狂备货!RTX 4060 Ti下月杀到 老黄会良心到卖2800元?
- 摔角动态外媒爆料蛋妞VS米兹的头号挑战者赛两分钟草草了事的原因
- 小米辣椒的腌制方法放一年都不坏?_新消息
- 看到洋人吃冰激凌,这样的场景应该珍惜
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
使用 Spring Cloud Bus 在微服务之间传递消息示例
(资料图片仅供参考)
下面是一个完整的示例,演示如何使用 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
关键词:
-
【全球速看料】学系统集成项目管理工程师(中项)系列03_职业道德规范
1 & 160;职业道德1 1 & 160;涵盖了从业人员与服务对象、职业与职工、职业与职业之间的关系1 2 & 160;是所有
来源: 使用 Spring Cloud Bus 在微服务之间传递消息示例
北方将现大范围雨雪局地大暴雪:局地冷到破纪录 秋裤快穿回来 全球观点
0秒吸水:亚光加厚纯棉大浴巾23.9元(单条450g)
【全球速看料】学系统集成项目管理工程师(中项)系列03_职业道德规范
【环球时快讯】德宏股份:2022年净利润1107.61万元 同比下降71.54%
【环球财经】英国4月份制造业和服务业复苏分化进一步明显
环球观察:周鸿祎发全员信 确认这类360员工不会被GPT取代!
世界快讯:精研“模考”功能
观察:罗翔在新东方当过三年老师 俞敏洪:讲课幽默风格是被新东方训练的
国内用户无缘!iOS 17将支持三方应用商店或仅限欧洲:苹果准备收费
商品日报(4月21日):负反馈担忧加重黑色系全线下跌 乙二醇逆势涨超2%
快消息!博敏电子:4月21日融券卖出10.9万股,融资融券余额4.75亿元
安徽宁国经开区新型储能项目战略合作签约,预期投资总规模达30亿元
【全球播资讯】AI教你玩游戏
微资讯!厂商疯狂备货!RTX 4060 Ti下月杀到 老黄会良心到卖2800元?
摔角动态外媒爆料蛋妞VS米兹的头号挑战者赛两分钟草草了事的原因
全球热讯:FirewallD入门手册
2023.4.21【图论】点分治|世界新视野
全球视讯!学系统集成项目管理工程师(中项)系列07_信息(文档)管理
小米辣椒的腌制方法放一年都不坏?_新消息
看到洋人吃冰激凌,这样的场景应该珍惜
今日播报!宝马MINI称两名女生不是公司员工 不会再出现:回应求原谅 你还会买吗?
世界焦点!内地票房破2亿!《灌篮高手》登顶淘宝热搜:周边被抢空
三方签约共建华侨大学国家语言服务出口基地 今日报
买到烂尾楼“钱房两空”?最高法明确优先保护购房者权益|每日资讯
世界看点:面对特斯拉掀起的价格战,有“勇士”选择应战,有“逆行者”坚持高端
电脑c盘怎么除了系统其他文删除件_怎样清理c盘除了系统之外的东西
天天快看:张小泉客服回应菜刀拍蒜断两截:比较硬的刀就容易断裂
解决信号盲区!曝小米Civi 3支持5G异网漫游:光明正大“蹭”网 当前关注
环球最资讯丨10倍提升 安卓新旗舰放弃祖传USB2.0:体验变化太明显了
网上的那些喷子 为啥一玩这类游戏就闭嘴了?-全球热点评
热门:i7处理器32GB+1TB仅2999 这款性价比神机只有巴掌大小
潍坊开展“10+”行动 助力工业经济高质量发展 天天新消息
新能源产品集结,长安加速向全球企业转型 当前快播
英国宣布制裁5名俄公民,梅德韦杰夫回应:英国是俄罗斯永远的敌人
华仁物业2022年净利636.57万元,同比减少34.7%|年报
千的组词_关于千的组词
六张iPad绘制的交通卡卡面 是苹果联合创作者为世界地球日送上的绿色礼物_微动态
潭村站_关于潭村站介绍-世界热议
山西一妈妈为催婚给25岁儿子床头摆稻草人 不料小伙儿人间清醒,反告诫勿迷信 环球热门
青春无价 《灌篮高手》首日即破12项纪录!
世界新资讯:马斯克称特斯拉今年将推出全自动驾驶技术
蚌埠:马天奇带队赴长三角地区考察招商 当前速读
黄辣丁和乌鱼能一起养吗 黄辣丁和乌鱼能不能养在一起呢 环球关注
郑州公积金可以取现吗?提取的条件有哪些?-全球简讯
全球今头条!中国恒大:预计无法于4月30日前披露2022年度审计报告及2022年公司债券年度报告
每日简讯:可以骑的行李箱、机械臂咖啡机……广交会创新产品引关注 参展企业订单增加
天天观点:萤石“小步快走”,跨进智能家居生态圈
每日观察!宝马半个董事会败给了一个冰淇淋
打字高手电脑版下载安装_打字高手电脑版 速讯
小米13 Ultra首销火爆!很多小米11/12S Ultra老用户以旧换新
预售价109.8万元!比亚迪仰望U8的价格还是太保守了
电商开始制裁“偷盘哥”:敢仅退款就法院见
人民网评:“五个一百”,传递正能量、传播真善美 全球百事通
有稜有角打一字_有稜有角是什么生肖
iOS 屏幕旋转的设置方法
又是浪费时间的一天-ssh的安装之路
全球时讯:Java中处理高精度数据计算
一季度我国承接RCEP成员国离岸服务外包执行额同比增长34.3%
长盈通2022年度分配预案:拟10送转3股派5元|焦点快看
当前速递!智能建筑工程技术丛书信息网络工程_对于智能建筑工程技术丛书信息网络工程简单介绍
当前热文:全球最赚钱手游!《王者荣耀》3月吸金14.7亿元
国产闪存、内存受阻 韩国三星、海力士赚到了:份额还能涨 环球速看
库里:我们全队都知道今晚再输的后果 没人想去感受那种感觉 热讯
保时捷:我们和中国车没什么可争的
不能忍 用户质疑微软:自己花钱买的Win系统 凭啥加广告
全球新资讯:曾高喊刹车失灵!车顶维权女车主现身上海车展:特斯拉若参展必不放过
搭载谷歌TV的索尼BRAVIAX80L电视在市场推出 天天新动态
世界新消息丨AT_abc297_e 题解
anaconda / conda 环境复制和迁移
window下cmd显示乱码
关于Nginx作为http-web服务器时对404错误页面的配置-以及安全加固-隐藏404的状态码
【财经分析】30年期国债期货首日交易平稳 助力打造长期稳定投融资生态
4月21日地热能板块跌幅达2%-焦点热讯
7999元 宏碁发布新款44.5英寸带鱼屏显示器:165Hz 2K屏
DC宇宙重启!电影《闪电侠》中国内地定档:6月16日上映
重点聚焦!上市5年 8TB机械盘价格终于跌破700元:牙膏挤爆了
新消息丨对话理想汽车总裁:造纯电 理想到底有多“抠”?
销量跌出前15后不指望中国市场!机构称韩国现代将在2026年成全球第一大车企
世界通讯!周鸿祎内部信:360员工不会被GPT淘汰,鼓励使用GPT拿绩效
003CCE Turbo配置容器网卡动态预热|焦点速看
Nvidia GPU Virtual Memory Management
成都燃气:2022年度净利润约4.92亿元 同比增加0.57%
焦点精选!债市日报:4月21日
环球速讯:一批“色狼”被官方公布,罚了!
6299元起!魅族20 INFINITY无界版入网:双向卫星通信比苹果更强
朱一龙、倪妮亮相北影节开幕红毯:新电影《消失的她》即将上映
青岛一鸵鸟在车流中狂奔引骚乱:当天就被抓回
冰淇淋事件闹大 有车主扣掉车标“宝马”二字 称感觉羞愧
F-150纯电皮卡充电时起火 三辆新车惨烈烧毁!福特:韩国电池的锅
初三英语听力训练技巧_初三英语听力训练 全球滚动
联动长三角,走进马鞍山!浦东历史博物馆首次实现展览走出去
每一磅碎牛肉使用多少预制炸玉米饼调味料?-天天短讯
劝人写码,千刀万剐——“前端已死”难道要成真了?|世界快报
【新华解读】外资3月持有人民币债券规模回升 外资有望享受更多政策红利 播资讯
山西一妈妈为催婚给25岁儿子床头摆稻草人:神回应看醉
天天简讯:沃尔沃新车轮胎5个螺丝少4个 女车主崩溃要退车
女子吐槽软卧车厢分配3男1女 12306回应:可找工作人员调换
目前适配最完美的小折叠!vivo X Flip评测:超好看超能打|世界观焦点
环球快资讯丨三星S23 Ultra用户入手小米13 Ultra:拿它当相机来用