Bus消息总线

2019-02-27 本文已影响8人昨日已逝去

Bus消息总线

原文在github，有些相对路径连接不能跳转，如想看原文项目地址 spingboot2.1.3加springcloud G版本,如果觉的不错给个star 谢谢！

Bus简介

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

示例演示

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

结合config 我们对spring-cloud-config-server改造成我们sprign-cloud-bus

前期准备工作

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

foo = foo version 22

启动注册中心spring-cloud-eureka

服务端改造(增加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.uri=https://github.com/DespairYoke/java-advance
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;
    }
}