springcloud使用(五) actuator实现自动刷新配

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