每日快报!使用 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 - 每日快报!使用 Spring Cloud Bus 在微服务之间传递消息示例
- 每日消息!世博会生肖金条价格今天多少一克(2023年04月19日)
- 当前快播:监听新标杆,精准复现创作之音,索尼发布首款专业开放式监听耳机MDR-MV1
- 世界百事通!“蔚小理”打擂台:理想拿下“宁王”,小鹏“扶摇”,蔚来不提手机
- 天天时讯:4月19日生意社聚丙烯酰胺基准价为14771.43元/吨
- 天天快看点丨农民日报:别让“电商果”成为劣质水果代名词
- 热点聚焦:招股遇冷!港股“白酒第一股”什么情况?
- 快看:现代名人诚信故事50字左右_现代名人诚信故事
- 环球热讯:卡马文加:上半场一度很困难,但清楚哪怕只剩几分钟也能逆转局势
- 【全球新要闻】启东市气象台发布大雾黄色预警【Ⅲ级/较重】
- 当前快讯:淄博烧烤有多火?电力数据告诉你
- 热点聚焦:“五一”返程火车票今起开售 这些线路车票或紧张
- 天天热推荐:希荻微:4月18日融券卖出金额46.96万元,占当日流出金额的1.65%
- 每日时讯!医药代表工作总结与不足_医药代表工作总结
- 环球快资讯:波兰重启乌克兰农产品过境 但将继续禁止其进口
- 全球热点!Python基础语法-函数-生成器函数
- 天天最资讯丨五年级上册数学课件讲课_五年级上册数学课件
- 【环球新视野】推动渝企数字化转型 华为云重庆凌云计划发布
- 世界看点:拯救气候,超级藻类工厂迈出坚实步伐
- 世界微资讯!广西自然资源遥感院:积极探索“党建+文明创建”的模式
- 环球速看:上海pvg是哪个机场_pvg是哪个机场
- 天天热文:南宁沃柑、茉莉花、火龙果等产业规模稳居全国第一
- 【天天速看料】苏美尔人是什么人种_苏美尔人
- 每日视点!宋念祖
- 热门看点:香味扑鼻的几道的家常菜,美味简单,下酒下饭,待客必备的好菜
- 世界快消息!如何加强党委信息工作_从法规制度层面加强新时代党委信息工作
- 世界观点:痴想的痴什么意思_痴想的意思
- 全球观速讯丨吉林:普惠金融助力实体经济
- 环球短讯!重症肺炎的护理措施_重症肺炎死亡率为什么那么高
- 世界看点:德银:维持Walt Disney(DIS.US)买入评级
