Only one connection receive subscriber allowed.

这个filter 中报Only one connection receive subscriber allowed.

主要是body体为null的情况

@Component
public class DecryptionFilter implements GlobalFilter, Ordered {

@SneakyThrows
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

解决办法：

参考：https://blog.csdn.net/weixin_37644979/article/details/115264027

完全代码：

package com.riocento.filter;import com.alibaba.fastjson.JSONObject;
import io.netty.buffer.ByteBufAllocator;import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.logging.log4j.util.Strings;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
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.NettyDataBufferFactory;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.CoreSubscriber;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.Iterator;/*** 解密过滤器* 对请求的request进行解密*/
@Slf4j
@Component
public class DecryptionFilter implements GlobalFilter, Ordered {@SneakyThrows@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("request解密处理");//源request对象ServerHttpRequest request = exchange.getRequest();//获取请求方式HttpMethod method = request.getMethod();URI uri = request.getURI();log.info("请求方式:"+method);log.info("请求地址:"+uri);MultiValueMap<String, String> queryParams = request.getQueryParams();log.info("所有参数:"+queryParams);//是否为加密参数Boolean isEncrypt = false;// GET请求解密if(HttpMethod.GET == method){if(queryParams.containsKey("isEncrypt")){isEncrypt = Boolean.valueOf(queryParams.get("isEncrypt").get(0));}if(isEncrypt){//加密参数String enParams = queryParams.get("enParams").get(0);//将参数解密String paramsStr = AESUtil.decrypt(enParams);//格式化参数String urlParams = formatUrlParams(paramsStr);//重新创建requestURI plaintUrl = new URI(uri.getScheme(), uri.getAuthority(), uri.getPath(), urlParams, uri.getFragment());ServerHttpRequest newRequest = request.mutate().uri(plaintUrl).build();return chain.filter(exchange.mutate().request(newRequest).build());}}//POST和PUT请求解密else if(HttpMethod.POST == method|| HttpMethod.PUT == method) {if(queryParams.containsKey("isEncrypt")){isEncrypt = Boolean.valueOf(queryParams.get("isEncrypt").get(0));}if(isEncrypt){URI plaintUrl = null;//处理url参数if(queryParams.size() > 0 && queryParams.containsKey("enParams")){//加密参数String urlEnParams = queryParams.get("enParams").get(0);//将参数解密String urlParamsStr = AESUtil.decrypt(urlEnParams);//格式化参数String urlParams = formatUrlParams(urlParamsStr);//重新创建uriplaintUrl = new URI(uri.getScheme(), uri.getAuthority(), uri.getPath(), urlParams, uri.getFragment());}else{plaintUrl = uri;}//处理表单参数//获取表单信息Flux<DataBuffer> dataBufferFlux = request.getBody();//获取body中的数据String strBody = FilterRequestResponseUtil.resolveBodyFromRequest(dataBufferFlux);//获取加密参数String enParams = getEnParams(strBody);//将参数解密String paramsStr = AESUtil.decrypt(enParams);ServerHttpRequest newRequest = request.mutate().uri(plaintUrl).build();DataBuffer bodyDataBuffer = stringBuffer(paramsStr);if(paramsStr == null) {newRequest = new ServerHttpRequestDecorator(newRequest) {@Overridepublic Flux<DataBuffer> getBody() {return Flux.just(bodyDataBuffer);}};// 构建新的请求头HttpHeaders headers = new HttpHeaders();headers.putAll(exchange.getRequest().getHeaders());// 重新设置CONTENT_LENGTHint length = 0;headers.remove(HttpHeaders.CONTENT_LENGTH);headers.setContentLength(length);newRequest = new ServerHttpRequestDecorator(newRequest) {@Overridepublic HttpHeaders getHeaders() {return headers;}};return chain.filter(exchange.mutate().request(newRequest).build());}Flux<DataBuffer> bodyFlux = Flux.just(bodyDataBuffer);newRequest = new ServerHttpRequestDecorator(newRequest) {@Overridepublic Flux<DataBuffer> getBody() {return bodyFlux;}};// 构建新的请求头HttpHeaders headers = new HttpHeaders();headers.putAll(exchange.getRequest().getHeaders());// 重新设置CONTENT_LENGTHint length = paramsStr.getBytes().length;headers.remove(HttpHeaders.CONTENT_LENGTH);headers.setContentLength(length);newRequest = new ServerHttpRequestDecorator(newRequest) {@Overridepublic HttpHeaders getHeaders() {return headers;}};return chain.filter(exchange.mutate().request(newRequest).build());}}//DELETE等请求方式不做处理return chain.filter(exchange);}@Overridepublic int getOrder() {return 0;}/*** 格式化url参数* @param paramsStr 字符串参数*/private String formatUrlParams(String paramsStr){StringBuilder stbResult = new StringBuilder();if(Strings.isNotEmpty(paramsStr)){if(paramsStr.startsWith("{")){JSONObject paramsJSON = JSONObject.parseObject(paramsStr);Iterator<String> iterator = paramsJSON.keySet().iterator();while (iterator.hasNext()) {String key = iterator.next();String value = paramsJSON.getString(key);if(stbResult.length() > 0){stbResult.append("&");}stbResult.append(key).append("=").append(value);}}else{stbResult.append(paramsStr);}}return stbResult.toString();}/*** 获取加密字符串参数* @return*/private String getEnParams(String paramsStr){String result = null;if(Strings.isNotEmpty(paramsStr)){if(paramsStr.startsWith("{")){//将字符串转换为JSON格式JSONObject jsonBody = JSONObject.parseObject(paramsStr);result = jsonBody.getString("enParams");}else if(paramsStr.indexOf("=") > 0){String[] paramsArr = paramsStr.split("=");result = paramsArr[1];}}return  result;}private DataBuffer stringBuffer(String value) {if(value == null) {NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(ByteBufAllocator.DEFAULT);DataBuffer buffer = nettyDataBufferFactory.allocateBuffer(0);return buffer;}byte[] bytes = value.getBytes(StandardCharsets.UTF_8);NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(ByteBufAllocator.DEFAULT);DataBuffer buffer = nettyDataBufferFactory.allocateBuffer(bytes.length);buffer.write(bytes);return buffer;}
}

Only one connection receive subscriber allowed.相关推荐

spring cloud gateway Unhandled failure: Only one connection receive subscriber allowed.
https://gist.github.com/WeirdBob/b25569d461f0f54444d2c0eab51f3c48 ToUppercaseGlobalFilter.java https ...
Spring Cloud Gateway 之获取请求体的几种方式
一.直接在全局拦截器中获取伪代码如下 private String resolveBodyFromRequest(ServerHttpRequest serverHttpRequest){Flux& ...
spring cloud gateway - 日志
spring cloud gateway - 日志实现日志前提:spring cloud gateway是基于webflux的项目,所以不能像使用spring mvc一样直接获取request b ...
SpringCloud Gateway获取post请求体(request body)
获取spring cloud gateway POST请求体的时候,会有很多坑,网上大多数解决方案是 /** 这种方法在spring-boot-starter-parent 2.0.6.RELEASE ...
quartz异常：Couldn't rollback jdbc connection
为什么80%的码农都做不了架构师?>>> 最近工作发现,有个项目偶尔会报Couldn't rollback jdbc connection. No operations all ...
python2.0_s12_day10_rabbitMQ使用介绍
RabbitMQ RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统.他遵循Mozilla Public License开源协议. MQ全称为Message Queue, 消息队列(M ...
Python-day-9- RabbitMQ队列
RabbitMQ队列安装 http://www.rabbitmq.com/install-standalone-mac.html 安装python rabbitMQ module pip insta ...
Day10-Python3基础-协程、异步IO、redis缓存、rabbitMQ队列
内容目录: Gevent协程 Select\Poll\Epoll异步IO与事件驱动 Python连接Mysql数据库操作 RabbitMQ队列 Redis\Memcached缓存 Paramiko S ...
Python学习笔记day10
Twsited异步网络框架 twisted是一个用python语言写的事件驱动的网络框架,他支持很多种协议,包括UDP,TCP,TLS和其他应用层协议,比如HTTP,SMTP,NNTM,IRC,XMP ...
java disconnect_Java BlockingConnection.disconnect方法代碼示例
本文整理匯總了Java中org.fusesource.mqtt.client.BlockingConnection.disconnect方法的典型用法代碼示例.如果您正苦於以下問題:Java Bloc ...

Only one connection receive subscriber allowed.

Only one connection receive subscriber allowed.相关推荐

最新文章

热门文章