Spring Cloud Gateway 優(yōu)雅修改請求與響應(yīng)報(bào)文

修改請求報(bào)文螟蝙、響應(yīng)報(bào)文是API網(wǎng)關(guān)框架的基礎(chǔ)功能，然而在Spring Cloud Gateway中修改報(bào)文體似乎并不是一件容易的事在塔，本文以3.0.3版本為例胳搞，講講在Spring Cloud Gateway如何優(yōu)雅的修改請求報(bào)文、響應(yīng)報(bào)文姥闪。

一始苇、官方方法

在Spring Cloud Gateway官方文檔中，有如下方法筐喳，可供參考：

1.1 修改請求報(bào)文

@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
    return builder.routes()
        .route("rewrite_request_obj", r -> r.host("*.rewriterequestobj.org")
            .filters(f -> f.prefixPath("/httpbin")
                .modifyRequestBody(String.class, Hello.class, MediaType.APPLICATION_JSON_VALUE,
                    (exchange, s) -> return Mono.just(new Hello(s.toUpperCase())))).uri(uri))
        .build();
}

static class Hello {
    String message;

    public Hello() { }

    public Hello(String message) {
        this.message = message;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }
}

1.2 修改響應(yīng)報(bào)文

@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
    return builder.routes()
        .route("rewrite_response_upper", r -> r.host("*.rewriteresponseupper.org")
            .filters(f -> f.prefixPath("/httpbin")
                .modifyResponseBody(String.class, String.class,
                    (exchange, s) -> Mono.just(s.toUpperCase()))).uri(uri))
        .build();
}

當(dāng)然催式，這種方式有其局限性：

只能寫死在生成Route的地方，一旦API變多避归，或者是動態(tài)路由荣月，不太優(yōu)雅
無法在自定義的Global Filter、Gateway Filter中直接調(diào)用

二梳毙、優(yōu)雅實(shí)現(xiàn)

一開始哺窄，當(dāng)我接觸Spring Cloud Gateway時(shí)，想自己通過實(shí)現(xiàn)Global Filter實(shí)現(xiàn)修改請求報(bào)文、響應(yīng)報(bào)文萌业，摸不著頭腦坷襟。一個(gè)看似很簡單的問題，在zuul1中只需要修改兩下變量咽白，就可以輕松改掉啤握。換了異步非阻塞的Spring Cloud Gateway，仿若掉入了天坑晶框，想修改一次排抬，沒有100行代碼，辦不了這個(gè)事情授段。

看互聯(lián)網(wǎng)上有很多文章蹲蒲，代碼不僅冗余、復(fù)雜侵贵、不夠優(yōu)雅届搁、易讀性差，還不能夠支持HTTP 1.1窍育、Gzip卡睦，總給人一種hacky實(shí)現(xiàn)的感覺。這就讓我頓時(shí)疑惑了起來漱抓，一個(gè)堂堂的Gateway網(wǎng)關(guān)表锻，修改請求報(bào)文、響應(yīng)報(bào)文居然要這么麻煩乞娄。

后來瞬逊，隨著閱讀官方文檔、官方源碼的不斷深入仪或，我理解了其實(shí)Spring Cloud Gateway的初衷确镊，似乎并不是想做一個(gè)網(wǎng)關(guān)“框架”，而更像是做一個(gè)開箱即用的網(wǎng)關(guān)應(yīng)用程序范删，任何網(wǎng)關(guān)相關(guān)的參數(shù)蕾域，均可通過參數(shù)配置實(shí)現(xiàn)，無需自行編碼瓶逃，或者使用輕量級的函數(shù)式編程語句束铭。確實(shí)，這很好厢绝，對于微服務(wù)網(wǎng)關(guān)契沫，足夠了。但是昔汉，如果要深度定制網(wǎng)關(guān)的功能懈万，就會感到十分為難拴清，一個(gè)封裝十足徹底的工具，要想不動引用包源碼的情況下会通，從外層修改它口予，猶如把一個(gè)豪華法拉利改裝成特斯拉，使用網(wǎng)上的hacky辦法涕侈，總給人一種沪停，里外里套了兩層的感覺。

