\u4e00\u822c\u4ece\u524d\u53f0\u63a5\u6536\u5230\u7684\u53c2\u6570\u90fd\u662fJSON\u4e4b\u7c7b\u7684\u901a\u7528\u683c\u5f0f\uff0c\u6216\u8005\u901a\u8fc7@RequestBody\u81ea\u52a8\u6620\u5c04\u5b9e\u4f53\u7c7b\u3002\u4f46\u662f\u5982\u679c\u60f3\u8981\u5c06\u62ff\u5230\u7684\u6570\u636e\u76f4\u63a5\u81ea\u52a8\u8f6c\u6362\u6210\u4e00\u4e2a\u975e\u666e\u901a\u7c7b\u5b9e\u4f53\uff0c\u800c\u4e0d\u662f\u62ff\u5230\u4ee5\u540e\u81ea\u5df1\u518d\u5c01\u88c5\u3002\u8fd9\u65f6\u5019\u6700\u597d\u5c31\u81ea\u5b9a\u4e49\u4e00\u4e2a\u6ce8\u89e3\uff0c\u9488\u5bf9\u6240\u9700\u8981\u7684\u683c\u5f0f\u81ea\u52a8\u5c01\u88c5\u3002<\/p>\n\n\n\n
\u5b9e\u73b0\u65b9\u6cd5\u5982\u4e0b\uff1a<\/p>\n\n\n\n
\u9996\u5148\u58f0\u660e\u4e00\u4e2a\u6ce8\u89e3\uff1a\uff08Dson\u4e3a\u4e00\u4e2a\u57fa\u4e8eJSON\u683c\u5f0f\u7684\u81ea\u5b9a\u4e49\u4e8c\u6b21\u5c01\u88c5\u7c7b\uff0c\u5bf9JSON\u683c\u5f0f\u8fdb\u884c\u7a7a\u53c2\u5224\u65ad\uff0c\u5ffd\u7565\u5f15\u53f7\uff0c\u53ef\u4ee5\u7b80\u6613\u65b9\u6cd5\u76f4\u63a5\u53d6\u503c\uff09<\/p>\n\n\n
\n@Target({ElementType.PARAMETER})\n@Retention(RetentionPolicy.RUNTIME)\n@Documented\npublic @interface RequestDson {\n}\n<\/pre><\/div>\n\n\n\u63a5\u4e0b\u6765\u5199\u4e00\u4e2a\u6620\u5c04\u5668\uff0c\u76f8\u5f53\u4e8e\u4e0a\u9762\u81ea\u5b9a\u4e49\u6ce8\u89e3\u7684\u5b9e\u73b0\u65b9\u6cd5\u3002\u7ee7\u627f AbstractMessageReaderArgumentResolver \u7c7b\uff0c\u5b9e\u73b0\u5176\u4e2d\u4e24\u4e2a\u65b9\u6cd5\uff0csupportsParameter\u662f\u5224\u65ad\u8be5\u6ce8\u89e3\u662f\u5426\u53ef\u4ee5\u751f\u6548\uff0ctrue\u7684\u8bdd\u8fdb\u5165\u4e0b\u9762\u5b9e\u73b0\u65b9\u6cd5\u4e2d\u8fdb\u884c\u5b9e\u73b0\uff0c\u5b9e\u73b0\u65b9\u6cd5\u4e2dresolveArgument\u8fdb\u884c\u5904\u7406\u540e\u5c31\u4f20\u5230@RequestBody\u4e2d\u8fc7\u4e00\u904d\u540e\u4f20\u5230Controller\u4e2d\u8fdb\u884c\u903b\u8f91\u5904\u7406\u3002<\/p>\n\n\n
\npackage com.miracle.qaodo.config;\n\n\nimport com.miracle.dson.Dson;\nimport com.miracle.qaodo.annotation.RequestDson;Q\nimport lombok.extern.slf4j.Slf4j;\nimport org.springframework.context.annotation.Configuration;\nimport org.springframework.core.MethodParameter;\nimport org.springframework.core.ReactiveAdapterRegistry;\nimport org.springframework.core.io.buffer.DataBuffer;\nimport org.springframework.core.io.buffer.DataBufferUtils;\nimport org.springframework.http.codec.DecoderHttpMessageReader;\nimport org.springframework.http.codec.HttpMessageReader;\nimport org.springframework.http.codec.json.Jackson2JsonDecoder;\nimport org.springframework.http.server.reactive.ServerHttpRequest;\nimport org.springframework.util.Assert;\nimport org.springframework.util.MultiValueMap;\nimport org.springframework.util.StringUtils;\nimport org.springframework.web.reactive.BindingContext;\nimport org.springframework.web.reactive.config.EnableWebFlux;\nimport org.springframework.web.reactive.config.WebFluxConfigurer;\nimport org.springframework.web.reactive.result.method.annotation.AbstractMessageReaderArgumentResolver;\nimport org.springframework.web.reactive.result.method.annotation.ArgumentResolverConfigurer;\nimport org.springframework.web.server.ServerWebExchange;\nimport reactor.core.publisher.Mono;\n\nimport java.io.UnsupportedEncodingException;\nimport java.net.URLDecoder;\nimport java.nio.charset.StandardCharsets;\nimport java.util.ArrayList;\nimport java.util.List;\nimport java.util.Map;\n\n\/**\n * @Author Diuut\n * @Date 2020\/4\/28 14:45\n *\/\n@Configuration\n@EnableWebFlux\n@Slf4j\npublic class WebConfig implements WebFluxConfigurer {\n\n @Override\n public void configureArgumentResolvers(ArgumentResolverConfigurer configurer) {\n List<HttpMessageReader<?>> readers = new ArrayList<HttpMessageReader<?>>();\n \/\/\u6dfb\u52a0Http\u6d88\u606f\u7f16\u89e3\u7801\u5668\n readers.add(new DecoderHttpMessageReader<>(new Jackson2JsonDecoder()));\n \/\/\u6d88\u606f\u7f16\u89e3\u7801\u5668\u4e0eResolver\u7ed1\u5b9a\n configurer.addCustomResolver(new DsonHandlerArgumentResolver(readers));\n }\n\n static class DsonHandlerArgumentResolver extends AbstractMessageReaderArgumentResolver {\n\n\n public DsonHandlerArgumentResolver(List<HttpMessageReader<?>> readers) {\n\n super(readers);\n }\n\n protected DsonHandlerArgumentResolver(List<HttpMessageReader<?>> messageReaders, ReactiveAdapterRegistry adapterRegistry) {\n super(messageReaders, adapterRegistry);\n }\n\n @Override\n public boolean supportsParameter(MethodParameter parameter) {\n boolean hasParameterAnnotation = parameter.hasParameterAnnotation(RequestDson.class);\n\/\/ log.info("supportsParameter: {}", hasParameterAnnotation);\n return hasParameterAnnotation;\/\/\u7ed1\u5b9a\u6ce8\u89e3\n }\n\n @Override\n public Mono<Object> resolveArgument(MethodParameter parameter, BindingContext bindingContext, ServerWebExchange exchange) {\n RequestDson annotation = parameter.getParameterAnnotation(RequestDson.class);\n Assert.state(annotation != null, "No KIMBody annotation");\n ServerHttpRequest request = exchange.getRequest();\n\n if ("POST".equals(request.getMethodValue())) {\n return request.getBody()\n .collectList()\n .map(list -> {\n StringBuffer str = new StringBuffer();\n for (DataBuffer buf : list) {\n str.append(buf.toString(StandardCharsets.UTF_8));\n DataBufferUtils.release(buf);\n }\n log.info("post\u8bf7\u6c42 request:{}", str);\n String decode = "";\n try {\n int flag = 5; \/\/decode\u91cd\u8bd5\u89e3\u7801\u6b21\u6570\n String decodeStr = "";\n String temp=str.toString();\n do {\n flag--;\n decodeStr=decode;\n decode = URLDecoder.decode(temp, "UTF-8");\n\/\/ log.info("post\u8bf7\u6c42 decode:{}", decode);\n temp=decode;\n if (decode.contains("+")) {\n break;\n }\n } while (!StringUtils.pathEquals(decodeStr, decode) && flag > 0);\n \/\/URLDecoder.decode\u4f1a\u5bfc\u81f4+ \u8f6c\u4e3a \u7a7a\u683c\n } catch (Exception e) {\n log.warn(str+"url\u8f6c\u7801\u5931\u8d25");\n }\n log.info("post\u8bf7\u6c42 decode:{}", decode);\n return Dson.fromString(decode);\n });\n\n } else if ("GET".equals(request.getMethodValue())) {\n MultiValueMap<String, String> queryParams = exchange.getRequest().getQueryParams();\n\/\/ log.info("queryParams:{}", queryParams);\n Map<String, String> map = queryParams.toSingleValueMap();\n log.info("get\u8bf7\u6c42 request:{}", map);\n Dson dson = null;\n for (Map.Entry<String, String> entry : map.entrySet()) {\n if (entry.getKey().startsWith("{")) {\n Dson tmp = Dson.fromMap(entry.getKey());\n if (dson == null) {\n dson = Dson.fromMap("{}");\n }\n dson.putAll(tmp._Value());\n } else if (entry.getKey().startsWith("[")) {\n Dson tmp = Dson.fromArray(entry.getKey());\n if (dson == null) {\n dson = Dson.fromArray("[]");\n }\n dson.addAll(tmp._Value());\n } else {\n if (dson == null) {\n dson = Dson.fromMap("{}");\n }\n dson.put(entry.getKey(), entry.getValue());\n }\n }\n if (dson == null) {\n dson = Dson.fromMap("{}");\n }\n return Mono.just(dson);\n }\n return null;\n }\n }\n\n}\n<\/pre><\/div>\n\n\n\u4f7f\u7528\u65b9\u6cd5\u7684\u8bdd\u540c\u5728@RequestBody\u7684\u4f4d\u7f6e\u66ff\u6362\u4e3a@RequestDson\uff0c\u5373\u53ef\u4ece\u524d\u53f0\u76f4\u63a5\u4f20Dson\u683c\u5f0f\u7684\u6570\u636e\u5230\u540e\u53f0\u4e2d\u76f4\u63a5\u4f7f\u7528\u3002 \u4ee5\u4e0a\u3002 <\/p>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u822c\u4ece\u524d\u53f0\u63a5\u6536\u5230\u7684\u53c2\u6570\u90fd\u662fJSON\u4e4b\u7c7b\u7684\u901a\u7528\u683c\u5f0f\uff0c\u6216\u8005\u901a\u8fc7@RequestBody\u81ea\u52a8\u6620\u5c04\u5b9e\u4f53\u7c7b\u3002\u4f46\u662f\u5982\u679c\u60f3\u8981