| | |
| | | import org.springframework.cloud.gateway.filter.GlobalFilter;
|
| | | import org.springframework.core.Ordered;
|
| | | import org.springframework.core.io.buffer.DataBuffer;
|
| | | import org.springframework.core.io.buffer.DataBufferFactory;
|
| | | import org.springframework.core.io.buffer.DataBufferUtils;
|
| | | import org.springframework.core.io.buffer.DefaultDataBufferFactory;
|
| | | import org.springframework.core.io.buffer.NettyDataBufferFactory;
|
| | | import org.springframework.http.HttpHeaders;
|
| | | import org.springframework.http.HttpMethod;
|
| | |
| | | public Flux<DataBuffer> getBody()
|
| | | {
|
| | | Flux<DataBuffer> body = super.getBody();
|
| | | return body.map(dataBuffer -> {
|
| | | byte[] content = new byte[dataBuffer.readableByteCount()];
|
| | | dataBuffer.read(content);
|
| | | DataBufferUtils.release(dataBuffer);
|
| | | return body.buffer().map(dataBuffers -> {
|
| | | DataBufferFactory dataBufferFactory = new DefaultDataBufferFactory();
|
| | | DataBuffer join = dataBufferFactory.join(dataBuffers);
|
| | | byte[] content = new byte[join.readableByteCount()];
|
| | | join.read(content);
|
| | | DataBufferUtils.release(join);
|
| | | String bodyStr = new String(content, StandardCharsets.UTF_8);
|
| | | // 防xss攻击过滤
|
| | | bodyStr = EscapeUtil.clean(bodyStr);
|
| | |
| | | /**
|
| | | * 是否是Json请求
|
| | | *
|
| | | * @param request
|
| | | * @param exchange HTTP请求
|
| | | */
|
| | | public boolean isJsonRequest(ServerWebExchange exchange)
|
| | | {
|