Spring Cloud 集成 WebHook

逃离我推掉我的手 2024-04-17 06:07 52阅读 0赞

# 1.配置 WebHook 地址 #

登录 GitHub，点击 GitHub 的 WebHook 菜单，右侧面板中 Payload URL 填写 <配置中心 url>/actuator/bus-refresh, Content-type 选择 applicaton/json，保存即可。

因为需要用到外网，这里使用[natapp外网穿透][natapp]做外网映射

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70][]

设置 WebHook 操作：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70 1][]

# 2.修改config-server #

添加：

import org.springframework.stereotype.Component;
    
    import javax.servlet.*;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletRequestWrapper;
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    
    @Component
    public class WebHookFilter implements Filter {
    
        @Override
        public void init(FilterConfig filterConfig) throws ServletException {
    
        }
    
        @Override
        public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
                throws IOException, ServletException {
            HttpServletRequest httpServletRequest = (HttpServletRequest) request;
            String url = new String(httpServletRequest.getRequestURI());
    
            // 只过滤 /actuator/bus-refresh 请求
            if (!url.endsWith("/actuator/bus-refresh")) {
                chain.doFilter(request, response);
                return;
            }
    
            // 使用 HttpServletRequest 包装原始请求达到修改 post 请求中 body 内容的目的
            CustometRequestWrapper requestWrapper = new CustometRequestWrapper(httpServletRequest);
    
            chain.doFilter(requestWrapper, response);
    
        }
    
        @Override
        public void destroy() {
    
        }
    
        private class CustometRequestWrapper extends HttpServletRequestWrapper {
            public CustometRequestWrapper(HttpServletRequest request) {
                super(request);
            }
    
            @Override
            public ServletInputStream getInputStream() throws IOException {
                byte[] bytes = new byte[0];
                ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
    
                return new ServletInputStream() {
                    @Override
                    public boolean isFinished() {
                        return byteArrayInputStream.read() == -1 ? true : false;
                    }
    
                    @Override
                    public boolean isReady() {
                        return false;
                    }
    
                    @Override
                    public void setReadListener(ReadListener readListener) {
    
                    }
    
                    @Override
                    public int read() throws IOException {
                        return byteArrayInputStream.read();
                    }
                };
            }
        }
    }

# 3.测试 #

1.  完成以上配置后，重启项目
2.  修改github文件
3.  再执行 [http://localhost/test/getConfigInfo][http_localhost_test_getConfigInfo]

因为网络原因，等几秒钟加载几次就能拉去新的数据了

[natapp]: https://blog.csdn.net/qq_40369944/article/details/86712298
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/16/9f894694489c43b7a5e9c748128d14a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/16/5ad134ad2a5241fcb1e1ac6e13c70932.png
[http_localhost_test_getConfigInfo]: http://localhost/test/getConfigInfo