我正在构建一个应用程序,使用 Spring Cloud 配置服务器作为保存属性文件的集中位置。我有多个客户端应用程序从配置服务器获取配置数据。
但是我使用 Spring 云总线和 Kafka 作为消息代理,而不是手动刷新每个客户端应用程序以在提交后提取属性文件中的最新更改,以便所有更改都广播到客户端应用程序。以下是 pom 文件和属性文件。
配置服务器: pom
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
应用程序属性:
server.port = 8980
Bootstrap 属性:
spring.cloud.bus.enabled=true
spring.cloud.config.server.git.uri= "some path"
配置客户端: 功课
<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>
应用程序属性:
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 属性:
spring.application.name=department-service
spring.cloud.config.uri=http://localhost:8980
management.security.enabled=false
但是在对本地 git 存储库文件进行更改并提交之后 当我尝试使用“http://localhost:8982/actuator/bus-refresh”端点提取最新更改时,出现如下错误:
{
"timestamp": "2019-01-29T08:49:21.569+0000",
"status": 404,
"error": "Not Found",
"message": "No message available",
"path": "/actuator/bus-refresh"
最佳答案
您需要在配置服务器 application.properties 中包含“management.endpoints.web.exposure.include=bus-refresh”。之后,向此 URL localhost:8012/actuator 发送一个 GET 请求,以查看可用的 LINKS 以刷新配置更改。您将在下面看到 JSON
{
"_links": {
"self": {
"href": "http://localhost:8012/actuator",
"templated": false
},
"busrefresh-destinations": {
"href": "http://localhost:8012/actuator/busrefresh/{*destinations}",
"templated": true
},
"busrefresh": {
"href": "http://localhost:8012/actuator/busrefresh",
"templated": false
}
}
然后你可以发送一个POST到这个URL localhost:8012/actuator/busrefresh
关于java - 使用 Spring Cloud Bus 刷新配置更改,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54417296/