解決Spring Cloud Gateway獲取body內(nèi)容,不影響GET請求的操作
廢話
這幾天換了新工作,需要重新開發(fā)一套系統(tǒng),技術選用Spring Cloud。在對接終端接口的時候要做驗簽,就涉及到在網(wǎng)關做攔截器,然后取出BODY里面的數(shù)據(jù)。
網(wǎng)上找了幾個方法,有的拿不到數(shù)據(jù),有的拿到數(shù)據(jù)之后不支持GET請求了。沒有一個合理的解決辦法,最后想到在動態(tài)路由構建的時候可以指定METHOD,于是有了如下解決辦法
解決
@Bean
public RouteLocator vmRouteLocator(RouteLocatorBuilder builder) {
return builder.routes()
.route(r -> r.method(HttpMethod.POST).and()
.readBody(Object.class, requestBody -> {
//相當于緩存了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();
}
關鍵代碼:
r.method(HttpMethod.POST)
r.method(HttpMethod.GET)
分別指定了不同請求METHOD對應的路由策略
在POST請求中需要緩存BODY信息,在Filter中便可以獲取到
GET請求因為沒有BODY,所以如果不指定GET的路由便會報錯
可能會有更通用的方法,但是目前只想到這么多,以后有好的解決辦法會繼續(xù)更新
補充知識:Spring Cloud Gateway 2.x 獲取body中的數(shù)據(jù)并緩存在請求中
場景
因為http請求中的body,讀取過一次后就無法重新再讀,但是我們希望網(wǎng)關項目中可以在所有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
@Slf4j
public 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屬性中,這樣就可以在本次請求中的所有地方進行使用了
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)容了,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
springboot+mybatis-plus實現(xiàn)內(nèi)置的CRUD使用詳解
這篇文章主要介紹了springboot+mybatis-plus實現(xiàn)內(nèi)置的CRUD使用詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
Java實現(xiàn)經(jīng)典游戲飛機大戰(zhàn)-I的示例代碼
《飛機大戰(zhàn)-I》是一款融合了街機、競技等多種元素的經(jīng)典射擊手游。本文將利用java語言實現(xiàn)這游戲,文中采用了swing技術進行了界面化處理,感興趣的可以了解一下2022-02-02
解決springboot讀取application.properties中文亂碼問題
初用properties,讀取java properties文件的時候如果value是中文,會出現(xiàn)亂碼的問題,所以本文小編將給大家介紹如何解決springboot讀取application.properties中文亂碼問題,需要的朋友可以參考下2023-11-11
如何自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題)
MyBatis-Plus默認生成的是 64bit 長整型,而 JS 的 Number 類型精度最高只有 53bit,這篇文章主要介紹了如何自定義Mybatis-Plus分布式ID生成器(解決ID長度超過JavaScript整數(shù)安全范圍問題),需要的朋友可以參考下2024-08-08
Hadoop+HBase+ZooKeeper分布式集群環(huán)境搭建步驟
這篇文章主要介紹了Hadoop+HBase+ZooKeeper分布式集群環(huán)境搭建,集群環(huán)境至少需要3個節(jié)點,1個Master,2個Slave,節(jié)點之間局域網(wǎng)連接,可以相互ping通,本文通過實例給大家介紹的非常詳細,需要的朋友可以參考下2022-04-04
hibernate-validator后端表單數(shù)據(jù)校驗的使用示例詳解
這篇文章主要介紹了hibernate-validator后端表單數(shù)據(jù)校驗的使用,hibernate-validator提供的校驗方式為在類的屬性上加入相應的注解來達到校驗的目的,本文結(jié)合示例代碼給大家介紹的非常詳細,需要的朋友可以參考下2022-08-08
Java多線程編程實戰(zhàn)之模擬大量數(shù)據(jù)同步
這篇文章主要介紹了Java多線程編程實戰(zhàn)之模擬大量數(shù)據(jù)同步,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2019-02-02
mybatisPlus如何使用MetaObjectHandler對字段進行更新
這篇文章主要介紹了mybatisPlus如何使用MetaObjectHandler對字段進行更新問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-04-04
Java 指定微信好友自動發(fā)送消息的實現(xiàn)示例
這篇文章主要介紹了Java 指定微信好友自動發(fā)送消息的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-10-10

