如何使用Spring云总线刷新不受配置服务器控制的数据的应用实例？

Question

我正在尝试在我的微服务应用程序中使用带有Kafka的Spring云总线，确实我可以使用它，但只有由Spring云配置服务器控制的数据被刷新了！

我在配置服务器上使用jdbc后端，为了模拟我的需要，我在我的一个服务的属性文件中更改了一些值，在属性表旁边，然后再次调用/monintorendpoint（这里提到了第4.3节https://www.baeldung.com/spring-cloud-bus)；因此，只更改来自属性表的数据。

这是我的配置服务器的yml文件

spring:
  cloud:
    config:
      server:
        jdbc:
          sql: SELECT KEY,VALUE from PROPERTIES where APPLICATION=? and PROFILE=? and LABEL=?
          order: 1
    stream:
      kafka:
        binder:
          brokers: localhost:9092
  datasource:
    url: jdbc:mysql://localhost:3306/sweprofile?zeroDateTimeBehavior=convertToNull
    username: 123
    password: 123ertbnm
    hikari:
      maximum-pool-size: 10
      connection-timeout: 5000
  profiles:
    active:
      - jdbc
  application:
    name: configServer

这些是分别用于我的一个MissRoseServices及其属性文件的yml文件

spring:
  datasource:
    username: 123
    password: 123ertbnm
    url: jdbc:mysql://localhost:3306/sweprofile?zeroDateTimeBehavior=convertToNull
    jpa:
      properties:
        hibernate:
          format_sql: true
          ddl-auto: none
  application:
    name: auth-service
  cloud:
    config:
      discovery:             
        enabled: true
        service-id: configServer
    bus:
      refresh:
        enabled: true
    profiles:
      active: jdbc

management:
  endpoints:
    web:
      exposure:
        include: ["health","info","refresh", "bus-refresh"]

# This line is dummy data for testing purpose 
ali.man = " Ola 12333"

这是Rest控制器的快照

@RestController
@RequestMapping("/user")
@RefreshScope
public class AuthController {
    private UserAuthService userAuthService;

    @Value("${name}")
    private String name;   // changed normally

    // Calling the key value mentioned in properties file after changing
    @Value("${ali.man}")
    private String k;      // -> not changed

    public AuthController(UserAuthService userAuthService) {
        this.userAuthService = userAuthService;
    }

    @GetMapping("authTest")
    public String getAuth() {
        return name + k;
    }
}

我错过了什么？为什么属性文件中的值没有更改？希望我可以使用带有Kafka的Spring云总线来刷新这些外部数据。

Answer 1

经过几个小时的调查，我发现有一些推荐的方法。云总线可以发送刷新事件，Spring boot具有该事件的刷新事件监听器；这就是我构建解决方案的基础。

所以当事件由总线发送时；所有实例将对加载的内存配置执行相同的逻辑（刷新数据）。

我用这个片段来应用这个

@Configuration
public class ReloadLookupEvent implements ApplicationListener<RefreshScopeRefreshedEvent> {
    @Autowired
    private CacheService cacheService;

    @Override
    public void onApplicationEvent(RefreshScopeRefreshedEvent event) {
        cacheService.refreshLookUp();     
    }

}

我可以根据需要刷新所有其他配置，也许这是一种解决方法，但可以接受。