Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

I get error when read cached resposne in spring cloud gateway #3282

Closed
mehrdadbozorgmehr opened this issue Feb 27, 2024 · 0 comments
Closed

Comments

@mehrdadbozorgmehr
Copy link

mehrdadbozorgmehr commented Feb 27, 2024

I got this error when read from cached response

at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:108)
at org.springframework.http.HttpHeaders.setContentLength(HttpHeaders.java:963)
at org.springframework.http.codec.EncoderHttpMessageWriter.lambda$write$1(EncoderHttpMessageWriter.java:135)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:132)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74)
at reactor.core.publisher.Operators$MonoInnerProducerBase.complete(Operators.java:2842)
at reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:180)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2573)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnRequest(MonoSingle.java:103)
at reactor.core.publisher.Operators$MonoInnerProducerBase.request(Operators.java:2909)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241)
at reactor.core.publisher.MonoSingle$SingleSubscriber.onSubscribe(MonoSingle.java:115)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:96)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55)
at reactor.core.publisher.FluxFromMonoOperator.subscribe(FluxFromMonoOperator.java:85)
at reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:57)
at reactor.core.publisher.Mono.subscribe(Mono.java:4512)
at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:202)
at reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53)
at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:63)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:158)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:297)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:478)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:470)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55)
at reactor.core.publisher.MonoZip$ZipCoordinator.request(MonoZip.java:220)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onSubscribe(FluxOnErrorResume.java:74)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:129)
at reactor.core.publisher.Mono.subscribe(Mono.java:4512)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:280)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onError(FluxDoFinally.java:119)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:2236)
at reactor.core.publisher.Operators.error(Operators.java:198)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:49)
at reactor.core.publisher.Mono.subscribe(Mono.java:4512)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:250)
at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:324)
at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299)
at org.springframework.http.server.reactive.ChannelSendOperator$WriteCompletionBarrier.onComplete(ChannelSendOperator.java:423)

	this my code :
	`    @Override
public GatewayFilter apply(Config config) {
    return new OrderedGatewayFilter((exchange, chain) -> {
        if (!config.isEnabled()) {
            return chain.filter(exchange);
        }
        String key = getKey(config, exchange);
        return redisOperations.opsForValue().get(key)
                .flatMap(cacheResponseDTO -> {
                    Gson gson = new Gson();
                    if (!ObjectUtils.isEmpty(cacheResponseDTO)) {
                        final ServerHttpResponse serverHttpResponse = exchange.getResponse();
                        serverHttpResponse.setStatusCode(HttpStatusCode.valueOf(cacheResponseDTO.getHttpStatus()));
                        serverHttpResponse.beforeCommit(() -> {
                            HttpHeaders deserializedHeaders = gson.fromJson(cacheResponseDTO.getHeaders(), HttpHeaders.class);
                            serverHttpResponse.getHeaders().setAll(deserializedHeaders.toSingleValueMap());

                            return Mono.empty();
                        });
                        final DataBuffer buffer = serverHttpResponse.bufferFactory().wrap(cacheResponseDTO.getBody());
                        return serverHttpResponse.writeWith(Flux.just(buffer));
                    } else {
                        exchange.getResponse().getHeaders().add("X-Cache-Status", "MISS");
                        ServerHttpResponse decoratedResponse = getDecoratedResponse(key, exchange, config);
                        return chain.filter(exchange.mutate().response(decoratedResponse).build());
                    }
                })
                .switchIfEmpty(Mono.defer(() -> {
                    exchange.getResponse().getHeaders().add("X-Cache-Status", "MISS");
                    ServerHttpResponse decoratedResponse = getDecoratedResponse(key, exchange, config);
                    return chain.filter(exchange.mutate().response(decoratedResponse).build());
                }));
    }, NettyWriteResponseFilter.WRITE_RESPONSE_FILTER_ORDER - 1);`
@mehrdadbozorgmehr mehrdadbozorgmehr changed the title I gett error when read cached resposne I gett error when read cached resposne in spring cloud gateway Feb 27, 2024
@mehrdadbozorgmehr mehrdadbozorgmehr changed the title I gett error when read cached resposne in spring cloud gateway I get error when read cached resposne in spring cloud gateway Feb 27, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant