当前位置:首页 > 服务端 > 关于feign调用的异常

关于feign调用的异常

2022年11月09日 22:14:52服务端6

Feign声明式调用服务 feign.codec.DecodeException: Error while extracting response for type [class **] and...

日前在做项目时候遇到feign调用出现返回乱码,导致程序出错事件。原因是因为cloud的依赖版本过低,feign不支持 gzip 解码。在不升级jar的情况下,增加了一个过滤器。 

 

代码如下:

public class FeignResponseDecoder implements Decoder {
    private final Decoder delegate;

    public FeignResponseDecoder(Decoder delegate) {
        Objects.requireNonNull(delegate, "Decoder must not be null. ");
        this.delegate = delegate;
    }

    @Override
    public Object decode(Response response, Type type) throws IOException {
        Collection<String> values = response.headers().get(HttpEncoding.CONTENT_ENCODING_HEADER);
        if (Objects.nonNull(values) && !values.isEmpty() && values.contains(HttpEncoding.GZIP_ENCODING)) {
            byte[] compressed = Util.toByteArray(response.body().asInputStream());
            if ((compressed == null) || (compressed.length == 0)) {
                return delegate.decode(response, type);
            }
            //decompression part
            //after decompress we are delegating the decompressed response to default
            //decoder
            if (isCompressed(compressed)) {
                final StringBuilder output = new StringBuilder();
                final GZIPInputStream gis = new GZIPInputStream(new ByteArrayInputStream(compressed));
                final BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(gis, StandardCharsets.UTF_8));
                String line;
                while ((line = bufferedReader.readLine()) != null) {
                    output.append(line);
                }
                Response uncompressedResponse = response.toBuilder().body(output.toString().getBytes()).build();
                return delegate.decode(uncompressedResponse, type);
            } else {
                return delegate.decode(response, type);
            }
        } else {
            return delegate.decode(response, type);
        }
    }

    private static boolean isCompressed(final byte[] compressed) {
        return (compressed[0] == (byte) (GZIPInputStream.GZIP_MAGIC)) && (compressed[1] == (byte) (GZIPInputStream.GZIP_MAGIC >> 8));
    }
}

  

 

再把这个类,以bean的方式注入即可:

@Bean
public Decoder GZIPResponseDecoder(ObjectFactory<HttpMessageConverters> messageConverters) {
Decoder decoder = new FeignResponseDecoder(new SpringDecoder(messageConverters));
return decoder;
}

作者:码代码的小表哥
来源链接:https://www.cnblogs.com/woshuaile/p/14754978.html

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/69222.html

标签: Feign异常
分享给朋友:

“关于feign调用的异常” 的相关文章

Spring Cloud Feign 如何使用对象参数

概述Spring Cloud Feign 用于微服务的封装,通过接口代理的实现方式让微服务调用变得简单,让微服务的使用上如同本地服务。但是它在传参方面不是很完美。在使用 Feign 代理 GET 请求时,对于简单参数(基本类型、包装器、字符串)的使用上没有困难,但是在使用对象传参时却无法自动的将对象...

Android程序报IOException和ConnectException

写的是Android程序作为客户端访问Java Web应用程序, android应用程序是用通过URL,HttpPost request = new HttpPost(url) ; HttpResponse response=DefaultHttpCli...

after : """>【异常】Maxwell异常 Exception in thread "main" net.sf.jsqlparser.parser.TokenMgrError: Lexical error at line 1, column 596. Encountered: after : ""

1 详细异常 Exception in thread "main" net.sf.jsqlparser.parser.TokenMgrError: Lexical error at line 1, column 596. Encountered: <EOF>...

关于Java中Error和Exception的区别

  做个比喻:   Error和Exception的区别就是水池和水池里的水的区别;   水池,是代码正常运行的外部环境,如果水池奔溃(系统奔溃),或者池水满溢(内存溢出),这些跟水池外部环境有关的是Error;   水池里的水,是正常运行的代码,水污染了,有杂质了,...

Exception in thread "main" java.lang.Error: Unresolved compilation problem:

package cn.itcast.day1; //import static java.lang.Math.max; //import static java.lang.Math.*; public class StaticImport { public sta...

【Android】安卓运行问题

【Android】安卓运行问题

问题一:Could not resolve all artifacts for configuration ‘:fluwx:classpath’ A problem occurred configuring project ':fluwx'....

error和exception有什么区别?

Error(错误)表示系统级的错误和程序不必处理的异常,是java运行环境中的内部错误或者硬件问题。比如:内存资源不足等。对于这种错误,程序基本无能为力,除了退出运行外别无选择,它是由Java虚拟机抛出的。Exception(违例)表示需要捕捉或者需要程序进行处理的异常,它处理的是因为...

Caused by: java.lang.IllegalStateException: RedisConnectionFactory is required

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'redisTemplate' defined in class path resource [com/zhan...

throw exception和 try catch的区别

1. 区别: throw exception直接终止方法,或者退出循环。 try catch还要继续处理方法余下的逻辑,或者不结束循环。 try catch 不中断,throw exception中断 2.代码 (1)try ca...

Android 11推荐使用Handler的构造方法

Android 11推荐使用Handler的构造方法

背景 Android 11(即API 30:Android R)弃用了Handler默认的无参构造方法 参考链接:Android 开发者文档指南-Handler 源代码(android.os.Handler)...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。