{"id":1744,"date":"2023-03-26T21:20:04","date_gmt":"2023-03-26T13:20:04","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1744"},"modified":"2023-04-23T21:29:07","modified_gmt":"2023-04-23T13:29:07","slug":"spring-cloud-gateway-global-globalfilter-get-request-parameters","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/26\/spring-cloud-gateway-global-globalfilter-get-request-parameters\/","title":{"rendered":"Spring Cloud Gateway\u5168\u5c40GlobalFilter\u83b7\u53d6\u8bf7\u6c42\u53c2\u6570"},"content":{"rendered":"<p>\u521b\u5efa\u81ea\u5b9a\u4e49\u7684<code>GlobalFilter<\/code>\u53ef\u4ee5\u5b9e\u73b0\u65e5\u5fd7\u5904\u7406\u3001\u8ba4\u8bc1\u9274\u6743\u7b49\uff0c\u7528\u6237\u53d1\u8d77Get\u3001Post\u8bf7\u6c42\uff0c\u7ecf\u8fc7\u7f51\u5173gateway\uff0cgateway\u7684<code>GlobalFilter<\/code>\u8fdb\u884c\u62e6\u622a\uff0c\u83b7\u53d6\u53c2\u6570\uff0c\u5904\u7406\u5e76\u5305\u88c5\uff0c\u8f6c\u5230\u4e0b\u4e00\u7ea7\uff0c\u8fd9\u91cc\u5c31\u6d89\u53ca\u83b7\u53d6\u8bf7\u6c42\u53c2\u6570\u7684\u95ee\u9898\u3002<\/p>\n<h2>Get\u8bf7\u6c42<\/h2>\n<p><!-- more --><\/p>\n<pre><code class=\"language-java\">@Component\npublic class AuthSignFilter implements GlobalFilter, Ordered {\n    @Override\n    public Mono&lt;Void&gt; filter(ServerWebExchange exchange, GatewayFilterChain chain) {\n        String token = exchange.getRequest().getQueryParams().getFirst(&quot;token&quot;);\n        if (token == null || token.isEmpty()) {\n            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);\n            return exchange.getResponse().setComplete();\n        }\n        return chain.filter(exchange);\n    }\n\n    @Override\n    public int getOrder() {\n        return 0;\n    }\n}<\/code><\/pre>\n<h2>Post\u8bf7\u6c42<\/h2>\n<p>Post\u8bf7\u6c42\u7684\u4f20\u53c2\u83b7\u53d6\u76f8\u5bf9\u6bd4\u8f83\u9ebb\u70e6\u4e00\u4e9b\uff0cgateway\u91c7\u7528\u4e86webflux\u7684\u65b9\u5f0f\u6765\u5c01\u88c5\u7684\u8bf7\u6c42\u4f53\u3002<\/p>\n<p>\u6211\u4eec\u77e5\u9053Post\u5e38\u7528\u7684\u4e24\u79cd\u4f20\u53c2<code>content-type<\/code>\u662f<code>application\/x-www-form-urlencoded<\/code>\u548c<code>application\/json<\/code>\uff0c\u65e0\u8bba\u662f<code>application\/x-www-form-urlencoded<\/code>\u548c<code>application\/json<\/code>\u90fd\u53ef\u4ee5\u901a\u8fc7\u5982\u4e0b\u65b9\u5f0f<\/p>\n<pre><code class=\"language-java\">import io.netty.buffer.ByteBufAllocator;\nimport org.springframework.cloud.gateway.filter.GatewayFilterChain;\nimport org.springframework.cloud.gateway.filter.GlobalFilter;\nimport org.springframework.core.Ordered;\nimport org.springframework.core.io.buffer.DataBuffer;\nimport org.springframework.core.io.buffer.DataBufferUtils;\nimport org.springframework.core.io.buffer.NettyDataBufferFactory;\nimport org.springframework.http.server.reactive.ServerHttpRequest;\nimport org.springframework.http.server.reactive.ServerHttpRequestDecorator;\nimport org.springframework.stereotype.Component;\nimport org.springframework.web.server.ServerWebExchange;\nimport reactor.core.publisher.Flux;\nimport reactor.core.publisher.Mono;\n\nimport java.net.URI;\nimport java.nio.CharBuffer;\nimport java.nio.charset.StandardCharsets;\nimport java.util.Map;\nimport java.util.concurrent.atomic.AtomicReference;\n\n@Component\npublic class AuthSignFilter implements GlobalFilter, Ordered {\n    @Override\n    public Mono&lt;Void&gt; filter(ServerWebExchange exchange, GatewayFilterChain chain) {\n        ServerHttpRequest serverHttpRequest = exchange.getRequest();\n        String method = serverHttpRequest.getMethodValue();\n        if (&quot;POST&quot;.equals(method)) {\n            \/\/\u4ece\u8bf7\u6c42\u91cc\u83b7\u53d6Post\u8bf7\u6c42\u4f53\n            String bodyStr = resolveBodyFromRequest(serverHttpRequest);\n            \/\/TODO \u5f97\u5230Post\u8bf7\u6c42\u7684\u8bf7\u6c42\u53c2\u6570\u540e\uff0c\u505a\u4f60\u60f3\u505a\u7684\u4e8b\n\n            \/\/\u4e0b\u9762\u7684\u5c06\u8bf7\u6c42\u4f53\u518d\u6b21\u5c01\u88c5\u5199\u56de\u5230request\u91cc\uff0c\u4f20\u5230\u4e0b\u4e00\u7ea7\uff0c\u5426\u5219\uff0c\u7531\u4e8e\u8bf7\u6c42\u4f53\u5df2\u88ab\u6d88\u8d39\uff0c\u540e\u7eed\u7684\u670d\u52a1\u5c06\u53d6\u4e0d\u5230\u503c\n            URI uri = serverHttpRequest.getURI();\n            ServerHttpRequest request = serverHttpRequest.mutate().uri(uri).build();\n            DataBuffer bodyDataBuffer = stringBuffer(bodyStr);\n            Flux&lt;DataBuffer&gt; bodyFlux = Flux.just(bodyDataBuffer);\n\n            request = new ServerHttpRequestDecorator(request) {\n                @Override\n                public Flux&lt;DataBuffer&gt; getBody() {\n                    return bodyFlux;\n                }\n            };\n            \/\/\u5c01\u88c5request\uff0c\u4f20\u7ed9\u4e0b\u4e00\u7ea7\n            return chain.filter(exchange.mutate().request(request).build());\n        } else if (&quot;GET&quot;.equals(method)) {\n            Map requestQueryParams = serverHttpRequest.getQueryParams();\n            \/\/TODO \u5f97\u5230Get\u8bf7\u6c42\u7684\u8bf7\u6c42\u53c2\u6570\u540e\uff0c\u505a\u4f60\u60f3\u505a\u7684\u4e8b\n\n            return chain.filter(exchange);\n        }\n        return chain.filter(exchange);\n    }\n\n    \/**\n     * \u4eceFlux&lt;DataBuffer&gt;\u4e2d\u83b7\u53d6\u5b57\u7b26\u4e32\u7684\u65b9\u6cd5\n     * @return \u8bf7\u6c42\u4f53\n     *\/\n    private String resolveBodyFromRequest(ServerHttpRequest serverHttpRequest) {\n        \/\/\u83b7\u53d6\u8bf7\u6c42\u4f53\n        Flux&lt;DataBuffer&gt; body = serverHttpRequest.getBody();\n\n        AtomicReference&lt;String&gt; bodyRef = new AtomicReference&lt;&gt;();\n        body.subscribe(buffer -&gt; {\n            CharBuffer charBuffer = StandardCharsets.UTF_8.decode(buffer.asByteBuffer());\n            DataBufferUtils.release(buffer);\n            bodyRef.set(charBuffer.toString());\n        });\n        \/\/\u83b7\u53d6request body\n        return bodyRef.get();\n    }\n\n    private DataBuffer stringBuffer(String value) {\n        byte[] bytes = value.getBytes(StandardCharsets.UTF_8);\n\n        NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(ByteBufAllocator.DEFAULT);\n        DataBuffer buffer = nettyDataBufferFactory.allocateBuffer(bytes.length);\n        buffer.write(bytes);\n        return buffer;\n    }\n\n    @Override\n    public int getOrder() {\n        return 0;\n    }\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>\u521b\u5efa\u81ea\u5b9a\u4e49\u7684GlobalFilter\u53ef\u4ee5\u5b9e\u73b0\u65e5\u5fd7\u5904\u7406\u3001\u8ba4\u8bc1\u9274\u6743\u7b49\uff0c\u7528\u6237\u53d1\u8d77Get\u3001Post\u8bf7\u6c42\uff0c\u7ecf\u8fc7\u7f51\u5173gat [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[42],"tags":[439],"class_list":["post-1744","post","type-post","status-publish","format-standard","hentry","category-spring-cloud","tag-spring-cloud-gateway"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1744","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1744"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1744\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1744"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1744"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1744"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}