添加到配置中心filter

src/main/java/com/unissoft/filter/CustomerRequestWrapper.java

@@ -0,0 +1,49 @@
+package com.unissoft.filter;
+
+import javax.servlet.ReadListener;
+import javax.servlet.ServletInputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletRequestWrapper;
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+
+/**
+ * 文件描述
+ *
+ * @author tongxi.xia
+ * @date 2020年12月17日 19:07
+ */
+public class CustomerRequestWrapper extends HttpServletRequestWrapper {
+    public CustomerRequestWrapper(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();
+            }
+        };
+    }
+}

src/main/java/com/unissoft/filter/WebhooksFilter.java

@@ -0,0 +1,47 @@
+package com.unissoft.filter;
+
+import org.springframework.stereotype.Component;
+
+import javax.servlet.*;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * 文件描述
+ *
+ * @author tongxi.xia
+ * @date 2020年12月17日 19:06
+ */
+@Component
+public class WebhooksFilter implements Filter {
+
+    @Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+
+    }
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
+        HttpServletRequest httpServletRequest = (HttpServletRequest) servletRequest;
+        HttpServletResponse httpServletResponse = (HttpServletResponse) servletResponse;
+
+        String url = new String(httpServletRequest.getRequestURI());
+
+        //只过滤/actuator/bus-refresh
+        if (!url.endsWith("/actuator/bus-refresh")) {
+            filterChain.doFilter(servletRequest, httpServletResponse);
+            return;
+        }
+
+        //使用HttpServletRequest包装原始请求达到修改post请求中body内容的目的
+        CustomerRequestWrapper requestWrapper = new CustomerRequestWrapper(httpServletRequest);
+
+        filterChain.doFilter(requestWrapper, servletResponse);
+    }
+
+    @Override
+    public void destroy() {
+
+    }
+}