配置spring-cloud-config 利用kafka动态刷新配置

svr-configuration/src/main/resources/bootstrap.yml

@@ -66,17 +66,16 @@ spring:
  profiles:
    active: native
##git配置
  cloud:
    config:
      failFast: true ##启动快速失败 即链接不到配置服务就启动失败
      server:
        native:
          search-locations: file:G:\idea_workspace\jkzl_git\jw.config  ##本地的got配置路径
    stream:
      kafka:
        binder:
          brokers: 172.17.110.201:9092
          zkNodes: 172.17.110.201:2181
#配置服务动态刷新
#    stream:
#      kafka:
#        binder:
#          brokers: 172.17.110.201:9092
#          zkNodes: 172.17.110.201:2181

web-gateway/src/main/java/com/yihu/jw/controller/PatientController.java

@@ -27,7 +27,7 @@ import javax.servlet.http.HttpServletRequest;
@RestController
@RequestMapping("/{version}/patient")
@Api(description = "患者")
//@RefreshScope
@RefreshScope
public class PatientController {
    private Logger logger = LoggerFactory.getLogger(PatientController.class);
    @Autowired
@@ -37,9 +37,9 @@ public class PatientController {
    private Tracer tracer;
//
//    @Value("${test.aaa}")
//    private String aaaa;
    @Value("${test.aaa}")
    private String aaaa;
    @GetMapping("/hello")
    @ApiVersion(1)
@@ -68,12 +68,12 @@ public class PatientController {
        return "hello2";
    }
//    @GetMapping("/refresh")
//    @ApiVersion(0)
//    @ResponseBody
//    public String refresh(HttpServletRequest request) throws Exception {
//        return aaaa;
//    }
    @GetMapping("/refresh")
    @ApiVersion(0)
    @ResponseBody
    public String refresh(HttpServletRequest request) throws Exception {
        return aaaa;
    }
    @ApiOperation(value = "根据code查找患者")