使用springcloud的過程中,使用webhook自動發送一個post到configserver,在自己本機上測試可行,但是在碼雲或者github上就報下邊的錯誤。
{“timestamp”:“2020-12-13T07:01:11.392+00:00”,“status”:400,“error”:“Bad Request”,“message”:"",“path”:"/actuator/bus-refresh/"}
原因:
因為webhook發送post的時候攜帶了其他的資訊,是以可任意用過攔截器把對應的多餘的資訊攔截掉。
- 添加注解@ServletComponentScan(“com.englishcode.config.interceptors”)
- 編寫對應的攔截器
//編寫對應的攔截器對webhook發來的連接配接進行處理
package com.englishcode.config.interceptors;
import org.springframework.stereotype.Component;
import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayInputStream;
import java.io.IOException;
/**
* @author cyl
* @version 1.0
* @date 2020/12/13 15:26
*/
@Component
public class WebHooksFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void destroy() {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest httpServletRequest = (HttpServletRequest) servletRequest;
String url = new String(httpServletRequest.getRequestURI());
if(!url.endsWith("/bus-refresh")){
filterChain.doFilter(servletRequest,servletResponse);
return;
}
RequestWrapper requestWrapper = new RequestWrapper(httpServletRequest);
filterChain.doFilter(requestWrapper, servletResponse);
}
private class RequestWrapper extends HttpServletRequestWrapper {
public RequestWrapper(HttpServletRequest request) {
super(request);
}
@Override
public ServletInputStream getInputStream() throws IOException {
byte[] bytes = new byte[0];
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
ServletInputStream servletInputStream = new ServletInputStream() {
@Override
public int read() throws IOException {
return byteArrayInputStream.read();
}
@Override
public boolean isFinished() {
return byteArrayInputStream.read() == -1 ? true : false;
}
@Override
public boolean isReady() {
return false;
}
@Override
public void setReadListener(ReadListener listener) {
}
};
return servletInputStream;
}
}
}