jeecg-boot clound 3.5.0 版本网关全局过滤器 response body 读取乱码问题

版本号：

jeecg-boot clound 3.5.0

前端版本：vue3版？还是 vue2版？

问题描述：

jeecg-boot clound 3.5.0 版本网关全局过滤器 response body 读取乱码问题【list.add(new String(content, "utf-8")); 尝试过gbk Unicode 等均乱码】，尝试试过自己写的服务读取body数据正常。而且仅开了JeecgSystemCloudApplicants 。测试的接口是获取验证码的接口。 http://localhost:9999/sys/randomImage/1629428467008?_t=1678679615058； http://localhost:7001/sys/randomImage/1629428467008?_t=1678679615058；网关没有加过滤器，访问该接口正常。加了过滤器，只要尝试修改body内容，接口还回就异常。

截图&代码：

Copyright (c) 2018-2028, DreamLu All rights reserved.
Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are met:
Redistributions of source code must retain the above copyright notice,
this list of conditions and the following disclaimer.
Redistributions in binary form must reproduce the above copyright
notice, this list of conditions and the following disclaimer in the
documentation and/or other materials provided with the distribution.
Neither the name of the dreamlu.net developer nor the names of its
contributors may be used to endorse or promote products derived from
this software without specific prior written permission.
Author: DreamLu 卢春梦 (596392912@qq.com) */ package org.jeecg.filter;

import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.base.Joiner; import com.google.common.base.Throwables; import com.google.common.collect.Lists; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.reactivestreams.Publisher; import org.springframework.boot.actuate.autoconfigure.endpoint.web.WebEndpointProperties; import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.cloud.gateway.filter.GlobalFilter; import org.springframework.context.annotation.Configuration; import org.springframework.core.Ordered; 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.HttpStatus; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.http.server.reactive.ServerHttpResponse; import org.springframework.http.server.reactive.ServerHttpResponseDecorator; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono;

import java.nio.charset.Charset; import java.util.List;

/**

webflux 相应日志，方便开发调试，注意排序要优先。

@author dream.lu */ @Slf4j @Configuration @RequiredArgsConstructor public class GlobalResponseLogFilter implements GlobalFilter, Ordered { private final WebEndpointProperties endpointProperties; private final ObjectMapper objectMapper; private static Joiner joiner = Joiner.on("");

@Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {

ServerHttpResponse originalResponse = exchange.getResponse();
originalResponse.getHeaders().add("Content-Type", "text/plain;charset=UTF-8");
DataBufferFactory bufferFactory = originalResponse.bufferFactory();
ServerHttpResponseDecorator response = new ServerHttpResponseDecorator(originalResponse) {
    @Override
    public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
        if (getStatusCode().equals(HttpStatus.OK) && body instanceof Flux) {
            // 获取ContentType，判断是否返回JSON格式数据
            String originalResponseContentType = exchange.getAttribute("original_response_content_type");
            if (StringUtils.isNotBlank(originalResponseContentType) && originalResponseContentType.contains("application/json")) {
                Flux<? extends DataBuffer> fluxBody = Flux.from(body);
                //（返回数据内如果字符串过大，默认会切割）解决返回体分段传输
                return super.writeWith(fluxBody.buffer().map(dataBuffers -> {
                    List<String> list = Lists.newArrayList();
                    dataBuffers.forEach(dataBuffer -> {
                        try {
                            byte[] content = new byte[dataBuffer.readableByteCount()];
                            dataBuffer.read(content);
                            DataBufferUtils.release(dataBuffer);
                            list.add(new String(content, "utf-8"));
                        } catch (Exception e) {
                            log.info("加载Response字节流异常，失败原因：{}", Throwables.getStackTraceAsString(e));
                        }
                    });
                    String responseData = joiner.join(list);

                    System.out.println("responseData："+responseData);

                    byte[] uppedContent = new String(responseData.getBytes(), Charset.forName("UTF-8")).getBytes();
                    originalResponse.getHeaders().setContentLength(uppedContent.length);
                    return bufferFactory.wrap(uppedContent);
                }));
            }
        }
        return super.writeWith(Flux.from(body));
    }

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

}

@Override public int getOrder() { return Ordered.HIGHEST_PRECEDENCE; } }

友情提示（为了提高issue处理效率）：

未按格式要求发帖，会被直接删掉;
描述过于简单或模糊，导致无法处理的，会被直接删掉；
请自己初判问题描述是否清楚，是否方便我们调查处理；
针对问题请说明是Online在线功能(需说明用的主题模板)，还是生成的代码功能；

jeecgboot / JeecgBoot