2.1 實(shí)現(xiàn)原理

為了解決不夠優(yōu)雅的問題裳涛，通過借鑒Spring Cloud Gateway 如下類的原生的rewrite方法木张，重新實(shí)現(xiàn)Config的響應(yīng)式參數(shù)傳遞，從而實(shí)現(xiàn)在Filter中修改請求報(bào)文端三、響應(yīng)報(bào)文的函數(shù)式編程舷礼，一勞永逸。

org.springframework.cloud.gateway.filter.factory.rewrite.ModifyRequestBodyGatewayFilterFactory

org.springframework.cloud.gateway.filter.factory.rewrite.ModifyResponseBodyGatewayFilterFactory

通過該方式實(shí)現(xiàn)修改body體郊闯，相較于網(wǎng)絡(luò)上的通用方法妻献，好處如下：

代碼統(tǒng)一封裝，不用牽一發(fā)動全身团赁；
函數(shù)式編程育拨，實(shí)現(xiàn)優(yōu)雅；
支持gzip欢摄、chunked等HTTP特性至朗；
請求、響應(yīng)的修改剧浸，都還在Filter中修改；

值得注意的是矗钟，需要對Mono或Flux的異常進(jìn)行捕獲唆香，捕獲方式不一定是try catch的方式，而是.just(xxx).doOnError()

2.2 基礎(chǔ)封裝

在工程中吨艇，創(chuàng)建3個(gè)類躬它，放到基礎(chǔ)目錄下，用于調(diào)用东涡，如果Spring Cloud Gateway更新了請求冯吓、響應(yīng)相關(guān)的代碼，只需更新如下代碼即可疮跑。

RewriteConfig.java

import org.springframework.cloud.gateway.filter.factory.rewrite.RewriteFunction;

import java.util.Map;

public class RewriteConfig {

    private Class inClass;

    private Class outClass;

    private Map<String, Object> inHints;

    private Map<String, Object> outHints;

    private String newContentType;

    private String contentType;

    private RewriteFunction rewriteFunction;

    public Class getInClass() {
        return inClass;
    }

    public RewriteConfig setInClass(Class inClass) {
        this.inClass = inClass;
        return this;
    }

    public Class getOutClass() {
        return outClass;
    }

    public RewriteConfig setOutClass(Class outClass) {
        this.outClass = outClass;
        return this;
    }

    public Map<String, Object> getInHints() {
        return inHints;
    }

    public RewriteConfig setInHints(Map<String, Object> inHints) {
        this.inHints = inHints;
        return this;
    }

    public Map<String, Object> getOutHints() {
        return outHints;
    }

    public RewriteConfig setOutHints(Map<String, Object> outHints) {
        this.outHints = outHints;
        return this;
    }

    public String getNewContentType() {
        return newContentType;
    }

    public RewriteConfig setNewContentType(String newContentType) {
        this.newContentType = newContentType;
        return this;
    }

    public RewriteFunction getRewriteFunction() {
        return rewriteFunction;
    }

    public RewriteConfig setRewriteFunction(RewriteFunction rewriteFunction) {
        this.rewriteFunction = rewriteFunction;
        return this;
    }

    public <T, R> RewriteConfig setRewriteFunction(Class<T> inClass, Class<R> outClass,
                                            RewriteFunction<T, R> rewriteFunction) {
        setInClass(inClass);
        setOutClass(outClass);
        setRewriteFunction(rewriteFunction);
        return this;
    }

    public String getContentType() {
        return "application/json;charset=utf-8";
    }

    public RewriteConfig setContentType(String contentType) {
        this.contentType = contentType;
        return this;
    }
}

