解决——》feign文件下载时报错feign.codec.EncodeException: not in non blocking mode

淩亂°似流年 2024-04-01 16:59 53阅读 0赞

> 推荐链接：  
> [总结——》【Java】][Java]  
> [总结——》【Mysql】][Mysql]  
> [总结——》【Spring】][Spring]  
> [总结——》【SpringBoot】][SpringBoot]  
> [总结——》【MyBatis、MyBatis-Plus】][MyBatis_MyBatis-Plus]

#### 解决——》feign文件下载时报错feign.codec.EncodeException: not in non blocking mode ####

*  1、操作
 *  2、现象
 *  3、原因
 *  4、解决

## 1、操作 ##

feign文件下载

## 2、现象 ##

报异常`feign.codec.EncodeException: not in non blocking mode`

2022-11-10 09:30:05.200 ERROR [10.122.143.9] [http-nio-8882-exec-2] [house-platform-api-0a7a8f09-463345-253] com.eju.houseparent.config.starter.BaseControllerHandler.handleException [line=143 ] : handleException ex uri:/tmall/cityopen/syncEsfCommunity/logList/downloadError/1667895255597,param:{
        }
    2022-11-10 09:30:05.200 ERROR [10.122.143.9] [http-nio-8882-exec-2] [house-platform-api-0a7a8f09-463345-253] com.eju.houseparent.config.starter.BaseControllerHandler.handleException [line=144 ] : handleException ex class:class feign.codec.EncodeException,ex:not in non blocking mode.
    2022-11-10 09:30:05.201 ERROR [10.122.143.9] [http-nio-8882-exec-2] [house-platform-api-0a7a8f09-463345-253] com.eju.houseparent.config.starter.BaseControllerHandler.handleException [line=145 ] : 系统正在维护中，请稍候再试
    feign.codec.EncodeException: not in non blocking mode.
            at feign.ReflectiveFeign$BuildEncodedTemplateFromArgs.resolve(ReflectiveFeign.java:384)
            at feign.ReflectiveFeign$BuildTemplateByResolvingArgs.create(ReflectiveFeign.java:232)
            at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:84)
            at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:100)
            at com.sun.proxy.$Proxy305.downloadErrorLogListByBatchNo(Unknown Source)
            at com.ejudata.platform.controller.TmallCityOpenController.downloadErrorLogListByBatchNo$original$DkyYi2Ll(TmallCityOpenController.java:70)
            at com.ejudata.platform.controller.TmallCityOpenController.downloadErrorLogListByBatchNo$original$DkyYi2Ll$accessor$nvaSjmiZ(TmallCityOpenController.java)
            at com.ejudata.platform.controller.TmallCityOpenController$auxiliary$m4Yk46Iz.call(Unknown Source)
            at org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstMethodsInter.intercept(InstMethodsInter.java:86)
            at com.ejudata.platform.controller.TmallCityOpenController.downloadErrorLogListByBatchNo(TmallCityOpenController.java)

## 3、原因 ##

服务消费者，需要设置方法返回值为`Response`

## 4、解决 ##

`将服务提供者的文件下载响应的响应体(文件内容)复制到服务消费者对外的文件下载响应体中`

@FeignClient(value = "${feign.client.config.good-house-push.name}", url = "${feign.client.config.good-house-push.url}", path = "${feign.client.inner.path}", configuration = CatFeignConfiguration.class)
    public interface ITmallSyncEsfCommunityApi{
        
    
        @ApiOperation("根据批次号，下载同步二手房小区的错误日志列表")
        @GetMapping({
        "/api/tmall/syncEsfCommunity/logList/downloadError/{batchNo}"})
        Response downloadErrorLogListByBatchNo(@PathVariable(name = "batchNo") String batchNo);
    }

@ApiOperation(value = "根据批次号，下载同步二手房小区的错误日志列表")
        @GetMapping("/cityopen/syncEsfCommunity/logList/downloadError/{batchNo}")
        void downloadErrorLogListByBatchNo(@PathVariable(name = "batchNo") String batchNo, HttpServletResponse response) {
        
    
            InputStream inputStream = null;
            try {
        
                Response serviceResponse = tmallSyncEsfCommunityApi.downloadErrorLogListByBatchNo(batchNo);
                Response.Body body = serviceResponse.body();
                inputStream = body.asInputStream();
                BufferedInputStream bufferedInputStream = new BufferedInputStream(inputStream);
                response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
                response.setCharacterEncoding("utf-8");
                response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + batchNo + ".xlsx");
                BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(response.getOutputStream());
                int length = 0;
                byte[] temp = new byte[1024 * 10];
                while ((length = bufferedInputStream.read(temp)) != -1) {
        
                    bufferedOutputStream.write(temp, 0, length);
                }
                bufferedOutputStream.flush();
                bufferedOutputStream.close();
                bufferedInputStream.close();
                inputStream.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }

[Java]: https://blog.csdn.net/weixin_43453386/article/details/84788317
[Mysql]: https://blog.csdn.net/weixin_43453386/article/details/88667709
[Spring]: https://blog.csdn.net/weixin_43453386/article/details/124900806
[SpringBoot]: https://blog.csdn.net/weixin_43453386/article/details/84788714
[MyBatis_MyBatis-Plus]: https://blog.csdn.net/weixin_43453386/article/details/84788053