我正在构建一个使用Spring Cloud配置服务器作为保存属性文件的集中位置的应用程序。我有多个客户端应用程序从配置服务器获取配置数据。
但是,在提交之后,我不是手动刷新每个客户端应用程序以在属性文件中提取最新更改,而是使用Spring云总线和Kafka作为消息代理,以便将所有更改广播到客户端应用程序。下面是pom文件和属性文件。
ConfigServer:pom
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
application.properties :
server.port = 8980
bootstrap.properties :
spring.cloud.bus.enabled=true
spring.cloud.config.server.git.uri= "some path"
配置客户端:pom
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>
application.properties :
server.port=8982
spring.cloud.bus.refresh.enabled: true
spring.cloud.bus.env.enabled: true
endpoints.spring.cloud.bus.refresh.enabled: true
endpoints.spring.cloud.bus.env.enabled: true
spring.cloud.stream.kafka.binder.autoAddPartitions=true
spring.cloud.stream.kafka.binder.zkNodes=localhost:2181
spring.cloud.stream.kafka.binder.brokers=localhost:9892
bootstrap.properties :
spring.application.name=department-service
spring.cloud.config.uri=http://localhost:8980
management.security.enabled=false
但是在对本地git存储库文件进行更改之后以及在我尝试使用“qazxsw poi”端点进行最新更改时提交后,它给出了如下错误:
http://localhost:8982/actuator/bus-refresh
}
您需要在配置服务器application.properties中包含“management.endpoints.web.exposure.include = bus-refresh”并点击此url
{
"timestamp": "2019-01-29T08:49:21.569+0000",
"status": 404,
"error": "Not Found",
"message": "No message available",
"path": "/actuator/bus-refresh"