ModifiedRequestDecorator.java

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.factory.rewrite.CachedBodyOutputMessage;
import org.springframework.cloud.gateway.support.BodyInserterContext;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpHeaders;
import org.springframework.http.codec.HttpMessageReader;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
import org.springframework.web.reactive.function.BodyInserter;
import org.springframework.web.reactive.function.BodyInserters;
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;

import java.util.List;
import java.util.function.Function;

public class ModifiedRequestDecorator {

    private final List<HttpMessageReader<?>> messageReaders = HandlerStrategies.withDefaults().messageReaders();
    private final RewriteConfig config;

    public ModifiedRequestDecorator(ServerWebExchange exchange, RewriteConfig config) {
        this.config = config;
    }

    @SuppressWarnings("unchecked")
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        Class inClass = config.getInClass();
        ServerRequest serverRequest = ServerRequest.create(exchange, messageReaders);

        // TODO: flux or mono
        Mono<?> modifiedBody = serverRequest.bodyToMono(inClass)
                .flatMap(originalBody -> config.getRewriteFunction().apply(exchange, originalBody))
                .switchIfEmpty(Mono.defer(() -> (Mono) config.getRewriteFunction().apply(exchange, null)));

        BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, config.getOutClass());
        HttpHeaders headers = new HttpHeaders();
        headers.putAll(exchange.getRequest().getHeaders());

        // the new content type will be computed by bodyInserter
        // and then set in the request decorator
        headers.remove(HttpHeaders.CONTENT_LENGTH);

        // if the body is changing content types, set it here, to the bodyInserter
        // will know about it
        if (config.getContentType() != null) {
            headers.set(HttpHeaders.CONTENT_TYPE, config.getContentType());
        }
        CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, headers);
        return bodyInserter.insert(outputMessage, new BodyInserterContext())
                // .log("modify_request", Level.INFO)
                .then(Mono.defer(() -> {
                    ServerHttpRequest decorator = decorate(exchange, headers, outputMessage);
                    return chain.filter(exchange.mutate().request(decorator).build());
                })).onErrorResume((Function<Throwable, Mono<Void>>) throwable -> release(exchange,
                        outputMessage, throwable));

    }


    protected Mono<Void> release(ServerWebExchange exchange, CachedBodyOutputMessage outputMessage,
                                 Throwable throwable) {
        return outputMessage.getBody().map(DataBufferUtils::release).then(Mono.error(throwable));
    }

    ServerHttpRequestDecorator decorate(ServerWebExchange exchange, HttpHeaders headers,
                                        CachedBodyOutputMessage outputMessage) {
        return new ServerHttpRequestDecorator(exchange.getRequest()) {
            @Override
            public HttpHeaders getHeaders() {
                long contentLength = headers.getContentLength();
                HttpHeaders httpHeaders = new HttpHeaders();
                httpHeaders.putAll(headers);
                if (contentLength > 0) {
                    httpHeaders.setContentLength(contentLength);
                }
                else {
                    // TODO: this causes a 'HTTP/1.1 411 Length Required' // on
                    // httpbin.org
                    httpHeaders.set(HttpHeaders.TRANSFER_ENCODING, "chunked");
                }
                return httpHeaders;
            }

            @Override
            public Flux<DataBuffer> getBody() {
                return outputMessage.getBody();
            }
        };
    }
}

ModifiedResponseDecorator.java

import org.reactivestreams.Publisher;
import org.springframework.cloud.gateway.filter.factory.rewrite.CachedBodyOutputMessage;
import org.springframework.cloud.gateway.filter.factory.rewrite.GzipMessageBodyResolver;
import org.springframework.cloud.gateway.filter.factory.rewrite.MessageBodyDecoder;
import org.springframework.cloud.gateway.filter.factory.rewrite.MessageBodyEncoder;
import org.springframework.cloud.gateway.support.BodyInserterContext;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferFactory;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpHeaders;
import org.springframework.http.codec.HttpMessageReader;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.http.server.reactive.ServerHttpResponseDecorator;
import org.springframework.web.reactive.function.BodyInserter;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.reactive.function.server.HandlerStrategies;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;

