Bus消息总线

Bus简介

Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来。它可以用于广播配置文件的更改或者服务之间的通讯，也可以用于监控。
本文要讲述的是用Spring Cloud Bus实现通知微服务架构的配置文件的更改。

示例演示

功能说明，修改配置文件而不重启服务，进行刷新加载。

前期准备工作

和config相同，在config-repo下创建一个bus-client-dev.properties

foo = foo version 22

启动注册中心

服务端改造(增加eureka注册)

添加maven依赖（由于本次使用eureka）

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

bootstrap.properties配置

spring.application.name=bus-server
server.port=8888


spring.cloud.config.server.git.search-paths=spring-cloud/config-repo
spring.cloud.config.server.git.username=username
spring.cloud.config.server.git.password=password

eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

启动类示例

@SpringBootApplication
@EnableConfigServer
@EnableEurekaClient
public class SpringCloudBusApplication {

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

}

客户端改造(重点)

添加消息总线和eureka依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

此处使用amqp来做消息传播介质，也可使用kafaka。

添加bootstrap.properties配置属性

spring.application.name=bus-client

server.port=8111
spring.cloud.config.label=master

spring.cloud.config.uri=http://localhost:8888

spring.cloud.config.profile=dev

spring.rabbitmq.host=47.96.127.51
spring.rabbitmq.port=5672
spring.rabbitmq.username=springcloud
spring.rabbitmq.password=123456

spring.cloud.bus.enabled=true
## 开启消息跟踪
spring.cloud.bus.trace.enabled=true
## 启用bus-refresh的监控端点
management.endpoints.web.exposure.include=bus-refresh

eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

启动类示例

@SpringBootApplication
@RestController
@EnableEurekaClient
@RefreshScope
public class SpringCloudBusClientApplication {

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

    @Value(value = "${foo}")
    public String foo;

    @RequestMapping("/")
    public String home() {
        return "Hello World!"+foo;
    }
}

环境搭建完成

启动
启动
修改spring-cloud-bus-client配置文件，修改端口号为8112，再次启动项目

bus-eureka.png

Hello World!foo version 33

修改config-repo下的bus-client-dev.properties内容。

bus-postman.png

Hello World!foo version 44

项目架构

bus-archtive.png

总结：可见服务通过消息总线实现不重启更新配置文件，并且通知其他相关服务更新配置。