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

2023-04-22 10:28:33 来源：腾讯云

【资料图】

下面是一个完整的示例，演示如何使用 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 在微服务之间传递消息示例 今日热议

为你推荐

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

全球热讯:信达证券：一季度净利润2.16亿元 同比增长30.19%

当前焦点!Consul 简单示例

五华科技产业园开展防火防灾安全隐患检查

打好创新牌、闯出新市场——一季度高技术制造业企业观察|播报

仙鹤股份：4月21日融资净买入62.88万元，连续3日累计净买入884.15万元

魏牌高山引领，中国高端MPV市场格局有望被重塑

全球微头条丨三维激光扫描仪原理和操作（三维激光扫描仪原理）

石家庄必买十大特产礼盒?

获刑14年！安以轩老公涉黑案判决出炉_今日视点

2023版“沪惠保”预计5月中上旬推出，监管部门已开会研究产品方案 天天时讯

关于网传大熊猫“福禄”淋雨，成都大熊猫繁育研究基地回应

环球微速讯：股票内在价值公式

莆田九华山简介_莆田九华山

环球观察：宁马城际铁路（南京段）首片双线简支梁浇筑成功

2023汽车零配件技术企业有哪些税务筹划方向_每日速看

天天最资讯丨勒布伦爆冷击败樊振东，下轮对战马龙，孙颖莎将对战陈梦

焦点热议:全国5G和千兆光网“双千兆”网络应用案例数超5万

暗黑破坏神_暗黑破坏神3下载与安装

环球热资讯！同行衬托？*ST泽达退市！东兴证券，终于道歉了

推荐内容

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

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

全球热讯:信达证券：一季度净利润2.16亿元同比增长30.19%

2023版“沪惠保”预计5月中上旬推出，监管部门已开会研究产品方案天天时讯