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

当前位置：首页>关注 >

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

2023-04-21 16:14:58 来源：腾讯云

(资料图)

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

关键词：

推荐内容

产业

查看全部

油气

河北深州警方打掉一暴力催债团伙 36名嫌犯被刑拘

寒潮降温破冰点如何保障温暖过冬？探访北京城管及供热

莆田致2死3伤案嫌犯拒捕并畏罪自杀经抢救无效死亡

福建福州一在建摩天轮发生垮塌事故原因正在调查中

为什么对张恒处3227万元罚款？其违法事实有哪些？

山西民政部门支出超2亿元捐款保障受灾困难民众基本生活

张恒被税务部门依法处以3227万元罚款

湖北赛武当国家级自然保护区监测到珍稀动物

首届“优秀长江协助巡护员”评选颁奖

今年火灾事故已超6000起！电动自行车为何频频爆炸？

查看全部

经济

国家一级保护动物梅花鹿误入羊群内蒙古警方及时救助

　　中新网通辽10月18日电 (记者张林虎)18日，记者从内蒙古自治区通辽市奈曼旗公安局获悉，国家一级保护动物--梅花鹿误入当地村民羊群，

浙江杭州西湖首次推“环湖游线” 重现灵隐天竺上香水路

　　中新网杭州10月18日电 (王题题胡燕婕)云天收夏色，浅秋正渐浓。10月18日，浙江杭州市西湖游船有限公司推出的惠民多站点“西湖环湖游

税务机关处罚一名艺人经纪人

　　中国税务机关处罚一名艺人经纪人　　中新社北京10月18日电 (记者赵建华)上海市税务局第一稽查局前期在艺人郑爽偷逃税案件检查过程中

【母亲河畔的中国】黄河润泽甘肃：沿岸城市兴文旅

　　中新网兰州10月18日电 (闫姣艾庆龙吉翔)“红山白土头，黄河向西流。”不少人疑问，天下黄河向东流，为何甘肃永靖县这段黄河却向西

《清华城市健康设施指数》：城市健康设施状况与其经济发

　　中新网北京10月18日电《清华城市健康设施指数》18日在北京发布。报告成果显示，城市健康设施指数领先城市以中心城市和东部沿海城市

查看全部

当前位置： 首页>关注 >