1 @Configuration
2 public class JsonConfig {
3
4 @Bean
5 public NumberFormatCustomizer getNumberFormatCustomizer() {
6 // 閰嶇疆jackson鍏ㄥ眬嫻偣鏁版牸寮忓寲杈撳嚭
7 return new NumberFormatCustomizer();
8 }
9
10 static class NumberFormatCustomizer implements Jackson2ObjectMapperBuilderCustomizer {
11
12 @Override
13 public void customize(Jackson2ObjectMapperBuilder jacksonObjectMapperBuilder) {
14 // 閰嶇疆json搴忓垪鍖?br />15 // long綾誨瀷杈撳嚭瀛楃涓?br />16 // double鍜孊igDecimal淇濈暀涓や綅灝忔暟鎴柇杈撳嚭瀛楃涓?/span>
17 jacksonObjectMapperBuilder
18 .serializerByType(Long.class, new StringSerializer())
19 .serializerByType(Long.TYPE, new StringSerializer())
20 .serializerByType(Double.class, new NumberSerializer())
21 .serializerByType(Double.TYPE, new NumberSerializer())
22 .serializerByType(BigDecimal.class, new NumberSerializer());
23 }
24 }
25
26 public static class NumberSerializer extends JsonSerializer<Number> {
27
28 private NumberFormat numberFormat;
29 public NumberSerializer() {
30 this.numberFormat = NumberFormat.getInstance();
31 // 鏈澶氫袱浣嶅皬鏁?/span>
32 this.numberFormat.setMaximumFractionDigits(2);
33 // 鎴柇
34 this.numberFormat.setRoundingMode(RoundingMode.FLOOR);
35 }
36
37 @Override
38 public void serialize(Number value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
39 if (value != null) {
40 gen.writeString(this.numberFormat.format(value));
41 }
42 }
43 }
44 }
2 public class JsonConfig {
3
4 @Bean
5 public NumberFormatCustomizer getNumberFormatCustomizer() {
6 // 閰嶇疆jackson鍏ㄥ眬嫻偣鏁版牸寮忓寲杈撳嚭
7 return new NumberFormatCustomizer();
8 }
9
10 static class NumberFormatCustomizer implements Jackson2ObjectMapperBuilderCustomizer {
11
12 @Override
13 public void customize(Jackson2ObjectMapperBuilder jacksonObjectMapperBuilder) {
14 // 閰嶇疆json搴忓垪鍖?br />15 // long綾誨瀷杈撳嚭瀛楃涓?br />16 // double鍜孊igDecimal淇濈暀涓や綅灝忔暟鎴柇杈撳嚭瀛楃涓?/span>
17 jacksonObjectMapperBuilder
18 .serializerByType(Long.class, new StringSerializer())
19 .serializerByType(Long.TYPE, new StringSerializer())
20 .serializerByType(Double.class, new NumberSerializer())
21 .serializerByType(Double.TYPE, new NumberSerializer())
22 .serializerByType(BigDecimal.class, new NumberSerializer());
23 }
24 }
25
26 public static class NumberSerializer extends JsonSerializer<Number> {
27
28 private NumberFormat numberFormat;
29 public NumberSerializer() {
30 this.numberFormat = NumberFormat.getInstance();
31 // 鏈澶氫袱浣嶅皬鏁?/span>
32 this.numberFormat.setMaximumFractionDigits(2);
33 // 鎴柇
34 this.numberFormat.setRoundingMode(RoundingMode.FLOOR);
35 }
36
37 @Override
38 public void serialize(Number value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
39 if (value != null) {
40 gen.writeString(this.numberFormat.format(value));
41 }
42 }
43 }
44 }
]]>
]]>
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Enumeration;
import java.util.concurrent.TimeUnit;
import javax.servlet.ServletInputStream;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
public class MyHttpRequestWrapper extends HttpServletRequestWrapper {
byte[] buffer = null;
private ServletInputStream in = null;
private BufferedReader reader = null;
private boolean isMultipart = false;
private String contentType = null;
public MyHttpRequestWrapper(HttpServletRequest request) throws IOException {
super(request);
contentType = request.getHeader("Content-Type");
if (contentType != null
&& contentType.startsWith("multipart/form-data")) {
isMultipart = true;// fileupload
readInputStream(request);
// read end and wrapper buffer
ByteArrayInputStream inputStream = new ByteArrayInputStream(buffer);// real
// servletInputStream
in = new WrapperServletInputstream(inputStream);
reader = new BufferedReader(new InputStreamReader(inputStream));
}
}
/**
* 璇誨彇request嫻佸埌buffer涓?br /> *
* @param request
* HttpServletRequest
* @throws IOException
* if throws IOException
*/
private void readInputStream(HttpServletRequest request) throws IOException {
int contentLength = request.getContentLength();
ServletInputStream sis = request.getInputStream();
int maxReadSize = 1024;// buffer size
buffer = new byte[contentLength];
int end = 0;
int len = 0;
while (end <= contentLength) {
len = sis.read(buffer, end, maxReadSize);
if (len == -1) {
end = contentLength;
break;
}
end += len;
try {
TimeUnit.MILLISECONDS.sleep(0);// 杞
} catch (InterruptedException e) {
// ignroe
}
}
sis.close();// closed?
}
/**
* if isMultipart return request inputstream to byte[]
*
* @return default null
*/
public byte[] getRequestData() {
return buffer;
}
// 閲嶈澆鐖剁被鑾峰彇inputStream鐨勬柟娉?/span>
@Override
public ServletInputStream getInputStream() throws IOException {
return isMultipart ? in : super.getInputStream();
}
// 閲嶈澆鐖剁被鑾峰彇reader鐨勬柟娉?/span>
@Override
public BufferedReader getReader() throws IOException {
return isMultipart ? reader : super.getReader();
}
/**
* 鍒ゆ柇姝ゆ璇鋒眰鏄惁鏄笂浼犳枃浠?br /> *
* @return
*/
public boolean isMultipart() {
return isMultipart;
}
public String getRequestInfo() {
Enumeration parameterNames = getParameterNames();
StringBuilder parameterInfo = new StringBuilder();
while (parameterNames.hasMoreElements()) {
String name = parameterNames.nextElement().toString();
String[] parameters = getParameterValues(name);
parameterInfo.append(name).append(":[");
for (String str : parameters) {
parameterInfo.append(str).append(",");
}
if (parameters.length > 0) {
parameterInfo.deleteCharAt(parameterInfo.length() - 1);
}
parameterInfo.append("]\n");
}
Enumeration headerNames = getHeaderNames();
StringBuilder headerInfo = new StringBuilder();
while (headerNames.hasMoreElements()) {
String name = headerNames.nextElement().toString();
Enumeration headers = getHeaders(name);
headerInfo.append(name).append(":");
while (headers.hasMoreElements()) {
headerInfo.append(headers.nextElement()).append(" ");
}
headerInfo.append("\n");
}
StringBuilder cookies = new StringBuilder();
// for (int i = 0;i<getCookies().length;i++) {
// Cookie cookie = getCookies()[i];
// if(cookie==null){
// continue;
// }
// cookies.append(cookie.getName()).append(":").append(
// cookie.getValue()).append("\n");
// }
StringBuilder requestInfo = new StringBuilder().append(parameterInfo)
.append(headerInfo).append(cookies);
return requestInfo.toString();
}
class WrapperServletInputstream extends ServletInputStream {
private InputStream in = null;
public WrapperServletInputstream(InputStream in) throws IOException {
this.in = in;
}
@Override
public int read() throws IOException {
int read = in.read();
return read;
}
@Override
public synchronized void reset() throws IOException {
in.reset();
super.reset();
}
}
}import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Enumeration;
import java.util.concurrent.TimeUnit;
import javax.servlet.ServletInputStream;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
public class MyHttpRequestWrapper extends HttpServletRequestWrapper {
byte[] buffer = null;
private ServletInputStream in = null;
private BufferedReader reader = null;
private boolean isMultipart = false;
private String contentType = null;
public MyHttpRequestWrapper(HttpServletRequest request) throws IOException {
super(request);
contentType = request.getHeader("Content-Type");
if (contentType != null
&& contentType.startsWith("multipart/form-data")) {
isMultipart = true;// fileupload
readInputStream(request);
// read end and wrapper buffer
ByteArrayInputStream inputStream = new ByteArrayInputStream(buffer);// real
// servletInputStream
in = new WrapperServletInputstream(inputStream);
reader = new BufferedReader(new InputStreamReader(inputStream));
}
}
/**
* 璇誨彇request嫻佸埌buffer涓?br /> *
* @param request
* HttpServletRequest
* @throws IOException
* if throws IOException
*/
private void readInputStream(HttpServletRequest request) throws IOException {
int contentLength = request.getContentLength();
ServletInputStream sis = request.getInputStream();
int maxReadSize = 1024;// buffer size
buffer = new byte[contentLength];
int end = 0;
int len = 0;
while (end <= contentLength) {
len = sis.read(buffer, end, maxReadSize);
if (len == -1) {
end = contentLength;
break;
}
end += len;
try {
TimeUnit.MILLISECONDS.sleep(0);// 杞
} catch (InterruptedException e) {
// ignroe
}
}
sis.close();// closed?
}
/**
* if isMultipart return request inputstream to byte[]
*
* @return default null
*/
public byte[] getRequestData() {
return buffer;
}
// 閲嶈澆鐖剁被鑾峰彇inputStream鐨勬柟娉?/span>
@Override
public ServletInputStream getInputStream() throws IOException {
return isMultipart ? in : super.getInputStream();
}
// 閲嶈澆鐖剁被鑾峰彇reader鐨勬柟娉?/span>
@Override
public BufferedReader getReader() throws IOException {
return isMultipart ? reader : super.getReader();
}
/**
* 鍒ゆ柇姝ゆ璇鋒眰鏄惁鏄笂浼犳枃浠?br /> *
* @return
*/
public boolean isMultipart() {
return isMultipart;
}
public String getRequestInfo() {
Enumeration parameterNames = getParameterNames();
StringBuilder parameterInfo = new StringBuilder();
while (parameterNames.hasMoreElements()) {
String name = parameterNames.nextElement().toString();
String[] parameters = getParameterValues(name);
parameterInfo.append(name).append(":[");
for (String str : parameters) {
parameterInfo.append(str).append(",");
}
if (parameters.length > 0) {
parameterInfo.deleteCharAt(parameterInfo.length() - 1);
}
parameterInfo.append("]\n");
}
Enumeration headerNames = getHeaderNames();
StringBuilder headerInfo = new StringBuilder();
while (headerNames.hasMoreElements()) {
String name = headerNames.nextElement().toString();
Enumeration headers = getHeaders(name);
headerInfo.append(name).append(":");
while (headers.hasMoreElements()) {
headerInfo.append(headers.nextElement()).append(" ");
}
headerInfo.append("\n");
}
StringBuilder cookies = new StringBuilder();
// for (int i = 0;i<getCookies().length;i++) {
// Cookie cookie = getCookies()[i];
// if(cookie==null){
// continue;
// }
// cookies.append(cookie.getName()).append(":").append(
// cookie.getValue()).append("\n");
// }
StringBuilder requestInfo = new StringBuilder().append(parameterInfo)
.append(headerInfo).append(cookies);
return requestInfo.toString();
}
class WrapperServletInputstream extends ServletInputStream {
private InputStream in = null;
public WrapperServletInputstream(InputStream in) throws IOException {
this.in = in;
}
@Override
public int read() throws IOException {
int read = in.read();
return read;
}
@Override
public synchronized void reset() throws IOException {
in.reset();
super.reset();
}
}
}import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;
public class MyHttpResponseWrapper extends HttpServletResponseWrapper {
private ByteArrayOutputStream buffer = null;
private ServletOutputStream out = null;
private PrintWriter writer = null;
private boolean usingStream = false;
private boolean usingWriter = false;
public MyHttpResponseWrapper(HttpServletResponse resp) throws IOException {
super(resp);
buffer = new ByteArrayOutputStream();// 鐪熸瀛樺偍鏁版嵁鐨勬祦
out = new WapperedOutputStream(buffer);
writer = new PrintWriter(new OutputStreamWriter(buffer, "UTF-8"));
}
// 閲嶈澆鐖剁被鑾峰彇outputstream鐨勬柟娉?/span>
@Override
public ServletOutputStream getOutputStream() throws IOException {
usingStream = true;
return out;
}
// 閲嶈澆鐖剁被鑾峰彇writer鐨勬柟娉?/span>
@Override
public PrintWriter getWriter() throws UnsupportedEncodingException {
usingWriter = true;
return writer;
}
// 閲嶈澆鐖剁被鑾峰彇flushBuffer鐨勬柟娉?/span>
@Override
public void flushBuffer() throws IOException {
if (out != null) {
out.flush();
}
if (writer != null) {
writer.flush();
}
}
@Override
public void reset() {
buffer.reset();
}
public byte[] getResponseData() throws IOException {
// 灝唎ut銆亀riter涓殑鏁版嵁寮哄埗杈撳嚭鍒癢apperedResponse鐨刡uffer閲岄潰錛屽惁鍒欏彇涓嶅埌鏁版嵁
flushBuffer();
return buffer.toByteArray();
}
// 鍐呴儴綾伙紝瀵筍ervletOutputStream榪涜鍖呰
private class WapperedOutputStream extends ServletOutputStream {
private ByteArrayOutputStream bos = null;
public WapperedOutputStream(ByteArrayOutputStream stream)
throws IOException {
bos = stream;
}
@Override
public void write(int b) throws IOException {
bos.write(b);
}
}
public boolean isUsingStream() {
return usingStream;
}
public boolean isUsingWriter() {
return usingWriter;
}
}// --------鑾峰彇璇鋒眰鍐呭------------------
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;
public class MyHttpResponseWrapper extends HttpServletResponseWrapper {
private ByteArrayOutputStream buffer = null;
private ServletOutputStream out = null;
private PrintWriter writer = null;
private boolean usingStream = false;
private boolean usingWriter = false;
public MyHttpResponseWrapper(HttpServletResponse resp) throws IOException {
super(resp);
buffer = new ByteArrayOutputStream();// 鐪熸瀛樺偍鏁版嵁鐨勬祦
out = new WapperedOutputStream(buffer);
writer = new PrintWriter(new OutputStreamWriter(buffer, "UTF-8"));
}
// 閲嶈澆鐖剁被鑾峰彇outputstream鐨勬柟娉?/span>
@Override
public ServletOutputStream getOutputStream() throws IOException {
usingStream = true;
return out;
}
// 閲嶈澆鐖剁被鑾峰彇writer鐨勬柟娉?/span>
@Override
public PrintWriter getWriter() throws UnsupportedEncodingException {
usingWriter = true;
return writer;
}
// 閲嶈澆鐖剁被鑾峰彇flushBuffer鐨勬柟娉?/span>
@Override
public void flushBuffer() throws IOException {
if (out != null) {
out.flush();
}
if (writer != null) {
writer.flush();
}
}
@Override
public void reset() {
buffer.reset();
}
public byte[] getResponseData() throws IOException {
// 灝唎ut銆亀riter涓殑鏁版嵁寮哄埗杈撳嚭鍒癢apperedResponse鐨刡uffer閲岄潰錛屽惁鍒欏彇涓嶅埌鏁版嵁
flushBuffer();
return buffer.toByteArray();
}
// 鍐呴儴綾伙紝瀵筍ervletOutputStream榪涜鍖呰
private class WapperedOutputStream extends ServletOutputStream {
private ByteArrayOutputStream bos = null;
public WapperedOutputStream(ByteArrayOutputStream stream)
throws IOException {
bos = stream;
}
@Override
public void write(int b) throws IOException {
bos.write(b);
}
}
public boolean isUsingStream() {
return usingStream;
}
public boolean isUsingWriter() {
return usingWriter;
}
}// --------鑾峰彇璇鋒眰鍐呭------------------
MyHttpRequestWrapper httpRequestWrapper = new MyHttpRequestWrapper(
request);// 鑾峰彇request璇鋒眰鍐呭
MyHttpResponseWrapper httpResponseWrapper = new MyHttpResponseWrapper(
response);// 瑁呴グHttpServletRequest
boolean passResponse = true;// 鏄惁閫氳繃鍝嶅簲,榛樿鏄?/span>
chain.doFilter(httpRequestWrapper, httpResponseWrapper);
String encode = httpRequestWrapper.getCharacterEncoding();
encode = encode == null ? Constant.default_charset : encode;
String request_content = null;
if (httpRequestWrapper.isMultipart()) {// 鏂囦歡涓婁紶鍐呭涓篵yte[]
request_content = new String(httpRequestWrapper.getRequestData(),
encode);
} else {// 鏅氫笂浼犲唴瀹?/span>
request_content = httpRequestWrapper.getRequestInfo();
// System.out.println("鏅氫笂浼犲唴瀹?"+request_content);
}
passRequest = !checkHtml.check_html(fullURL, request_content);
if (passRequest) {
System.out.println("passRequest:" + fullURL);
} else {
System.out.println("request contain keywords:" + fullURL);
// sendErrorPage(httpRequestWrapper, response);//涓嶈漿璺?nbsp;璁板綍鏃ュ織鍒版暟鎹簱灝卞彲浠ヤ簡
popupMessage(httpRequestWrapper, httpResponseWrapper);
return;
}
byte[] response_data = httpResponseWrapper.getResponseData();
if (httpResponseWrapper.isUsingWriter()) {
response_data = new String(response_data, "UTF-8")
.getBytes(httpResponseWrapper.getCharacterEncoding());
}
String response_content = new String(response_data, httpResponseWrapper
.getCharacterEncoding());
passResponse = !checkHtml.check_html(fullURL, response_content);
if (passResponse) {
System.out.println("passResponse:" + fullURL);
OutputStream out = response.getOutputStream();// 浜岃繘鍒跺鐞嗘墍鏈夌被鍨?/span>
out.write(response_data);
out.close();
} else {
System.out.println("can't passResponse:" + fullURL);
sendErrorPage(httpRequestWrapper,
(HttpServletResponse) httpResponseWrapper.getResponse());
}
鍦?TOMCAT_HOME/conf/web.xml閰嶇疆涓婇潰鐨刦ilter,瀹屼簡嫻嬭瘯浜嗕笅錛屼笂浼犳枃浠跺鐞嗚秴榪?6M鏂囦歡鏃訛紝鏂板緩buffer鏁扮粍鍙兘浼氭姤outofmemery閿欒request);// 鑾峰彇request璇鋒眰鍐呭
MyHttpResponseWrapper httpResponseWrapper = new MyHttpResponseWrapper(
response);// 瑁呴グHttpServletRequest
boolean passResponse = true;// 鏄惁閫氳繃鍝嶅簲,榛樿鏄?/span>
chain.doFilter(httpRequestWrapper, httpResponseWrapper);
String encode = httpRequestWrapper.getCharacterEncoding();
encode = encode == null ? Constant.default_charset : encode;
String request_content = null;
if (httpRequestWrapper.isMultipart()) {// 鏂囦歡涓婁紶鍐呭涓篵yte[]
request_content = new String(httpRequestWrapper.getRequestData(),
encode);
} else {// 鏅氫笂浼犲唴瀹?/span>
request_content = httpRequestWrapper.getRequestInfo();
// System.out.println("鏅氫笂浼犲唴瀹?"+request_content);
}
passRequest = !checkHtml.check_html(fullURL, request_content);
if (passRequest) {
System.out.println("passRequest:" + fullURL);
} else {
System.out.println("request contain keywords:" + fullURL);
// sendErrorPage(httpRequestWrapper, response);//涓嶈漿璺?nbsp;璁板綍鏃ュ織鍒版暟鎹簱灝卞彲浠ヤ簡
popupMessage(httpRequestWrapper, httpResponseWrapper);
return;
}
byte[] response_data = httpResponseWrapper.getResponseData();
if (httpResponseWrapper.isUsingWriter()) {
response_data = new String(response_data, "UTF-8")
.getBytes(httpResponseWrapper.getCharacterEncoding());
}
String response_content = new String(response_data, httpResponseWrapper
.getCharacterEncoding());
passResponse = !checkHtml.check_html(fullURL, response_content);
if (passResponse) {
System.out.println("passResponse:" + fullURL);
OutputStream out = response.getOutputStream();// 浜岃繘鍒跺鐞嗘墍鏈夌被鍨?/span>
out.write(response_data);
out.close();
} else {
System.out.println("can't passResponse:" + fullURL);
sendErrorPage(httpRequestWrapper,
(HttpServletResponse) httpResponseWrapper.getResponse());
}
]]>