import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import static java.util.function.Function.identity;

import static org.springframework.cloud.gateway.support.ServerWebExchangeUtils.ORIGINAL_RESPONSE_CONTENT_TYPE_ATTR;
public class ModifiedResponseDecorator extends ServerHttpResponseDecorator {

    private final ServerWebExchange exchange;

    private final RewriteConfig config;

    private final Map<String, MessageBodyDecoder> messageBodyDecoders ;
    private final Map<String, MessageBodyEncoder> messageBodyEncoders;

    private final List<HttpMessageReader<?>> messageReaders = HandlerStrategies.withDefaults().messageReaders();


    public ModifiedResponseDecorator(ServerWebExchange exchange, RewriteConfig config) {
        super(exchange.getResponse());
        this.exchange = exchange;
        this.config = config;
        Set<MessageBodyDecoder> messageBodyDecodersSet = new HashSet<>();
        Set<MessageBodyEncoder> messageBodyEncodersSet = new HashSet<>();
        MessageBodyDecoder messageBodyDecoder = new GzipMessageBodyResolver();
        MessageBodyEncoder messageBodyEncoder = new GzipMessageBodyResolver();
        messageBodyDecodersSet.add(messageBodyDecoder);
        messageBodyEncodersSet.add(messageBodyEncoder);
        this.messageBodyDecoders = messageBodyDecodersSet.stream()
                .collect(Collectors.toMap(MessageBodyDecoder::encodingType, identity()));
        this.messageBodyEncoders = messageBodyEncodersSet.stream()
                .collect(Collectors.toMap(MessageBodyEncoder::encodingType, identity()));
    }


    @SuppressWarnings("unchecked")
    @Override
    public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {

        Class inClass = config.getInClass();
        Class outClass = config.getOutClass();

        String originalResponseContentType = exchange.getAttribute(ORIGINAL_RESPONSE_CONTENT_TYPE_ATTR);
        HttpHeaders httpHeaders = new HttpHeaders();
        // explicitly add it in this way instead of
        // 'httpHeaders.setContentType(originalResponseContentType)'
        // this will prevent exception in case of using non-standard media
        // types like "Content-Type: image"
        httpHeaders.add(HttpHeaders.CONTENT_TYPE, originalResponseContentType);

        ClientResponse clientResponse = prepareClientResponse(body, httpHeaders);

        // TODO: flux or mono
        Mono modifiedBody = extractBody(exchange, clientResponse, inClass)
                .flatMap(originalBody -> config.getRewriteFunction().apply(exchange, originalBody))
                .switchIfEmpty(Mono.defer(() -> (Mono) config.getRewriteFunction().apply(exchange, null)));

        BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, outClass);
        CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange,
                exchange.getResponse().getHeaders());
        return bodyInserter.insert(outputMessage, new BodyInserterContext()).then(Mono.defer(() -> {
            Mono<DataBuffer> messageBody = writeBody(getDelegate(), outputMessage, outClass);
            HttpHeaders headers = getDelegate().getHeaders();
            if (!headers.containsKey(HttpHeaders.TRANSFER_ENCODING)
                    || headers.containsKey(HttpHeaders.CONTENT_LENGTH)) {
                messageBody = messageBody.doOnNext(data -> headers.setContentLength(data.readableByteCount()));
            }
            // TODO: fail if isStreamingMediaType?
            return getDelegate().writeWith(messageBody);
        }));
    }

    @Override
    public Mono<Void> writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body) {
        return writeWith(Flux.from(body).flatMapSequential(p -> p));
    }

    private ClientResponse prepareClientResponse(Publisher<? extends DataBuffer> body, HttpHeaders httpHeaders) {
        ClientResponse.Builder builder;
        builder = ClientResponse.create(exchange.getResponse().getStatusCode(), messageReaders);
        return builder.headers(headers -> headers.putAll(httpHeaders)).body(Flux.from(body)).build();
    }

    private <T> Mono<T> extractBody(ServerWebExchange exchange, ClientResponse clientResponse, Class<T> inClass) {
        // if inClass is byte[] then just return body, otherwise check if
        // decoding required
        if (byte[].class.isAssignableFrom(inClass)) {
            return clientResponse.bodyToMono(inClass);
        }

        List<String> encodingHeaders = exchange.getResponse().getHeaders().getOrEmpty(HttpHeaders.CONTENT_ENCODING);
        for (String encoding : encodingHeaders) {
            MessageBodyDecoder decoder = messageBodyDecoders.get(encoding);
            if (decoder != null) {
                return clientResponse.bodyToMono(byte[].class).publishOn(Schedulers.parallel()).map(decoder::decode)
                        .map(bytes -> exchange.getResponse().bufferFactory().wrap(bytes))
                        .map(buffer -> prepareClientResponse(Mono.just(buffer),
                                exchange.getResponse().getHeaders()))
                        .flatMap(response -> response.bodyToMono(inClass));
            }
        }

        return clientResponse.bodyToMono(inClass);
    }

    private Mono<DataBuffer> writeBody(ServerHttpResponse httpResponse, CachedBodyOutputMessage message,
                                       Class<?> outClass) {
        Mono<DataBuffer> response = DataBufferUtils.join(message.getBody());
        if (byte[].class.isAssignableFrom(outClass)) {
            return response;
        }

        List<String> encodingHeaders = httpResponse.getHeaders().getOrEmpty(HttpHeaders.CONTENT_ENCODING);
        for (String encoding : encodingHeaders) {
            MessageBodyEncoder encoder = messageBodyEncoders.get(encoding);
            if (encoder != null) {
                DataBufferFactory dataBufferFactory = httpResponse.bufferFactory();
                response = response.publishOn(Schedulers.parallel()).map(buffer -> {
                    byte[] encodedResponse = encoder.encode(buffer);
                    DataBufferUtils.release(buffer);
                    return encodedResponse;
                }).map(dataBufferFactory::wrap);
                break;
            }
        }
        return response;
    }

}

