廢話

這幾天換了新工作，需要重新開發(fā)一套系統(tǒng)，技術(shù)選用Spring Cloud。在對接終端接口的時候要做驗簽，就涉及到在網(wǎng)關(guān)做攔截器，然后取出BODY里面的數(shù)據(jù)。

網(wǎng)上找了幾個方法，有的拿不到數(shù)據(jù)，有的拿到數(shù)據(jù)之后不支持GET請求了。沒有一個合理的解決辦法，最后想到在動態(tài)路由構(gòu)建的時候可以指定METHOD，于是有了如下解決辦法

解決

@Bean public RouteLocator vmRouteLocator(RouteLocatorBuilder builder) { return builder.routes().route(r -> r.method(HttpMethod.POST).and() .readBody(Object.class, requestBody -> { //相當(dāng)于緩存了body信息，在filter 中可以這么獲取 exchange.getAttribute('cachedRequestBodyObject'); log.info('requestBody is {}', requestBody); return true; }) .and().path('/terminal/**') .filters(f -> f.filter(terminalSignFilter())) .uri('lb://TERMINAL-SERVICE') .order(0) .id('terminal-service')).route(r -> r.method(HttpMethod.GET).and() .path('/terminal/**') .filters(f -> f.filter(terminalSignFilter())) .uri('lb://TERMINAL-SERVICE') .order(1) .id('terminal-service')).build(); }

關(guān)鍵代碼：

r.method(HttpMethod.POST)

r.method(HttpMethod.GET)

分別指定了不同請求METHOD對應(yīng)的路由策略

在POST請求中需要緩存BODY信息，在Filter中便可以獲取到

GET請求因為沒有BODY，所以如果不指定GET的路由便會報錯

可能會有更通用的方法，但是目前只想到這么多，以后有好的解決辦法會繼續(xù)更新

補(bǔ)充知識：Spring Cloud Gateway 2.x 獲取body中的數(shù)據(jù)并緩存在請求中

場景

因為http請求中的body,讀取過一次后就無法重新再讀,但是我們希望網(wǎng)關(guān)項目中可以在所有filter中共享body中的內(nèi)容。

寫法

import lombok.extern.slf4j.Slf4j;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.DataBufferUtils;import org.springframework.http.server.reactive.ServerHttpRequest;import org.springframework.http.server.reactive.ServerHttpRequestDecorator;import org.springframework.stereotype.Component;import org.springframework.web.reactive.function.server.HandlerStrategies;import org.springframework.web.reactive.function.server.ServerRequest;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Flux;import reactor.core.publisher.Mono;@Component@Slf4jpublic class CacheBodyParamsFilter implements GlobalFilter, Ordered { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { if (ParamsUtil.logBody(exchange)) { return DataBufferUtils.join(exchange.getRequest().getBody()) .flatMap(dataBuffer -> { byte[] bytes = new byte[dataBuffer.readableByteCount()]; dataBuffer.read(bytes); DataBufferUtils.release(dataBuffer); Flux<DataBuffer> cachedFlux = Flux.defer(() -> { DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bytes); DataBufferUtils.retain(buffer); return Mono.just(buffer); }); ServerHttpRequest mutatedRequest = new ServerHttpRequestDecorator(exchange.getRequest()) { @Override public Flux<DataBuffer> getBody() {return cachedFlux; } }; ServerWebExchange mutatedExchange = exchange.mutate().request(mutatedRequest).build(); return ServerRequest.create(mutatedExchange, HandlerStrategies.withDefaults().messageReaders()).bodyToMono(String.class).doOnNext(objectValue -> { //在此處,將body中的params值獲取到,并存放在本次請求的attributes屬性中,這樣就可以在本次請求中的所有地方進(jìn)行使用了mutatedExchange.getAttributes().put(CommonConstant.PARAMS, ParamsUtil.buildParams(mutatedRequest,objectValue)); }).then(chain.filter(mutatedExchange)); }); } return chain.filter(exchange); } @Override public int getOrder() { return Ordered.HIGHEST_PRECEDENCE; }}

以上這篇解決Spring Cloud Gateway獲取body內(nèi)容,不影響GET請求的操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持好吧啦網(wǎng)。