当前位置：首页 > news >正文

芋道源码——Spring Cloud Bus RocketMQ 入门

news 2025/7/19 4:33:09

芋道源码——Spring Cloud Bus RocketMQ 入门

引言

在微服务架构中，服务之间的通信是一个关键问题。Spring Cloud Bus 提供了一种简单而高效的方式，通过消息队列实现服务之间的事件传播。本文将深入浅出地讲解 Spring Cloud Bus RocketMQ 的入门知识，帮助初学者快速上手。

一、Spring Cloud Bus 是什么？

1.1 定义

Spring Cloud Bus 是一个事件、消息总线，用于在集群中传播状态变化。它可以与 Spring Cloud Config 联合实现热部署，使得配置变化能够实时通知到所有服务实例。

1.2 特点

事件驱动：基于事件的编程模型，使得服务之间的通信更加灵活。
消息队列集成：支持多种消息队列，如 RabbitMQ、Kafka、RocketMQ 等。
实时性：能够实时传播状态变化，确保服务之间的同步。

1.3 作用

配置中心集成：与 Spring Cloud Config 配合，实现配置的自动刷新。
事件传播：在微服务架构中，实现跨服务的事件通知。

二、RocketMQ 是什么？

2.1 定义

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。

2.2 特点

高吞吐量：能够处理大量消息，适用于高并发场景。
严格的消息顺序：保证消息的顺序性，确保数据的一致性。
丰富的消息模式：支持多种消息拉取模式，满足不同业务需求。

2.3 应用场景

异步通信：解耦服务之间的直接调用。
企业解决方案：广泛应用于金融支付、电子商务、物流等领域。

三、Spring Cloud Bus RocketMQ 快速入门

3.1 环境准备

在开始之前，确保你已经搭建了 RocketMQ 服务。可以参考《RocketMQ 极简入门》进行学习和搭建。

3.2 项目结构

我们将创建两个项目：

事件发布器项目：负责发送事件。
事件监听器项目：负责监听和处理事件。

3.3 事件发布器项目

3.3.1 引入依赖

在 pom.xml 文件中，引入 Spring Cloud Bus 和 RocketMQ 的相关依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-rocketmq</artifactId>
    </dependency>
</dependencies>

3.3.2 配置文件

在 application.yml 文件中，配置 Spring Cloud Bus 和 RocketMQ：

server:
  port: 8081

spring:
  application:
    name: publisher-demo
  cloud:
    bus:
      enabled: true
      destination: springCloudBus
rocketmq:
  name-server: 127.0.0.1:9876

3.3.3 创建事件类

创建 UserRegisterEvent 类，继承 RemoteApplicationEvent：

public class UserRegisterEvent extends RemoteApplicationEvent {
    private String username;

    public UserRegisterEvent() {
    }

    public UserRegisterEvent(Object source, String originService, String destinationService, String username) {
        super(source, originService);
        this.username = username;
    }

    public String getUsername() {
        return username;
    }
}

3.3.4 创建控制器

创建 DemoController 类，提供注册接口并发送事件：

@RestController
@RequestMapping("/demo")
public class DemoController {
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    @Autowired
    private ServiceMatcher busServiceMatcher;

    @GetMapping("/register")
    public String register(String username) {
        logger.info("[register][执行用户({}) 的注册逻辑]", username);
        applicationEventPublisher.publishEvent(new UserRegisterEvent(this, busServiceMatcher.getServiceId(), null, username));
        return "success";
    }
}

3.3.5 启动类

创建 PublisherDemoApplication 类，作为项目的启动类：

@SpringBootApplication
public class PublisherDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(PublisherDemoApplication.class, args);
    }
}

3.4 事件监听器项目

3.4.1 引入依赖

与事件发布器项目一致，引入相同的依赖。

3.4.2 配置文件

与事件发布器项目一致，配置 Spring Cloud Bus 和 RocketMQ。

3.4.3 创建事件监听器

创建 UserRegisterListener 类，监听 UserRegisterEvent 事件：

@Component
public class UserRegisterListener implements ApplicationListener<UserRegisterEvent> {
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Override
    public void onApplicationEvent(UserRegisterEvent event) {
        logger.info("[onApplicationEvent][监听到用户({}) 注册]", event.getUsername());
    }
}

3.4.4 启动类

创建 ListenerDemoApplication 类，作为项目的启动类，并添加 @RemoteApplicationEventScan 注解：

@SpringBootApplication
@RemoteApplicationEventScan
public class ListenerDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(ListenerDemoApplication.class, args);
    }
}

3.5 简单测试

启动事件发布器项目。
启动两个事件监听器项目。
调用 http://127.0.0.1:8081/demo/register?username=test 接口。

控制台将打印日志，显示事件被成功发布和监听。

四、监控端点

Spring Cloud Bus 提供了两个监控端点：

bus-env 端点：用于发布环境变化事件。
bus-refresh 端点：用于刷新 Spring Context。

4.1 配置 Actuator

在 pom.xml 文件中，引入 Spring Boot Actuator：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

在 application.yml 文件中，配置 Actuator：

management:
  endpoints:
    web:
      exposure:
        include: '*'

4.2 测试监控端点

使用 Postman 发送请求到 bus-env 和 bus-refresh 端点，观察控制台日志。

五、面试回答思路

5.1 什么是 Spring Cloud Bus？

Spring Cloud Bus 是一个事件、消息总线，用于在集群中传播状态变化。它基于 Spring 事件机制，结合消息队列实现跨服务的事件通知。

5.2 Spring Cloud Bus 和 Spring Cloud Stream 有什么区别？

Spring Cloud Bus：主要用于事件传播，如配置变化通知。
Spring Cloud Stream：更侧重于数据流处理，提供更丰富的消息处理功能。

5.3 如何实现配置的自动刷新？

通过 Spring Cloud Bus 和 Spring Cloud Config 的结合，当配置发生变化时，发送一个刷新事件，通知所有服务实例重新加载配置。

六、总结

本文详细讲解了 Spring Cloud Bus RocketMQ 的入门知识，包括环境搭建、代码示例、监控端点等内容。通过本文的学习，初学者可以快速上手 Spring Cloud Bus RocketMQ，并在实际项目中应用。

芋道源码——Spring Cloud Bus RocketMQ 入门