修改請求

filter()方法返回參考代碼

            // 修改請求內(nèi)容
            return new ModifiedRequestDecorator(exchange, new RewriteConfig()
                    .setRewriteFunction(String.class, String.class, (ex, requestData)
                    ->  Mono.just(要修改請求內(nèi)容的方法(requestData))
            )).filter(exchange, chain);

修改響應(yīng)

filter()方法返回參考代碼

    // 修改響應(yīng)內(nèi)容
    return chain.filter(exchange.mutate().response(
        new ModifiedResponseDecorator(exchange, new RewriteConfig().
        setRewriteFunction(String.class, String.class, (ex, responseData)
        ->  Mono.just(要修改響應(yīng)內(nèi)容的方法(responseData))
        ))).build());

修改請求组贺、響應(yīng)

filter()方法返回參考代碼

            // 修改請求內(nèi)容
            return new ModifiedRequestDecorator(exchange, new RewriteConfig()
                    .setRewriteFunction(String.class, String.class, (ex, requestData)
                    ->  Mono.just(要修改請求內(nèi)容的方法(requestData))
            )).filter(exchange.mutate().response(
            // 修改響應(yīng)內(nèi)容
                    new ModifiedResponseDecorator(exchange, new RewriteConfig().
                            setRewriteFunction(String.class, String.class, (ex, responseData)
                    ->  Mono.just(要修改響應(yīng)內(nèi)容的方法(responseData))
                ))).build(),chain);

最后編輯于：2021.08.19 17:16:39

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者

