SpringCloud服务总线_spring cloud 服务总线

Spring Cloud 服务总线用于实现微服务架构中所有微服务之间的消息通知和广播通知。

服务总线可以使用RabbitMQ或者Kafka等消息中间件来实现。

以下是使用Spring Cloud Bus与RabbitMQ实现的一个简单的广播配置更新的例子：

1. 在pom.xml中添加依赖：

<dependencies>
    <!-- Spring Cloud Bus 依赖 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
    <!-- RabbitMQ 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

2. 在application.yml中配置RabbitMQ：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 在微服务中发送广播更新配置的事件：

@RestController
public class TestController {
 
    @Autowired
    private ApplicationEventPublisher publisher;
 
    @GetMapping("/sendMessage")
    public String sendMessage() {
        publisher.publishEvent(new RefreshRemoteApplicationEvent(this, "/actuator/bus-refresh", "originService"));
        return "Message sent";
    }
}

4. 其他微服务需要订阅这个事件，并在事件发生时更新自己的配置：

@Component
public class RefreshBusReceiver {
 
    @Autowired
    private Environment environment;
 
    @RefreshScope
    @Autowired
    private ApplicationContext context;
 
    @EventListener(value = RefreshRemoteApplicationEvent.class)
    public void refresh(RefreshRemoteApplicationEvent event) {
        if (event.getDestination().equals("/actuator/bus-refresh")) {
            ConfigurableApplicationContext configurableApplicationContext = (ConfigurableApplicationContext) context;
            configurableApplicationContext.getBean(RefreshScope.class).refreshAll();
        }
    }
}

在这个例子中，当/sendMessage接口被调用时，会发送一个广播事件，通知所有订阅了这个事件的微服务进行配置的更新。

注意：在生产环境中，你可能需要对Spring Cloud Bus进行更多的安全配置，比如使用SSL/TLS加密通信，或者使用更复杂的权限控制来确保事件的广播安全。