作者:付政委
在微服务架构中,为了更方便的向微服务实例广播消息,我们通常会构建一个消息中心,让所有的服务实例都连接上来,而该消息中心所发布的消息都会被微服务实例监听和消费,我们把这种机制叫做消息总线(SpringCloud Bus)
当我们的微服务达到是几个到百个以上,在更新配置时,不太可能一个个刷新或者重启,这样既不能保证效率也容易导致遗漏造成事故。因此我们需要SpringCloud Bus 提供总线服务,在我们push代码到Git的时候,通过Webhooks(http://localhost:port/actuator/bus-refresh/)执行刷新,消息总线会通知各个实例更新配置,以达到自动更新全服务配置。
itstack-demo-springcloud-07
├── itstack-demo-springcloud-config-client
│ └── src
│ └── main
│ ├── java
│ │ └── org.itstack.demo
│ │ ├── web
│ │ │ └── ConfigClientController.java
│ │ └── ConfigClientApplication.java
│ └── resources
│ ├── application.yml
│ └── bootstrap.yml
├── itstack-demo-springcloud-config-server
│ └── src
│ └── main
│ ├── java
│ │ └── org.itstack.demo
│ │ └── ConfigServerApplication.java
│ └── resources
│ └── application.yml
└── itstack-demo-springcloud-eureka-server
└── src
└── main
├── java
│ └── org.itstack.demo
│ └── EurekaServerApplication.java
└── resources
└── application.yml
完整代码欢迎关注公众号:bugstack虫洞栈 回复“SpringCloud专题”进行下载
web/ConfigClientController.java & 添加注解@RefreshScope自动刷新配置
@RestController
@RefreshScope
public class ConfigClientController {
@Value("${info.profile:error}")
private String profile;
@GetMapping("/config")
public Mono<String> config() {
return Mono.justOrEmpty(profile);
}
}
ConfigClientApplication.java & 普通配置即可
@SpringBootApplication
public class ConfigClientApplication {
public static void main(String[] args) {
SpringApplication.run(ConfigClientApplication.class, args);
}
}
application.yml & 需要配置endpoints,这样才可以暴漏刷新服务
spring:
application:
name: itstack-demo-springcloud-config-client
cloud:
bus:
trace:
enabled: true
enabled: true
server:
port: 9001
# 如果不使用消息总线,则开启如下配置 /actuator/refresh 这个 Endpoint 暴露出来
#management:
# endpoints:
# web:
# exposure:
# include: refresh
bootstrap.yml & 配置中心服务配置,http://localhost:7397 添加配置服务
spring:
cloud:
config:
name: config-client # 对应 {application} 部分,例如;config-client-dev = 只取最后一个符号'-'之前的
profile: dev # 对应 {profile} 部分
label: master # 对应 {label} 部分,即 Git 的分支。如果配置中心使用的是本地存储,则该参数无用
discovery:
enabled: true # 开启 config 服务发现支持
service-id: itstack-demo-springcloud-config-server # 配置服务name
#配置文件会被转换成 Web,访问规则如下;
#/{application}/{profile}[/{label}]
#/{application}-{profile}.yml
#/{label}/{application}-{profile}.yml
#/{application}-{profile}.properties
#/{label}/{application}-{profile}.properties
eureka:
client:
service-url:
defaultZone: http://localhost:7397/eureka/
ConfigServerApplication.java & 添加注解@EnableConfigServer设置成配置服务中心
@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {
public static void main(String[] args) {
SpringApplication.run(ConfigServerApplication.class, args);
}
}
application.yml & 配置信息,消息总线刷新
server:
port: 8080
spring:
application:
name: itstack-demo-springcloud-config-server
cloud:
config:
server:
git:
uri: https://github.com/fuzhengwei/itstack-demo-config # 换成自己的配置Git仓库的地址,如果没有可以新建工程地址,也可以克隆我的;https://github.com/fuzhengwei/itstack-demo-config
search-paths: config-repo # Git仓库地址下的底层配置文件名称,如果配置多个用逗号','分割。
# 如果配置中心需要访问权限,则开启配置
# spring.cloud.config.server.git.username:Github账户
# spring.cloud.config.server.git.password:Github密码
eureka:
client:
service-url:
defaultZone: http://localhost:7397/eureka/
management:
endpoints:
web:
exposure:
include: bus-refresh
EurekaServerApplication.java & 添加注解@EnableEurekaServer启动服务发现
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
public static void main(String[] args) {
SpringApplication.run( EurekaServerApplication.class, args );
}
}
application.yml & 配置信息
server:
port: 7397
eureka:
instance:
hostname: localhost
client:
registerWithEureka: false
fetchRegistry: false
serviceUrl:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
spring:
application:
name: itstack-demo-springcloud-eureka-server
{
"name": "config-client",
"profiles": [
"dev"
],
"label": null,
"version": "ea0b1a1017595d542aa01b8b2bda68f9620dd81a",
"state": null,
"propertySources": [
{
"name": "https://github.com/fuzhengwei/itstack-demo-config/config-repo/config-client-dev.yml",
"source": {
"info.profile": "dev bus"
}
}
]
}
dev bus
dev