人面猴
序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市祖娘，隨后出現(xiàn)的幾起案子失尖，更是在濱河造成了極大的恐慌，老刑警劉巖，帶你破解...
沈念sama閱讀 207,248評論 6贊 481
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件掀潮，死亡現(xiàn)場離奇詭異菇夸，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)仪吧，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 88,681評論 2贊 381
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門庄新，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人薯鼠，你說我怎么就攤上這事择诈。” “怎么了人断？”我有些...
開封第一講書人閱讀 153,443評論 0贊 344
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵吭从，是天一觀的道長。經(jīng)常有香客問我恶迈，道長涩金，這世上最難降的妖魔是什么？我笑而不...
開封第一講書人閱讀 55,475評論 1贊 279
?港島之戀（遺憾婚禮）
正文為了忘掉前任暇仲，我火速辦了婚禮步做，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘奈附。我一直安慰自己全度，他們只是感情好，可當(dāng)我...
茶點(diǎn)故事閱讀 64,458評論 5贊 374
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布斥滤。她就那樣靜靜地躺著将鸵，像睡著了一般。火紅的嫁衣襯著肌膚如雪佑颇。梳的紋絲不亂的頭發(fā)上顶掉，一...
開封第一講書人閱讀 49,185評論 1贊 284
城市分裂傳說
那天，我揣著相機(jī)與錄音痒筒，去河邊找鬼。笑死茬贵，一個(gè)胖子當(dāng)著我的面吹牛，可吹牛的內(nèi)容都是我干的解藻。我是一名探鬼主播老充，決...
沈念sama閱讀 38,451評論 3贊 401
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼螟左，長吁一口氣：“原來是場噩夢啊……” “哼蚂维！你這毒婦竟也來了戳粒？” 一聲冷哼從身側(cè)響起，我...
開封第一講書人閱讀 37,112評論 0贊 261
萬榮殺人案實(shí)錄
序言：老撾萬榮一對情侶失蹤虫啥，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后涂籽，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體苹祟，經(jīng)...
沈念sama閱讀 43,609評論 1贊 300
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡评雌，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 36,083評論 2贊 325
?白月光啟示錄
正文我和宋清朗相戀三年树枫，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片景东。...
茶點(diǎn)故事閱讀 38,163評論 1贊 334
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡砂轻，死狀恐怖斤吐，靈堂內(nèi)的尸體忽然破棺而出搔涝，到底是詐尸還是另有隱情，我是刑警寧澤庄呈，帶...
沈念sama閱讀 33,803評論 4贊 323
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布，位于F島的核電站派阱，受9級特大地震影響，放射性物質(zhì)發(fā)生泄漏贫母。R本人自食惡果不足惜，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 39,357評論 3贊 307
男人毒藥：我在死后第九天來索命
文/蒙蒙一腺劣、第九天我趴在偏房一處隱蔽的房頂上張望彩届。院中可真熱鬧誓酒，春花似錦、人聲如沸贮聂。這莊子的主人今日做“春日...
開封第一講書人閱讀 30,357評論 0贊 19
一樁弒父案吓懈，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽歼冰。三九已至耻警，卻和暖如春隔嫡，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背腮恩。一陣腳步聲響...
開封第一講書人閱讀 31,590評論 1贊 261
情欲美人皮
我被黑心中介騙來泰國打工梢杭，沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留秸滴，地道東北人武契。一個(gè)月前我還...
沈念sama閱讀 45,636評論 2贊 355
代替公主和親
正文我出身青樓荡含，卻偏偏與公主長得像咒唆，于是被迫代替她去往敵國和親。傳聞我的和親對象是個(gè)殘疾皇子全释，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 42,925評論 2贊 344

Spring Cloud Gateway 優(yōu)雅修改請求與響應(yīng)報(bào)文

一始苇、官方方法

1.1 修改請求報(bào)文

1.2 修改響應(yīng)報(bào)文

二梳毙、優(yōu)雅實(shí)現(xiàn)

2.1 實(shí)現(xiàn)原理

2.2 基礎(chǔ)封裝

RewriteConfig.java

ModifiedRequestDecorator.java

ModifiedResponseDecorator.java

修改請求

修改響應(yīng)

修改請求组贺、響應(yīng)

推薦閱讀更多精彩內(nèi)容