spring-boot-config-server和spring-boot-config-client已经搭建完毕, 但每次修改github上的配置文件后要主动调用一次/refresh才能刷新配置, 这有点不智能. 看到有人用github的webhook修改文件后自动调用/refresh, 但自己试了下会报415错误, json解析出错. 猜想到spring-boot2版本的接收参数和webhook提交的参数可能不匹配导致出错. 所以此方法可能不行.
于是换个思路, 用webhook调用本地接口, 自己可以控制, 然后本地接口再调用actuator的/refresh(参数为空字符串). 实践后确实可以.
1. 添加okhttp依赖
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.10.0</version>
</dependency>
为什么选择okhttp, 因为自己写的post请求会永久阻塞, 使用RestTemplate会超时(当然,可能是自己没有处理好)...
2. 编写okhttp的application/json形式的post请求方法
public static void postUseOkhttp(String url, String requestBody){
MediaType mediaType = MediaType.parse("application/json; charset=utf-8");
Request request = new Request.Builder()
.url(url)
.post(RequestBody.create(mediaType, requestBody))
.build();
OkHttpClient okHttpClient = new OkHttpClient.Builder().connectTimeout(5000, TimeUnit.MILLISECONDS).readTimeout(6000,TimeUnit.MILLISECONDS).build();
// execute还是会超时
/*try {
Response response = okHttpClient.newCall(request).execute();
// result = response.body().string();
} catch (IOException e) {
LOGGER.info(">>>>>>>>>>>>>>>>post请求发生错误,错误信息:{}",e);
}*/
okHttpClient.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
LOGGER.info(">>>>>>>>>>>>>>>>请求发生错误,错误信息:{}",e);
}
@Override
public void onResponse(Call call, Response response) throws IOException {
LOGGER.info(response.protocol() + " " +response.code() + " " + response.message());
Headers headers = response.headers();
for (int i = 0; i < headers.size(); i++) {
LOGGER.info( headers.name(i) + ":" + headers.value(i));
}
LOGGER.info( "onResponse: " + response.body().string());
}
});
}
3.编写webhook要调用的/refresh接口
/**
* github文件修改commit后,会主动调用本接口(直接调用/config/refresh,因为那边接口接收的json参数不匹配, 故报参数错误)
* 所以只能让github主动调用本接口, 本接口再发送一个参数为空的post请求给/config/refresh
* @param request
* @return
* @throws Exception
*/
@RequestMapping("/refresh")
public String refresh(HttpServletRequest request) throws Exception{
String url = "http://你的域名/config/refresh";
HttpTool.postUseOkhttp(url, "{}");
return "success";
}
注意这里的/config/refresh, 我有自定义, 如果不自定义的话2版本默认是/actuator/refresh
# 开放所有页面节点 默认只开启了health、info两个节点
management.endpoints.web.exposure.include=refresh
# web访问路径, 默认auctor, 可以自定义
management.endpoints.web.base-path=/config
然后去修改一下git上的配置文件的参数值, 然后再调用查看参数的接口, 发现配置参数自动刷新过来. 至此, actuator自动刷新配置实现完毕.
over
