Spring Boot FeignClient 如何捕获业务异常信息-6ren

Spring Boot FeignClient 如何捕获业务异常信息

转载作者：qq735679552 更新时间：2022-09-29 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Spring Boot FeignClient 如何捕获业务异常信息由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

Spring Boot FeignClient 捕获业务异常信息

因项目重构采用spring cloud，feign不可避免。目前spring cloud在国内还不是很成熟，所以踩坑是免不了的。最近处理全局异常的问题，搜了个遍也没找到合适的解决方案。

1.全局异常处理

 
    ? 
   
         import 
         com.bossien.common.comm.entity.ResponseDto; 
        
         import 
         org.slf4j.Logger; 
        
         import 
         org.slf4j.LoggerFactory; 
        
         import 
         org.springframework.web.bind.annotation.ControllerAdvice; 
        
         import 
         org.springframework.web.bind.annotation.ExceptionHandler; 
        
         import 
         org.springframework.web.bind.annotation.ResponseBody; 
        
         @ControllerAdvice 
        
         public 
         class 
         GlobalExceptionHandler { 
        
         private 
         static 
         final 
         Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler. 
         class 
         ); 
        
         /** 
        
         * @Author: lixg 
        
         * @Description: 系统异常捕获处理 
        
         */ 
        
         @ResponseBody 
        
         @ExceptionHandler 
         (value = Exception. 
         class 
         ) 
        
         public 
         ResponseDto errorExceptionHandler(Exception ex) { 
         //APIResponse是项目中对外统一的出口封装，可以根据自身项目的需求做相应更改 
        
         logger.error( 
         "捕获到 Exception 异常" 
         , ex); 
        
         //异常日志入库 
        
         return 
         new 
         ResponseDto(ResponseDto.RESPONSE_FAIL,  
         "系统繁忙,请稍后再试" 
         ); 
        
         } 
        
         /** 
        
         * @Author: lixg 
        
         * @Description: 自定义异常捕获处理 
        
         */ 
        
         @ResponseBody 
        
         @ExceptionHandler 
         (value = BusinessException. 
         class 
         ) 
         //BusinessException是自定义的一个异常 
        
         public 
         ResponseDto businessExceptionHandler(BusinessException ex) { 
        
         logger.error( 
         "捕获到 BusinessException 异常: code=" 
         + ex.getCode() +  
         " , errorMessage=" 
         + ex.getErrorMessage()); 
        
         return 
         new 
         ResponseDto(ex.getCode(), ex.getErrorMessage()); 
        
         } 
        
         }

2.请求参数解析handler

 
    ? 
   
         import 
         com.alibaba.fastjson.JSONObject; 
        
         import 
         com.ocean.common.comm.entity.ResponseDto; 
        
         import 
         com.ocean.common.core.exception.BusinessException; 
        
         import 
         org.slf4j.Logger; 
        
         import 
         org.slf4j.LoggerFactory; 
        
         /*** 
        
         * @author lixg 
        
         * 
        
         * feign请求响应对象处理 
        
         */ 
        
         public 
         class 
         ResponseHandler { 
        
         private 
         final 
         static 
         Logger logger = LoggerFactory.getLogger(ResponseHandler. 
         class 
         ); 
        
         /** 
        
         * 解析请求响应对象 
        
         * @param responseDto 
        
         * @param clazz 
        
         * @return 
        
         * @throws BusinessException 
        
         */ 
        
         public 
         static 
         Object getResponseData(ResponseDto responseDto, Class clazz)  
         throws 
         BusinessException { 
        
         if 
         (EmptyUtil.isEmpty(responseDto)){ 
        
         throw 
         new 
         BusinessException(BusinessException.OBJECT_IS_NULL, 
         "请求响应为空！" 
         ); 
        
         } 
        
         if 
         (ResponseDto.RESPONSE_SUCCESS.equals(responseDto.getCode())){ 
        
         try 
         { 
        
         String json = JSONObject.toJSONString(responseDto.getData()); 
        
         return 
         JSONObject.parseObject(json, clazz); 
        
         } 
         catch 
         (Exception e){ 
        
         logger.error( 
         "响应对象转换异常：" 
         +clazz.getName(),e); 
        
         throw 
         new 
         BusinessException(BusinessException.OBJECT_IS_NULL, 
         "响应对象转换失败！" 
         ); 
        
         } 
        
         } 
         else 
         { 
        
         throw 
         new 
         BusinessException(responseDto.getCode(),responseDto.getMessage()); 
        
         } 
        
         } 
        
         }

3.业务feign接口

 
    ? 
   
         package 
         com.bossien.usercenter.user.feign; 
        
         import 
         com.bossien.common.comm.entity.ResponseDto; 
        
         import 
         com.bossien.common.comm.util.PageModel; 
        
         import 
         com.bossien.common.comm.constant.SearchEntity; 
        
         import 
         com.bossien.common.core.exception.BusinessException; 
        
         import 
         com.bossien.usercenter.user.entity.User; 
        
         import 
         org.springframework.cloud.openfeign.FeignClient; 
        
         import 
         org.springframework.stereotype.Repository; 
        
         import 
         org.springframework.web.bind.annotation.RequestBody; 
        
         import 
         org.springframework.web.bind.annotation.RequestMapping; 
        
         import 
         org.springframework.web.bind.annotation.RequestMethod; 
        
         import 
         org.springframework.web.bind.annotation.RequestParam; 
        
         import 
         java.util.List; 
        
         import 
         java.util.Map; 
        
         @FeignClient 
         (value= 
         "bossien-usercenter-service" 
         ,path =  
         "/userFeign" 
         ) 
        
         @Repository 
        
         public 
         interface 
         UserFeign { 
        
         @RequestMapping 
         (value =  
         "getUserInfo" 
         ,method = RequestMethod.GET) 
        
         User getUserInfo( 
         @RequestParam 
         ( 
         "userId" 
         ) Long userId); 
        
         @RequestMapping 
         (value =  
         "getUserInfoByTicket" 
         ,method = RequestMethod.GET) 
        
         ResponseDto getUserInfoByTicket( 
         @RequestParam 
         ( 
         "ticket" 
         ) String ticket)  
         throws 
         BusinessException;  
        
         }

总结：

@controllerAdvice或者HandlerExceptionResolver是不能直接捕获到FeignException,所以需要在Feign层面拿到具体异常重新封装。最后总算把cloud service内部的异常安全(一样的错误码、一样的错误信息)送给了client!.

Feign调用异常处理

consumer服务调用Producer服务接口时，提示一下异常。

no suitable HttpMessageConverter found for request type 。

 
    ? 
   
 
     
       
       
         feign.codec.EncodeException: Could not write request: no suitable HttpMessageConverter found  
         for 
         request type [com.xxx.pojo.Xxx] and content type [application/x-www-form-urlencoded] 
        
 
           
         at org.springframework.cloud.openfeign.support.SpringEncoder.encode(SpringEncoder.java: 
         143 
         ) ~[spring-cloud-openfeign-core- 
         2.1 
         . 
         0 
         .RELEASE.jar: 
         2.1 
         . 
         0 
         .RELEASE] 
        
 
           
         at feign.ReflectiveFeign$BuildEncodedTemplateFromArgs.resolve(ReflectiveFeign.java: 
         372 
         ) ~[feign-core- 
         10.1 
         . 
         0 
         .jar:na] 
        
 
           
         at feign.ReflectiveFeign$BuildTemplateByResolvingArgs.create(ReflectiveFeign.java: 
         224 
         ) ~[feign-core- 
         10.1 
         . 
         0 
         .jar:na] 
        
 
           
         at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java: 
         74 
         ) ~[feign-core- 
         10.1 
         . 
         0 
         .jar:na] 
        
 
           
         at feign.hystrix.HystrixInvocationHandler$ 
         1 
         .run(HystrixInvocationHandler.java: 
         106 
         ) ~[feign-hystrix- 
         10.1 
         . 
         0 
         .jar:na] 
        
 
           
         at com.netflix.hystrix.HystrixCommand$ 
         2 
         .call(HystrixCommand.java: 
         302 
         ) ~[hystrix-core- 
         1.5 
         . 
         18 
         .jar: 
         1.5 
         . 
         18 
         ] 
        
 
           
         at com.netflix.hystrix.HystrixCommand$ 
         2 
         .call(HystrixCommand.java: 
         298 
         ) ~[hystrix-core- 
         1.5 
         . 
         18 
         .jar: 
         1.5 
         . 
         18 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java: 
         46 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java: 
         35 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         48 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         30 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         48 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         30 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         48 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         30 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.Observable.unsafeSubscribe(Observable.java: 
         10151 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java: 
         51 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java: 
         35 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.Observable.unsafeSubscribe(Observable.java: 
         10151 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java: 
         41 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java: 
         30 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         48 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java: 
         30 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.Observable.unsafeSubscribe(Observable.java: 
         10151 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at rx.internal.operators.OperatorSubscribeOn$ 
         1 
         .call(OperatorSubscribeOn.java: 
         94 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$ 
         1 
         .call(HystrixContexSchedulerAction.java: 
         56 
         ) ~[hystrix-core- 
         1.5 
         . 
         18 
         .jar: 
         1.5 
         . 
         18 
         ] 
        
 
           
         at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$ 
         1 
         .call(HystrixContexSchedulerAction.java: 
         47 
         ) ~[hystrix-core- 
         1.5 
         . 
         18 
         .jar: 
         1.5 
         . 
         18 
         ] 
        
 
           
         at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction.call(HystrixContexSchedulerAction.java: 
         69 
         ) ~[hystrix-core- 
         1.5 
         . 
         18 
         .jar: 
         1.5 
         . 
         18 
         ] 
        
 
           
         at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java: 
         55 
         ) ~[rxjava- 
         1.2 
         . 
         0 
         .jar: 
         1.2 
         . 
         0 
         ] 
        
 
           
         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java: 
         511 
         ) ~[na: 
         1.8 
         .0_221] 
        
 
           
         at java.util.concurrent.FutureTask.run(FutureTask.java: 
         266 
         ) ~[na: 
         1.8 
         .0_221] 
        
 
           
         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java: 
         1149 
         ) ~[na: 
         1.8 
         .0_221] 
        
 
           
         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java: 
         624 
         ) ~[na: 
         1.8 
         .0_221] 
        
 
           
         at java.lang.Thread.run(Thread.java: 
         748 
         ) [na: 
         1.8 
         .0_221] 
        
 
     
 
   

异常原因

如字面意思:

at org.springframework.cloud.openfeign.support.SpringEncoder.encode 。

缺少HttpMessageConverter 的编码器。

解决方法

缺少那就加进去。

将SpringFormEncoder加入到容器中。

 
    ? 
   
         import 
         feign.codec.Encoder; 
        
         import 
         feign.form.spring.SpringFormEncoder; 
        
         import 
         org.springframework.context.annotation.Bean; 
        
         import 
         org.springframework.context.annotation.Configuration; 
        
         import 
         org.springframework.context.annotation.Primary; 
        
         import 
         org.springframework.context.annotation.Scope; 
        
         /** 
        
         * @author jianming 
        
         * @create 2021-02-06-15:42 
        
         */ 
        
         @Configuration 
        
         public 
         class 
         FeignSupportConfig { 
        
         @Bean 
        
         @Primary 
        
         @Scope 
         ( 
         "prototype" 
         ) 
        
         public 
         Encoder multipartFormEncoder() { 
        
         return 
         new 
         SpringFormEncoder(); 
        
         } 
        
         }

问题处理完成。

Consumer的Feign使用

处理需要上述的编码器，还需在接口中指定ContentType 。

 
    ? 
   
         @Service 
        
         @FeignClient 
         (value =  
         "XXX-XXX" 
         ) 
        
         public 
         interface 
         LoginService { 
        
         /** 
        
         * 指定contentType 
        
         */ 
        
         @PostMapping 
         (value =  
         "/register" 
         , consumes = MediaType.APPLICATION_FORM_URLENCODED_VALUE) 
        
         public 
         MsgUtils create(User user); 
        
         }

Producer正常编写即可！以上为个人经验，希望能给大家一个参考，也希望大家多多支持我.

原文链接：https://blog.csdn.net/qq_36988277/article/details/90214665 。

最后此篇关于Spring Boot FeignClient 如何捕获业务异常信息的文章就讲到这里了,如果你想了解更多关于Spring Boot FeignClient 如何捕获业务异常信息的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐：企业网站如何优化要解决的问题

文章推荐：浅谈Python数学建模之固定费用问题

文章推荐：百度SEO和谷歌SEO的区别

文章推荐：浅谈Python数学建模之整数规划

database - 代理与自然/业务 key
关闭。这个问题是opinion-based 。目前不接受答案。想要改进这个问题吗？更新问题，以便 editing this post 可以用事实和引文来回答它。 . 已关闭 9 年前。 Improv
events - 记录*业务*事件 - 使用日志框架？
我在这里感觉有些不对劲，所以我希望社区提供意见 - 也许我以错误的方式处理这个问题...... 问:是否适合使用传统的基础架构日志框架(如 log4net)来记录业务事件？当我说业务事件时，我的意思
理解「业务」与「技术」概念
技术也好，业务也罢； 01 【什么是业务？】对于那些久经职场的人，也很难一句话说明白；业务，作为工作中绝对的核心点，即便在一个公司待的足够久，
设计「业务」与「技术」方案
三天研发，两天设计； 01 【优先做设计方案】职场中的那些魔幻操作，研发最烦的是哪个？作为一个数年且资深的互联网普通开发，可以来说明一下为什么
java - 业务、系统、接口(interface)、持久性类是什么意思？
业务、系统、接口(interface)、持久化类是什么意思？用一些例子解释一下？最佳答案业务可能是应用程序中所有功能部分发生的部分(即计算或规则) 系统是您的操作系统接口(interface)，
python - Facebook 业务 SDK : cannot create an Ad
我无法创建带有指向移动应用的外部链接的简单广告。我已正确设置访问权限，可以创建广告系列、广告集、加载图像，但在创建广告期间出现错误: Ads and ad creatives must be asso
algorithm - 组织贸易事件 ||业务 "speed dating"算法
我是软件工程专业的学生，现在我正在为我的期末项目工作，安排在交易日进行商务配对。这个想法是将卖家(开发人员)和买家(有经济能力的人)在一起。算法应该像“快速约会”。假设我有 15 张 table
aws-cloudformation - Whatsapp 业务 API HTTPS 证书
我们只需按照以下说明在 AWS Cloudformation 上部署企业 WhatsApp API: AWS WhatsApp API 所以一切正常，部署正确完成，问题出在“SSL 配置”选项上，我们
ios - 应用程序因准则 3.2 被拒绝 - 业务，下一步该怎么做？
我的应用因为以下原因被拒绝了 Guideline 3.2 - Business We found that your app is not appropriate for the App Store
php - 使用 WhatsApp 发送但未使用 WhatsApp 业务 API 发送给收件人的消息
您好，我想在我的网络应用程序中使用 WhatsApp 业务 API。我已经在 postman 中测试过了。每当在 WhatsApp 选项卡下的 Facebook 业务页面中运行示例 curl 代码时
audio - Skype 业务 2015 : Audio/Video not working in meetings
我是 Skype for Business 技术的新手，我正在尝试部署一个我愿意与 Skype WebSDK 和 AppSDK 一起使用的服务器。起初我尝试使用Skype进行在线商务，但websdk
ios - Apple 开发人员拒绝 - 在应用程序中使用订阅 - 业务 - 3.1.1
Apple 开发人员以此为由拒绝了我的应用。 “业务 - 3.1.1您的应用程序包含一个帐户注册功能，该功能被视为对外部机制的访问，以便在应用程序中使用购买或订阅。此功能不符合 App Store 审
android - 如何使用 Realm "live"对象并保持数据库层与其他层(业务、UI 等)解耦？
我正在玩 Realm for Android。我喜欢自动更新对象的想法，但我对它的软件架构有顾虑。我已经看到许多提议的架构都指定了一个层来处理数据/数据库访问，理想情况下，更高层不会知道有关数据库
ios - 自动续订购买的应用程序拒绝 - 准则 3.1.2 - 业务 - 付款 - 订阅
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。这个问题似乎与 help center 中定义的范围内的编程无关。 . 关闭 10 个月前。 Impro
facebook - 如何解决 Whatsapp 业务 Api 初始设置中服务 "image"中缺少 "wacore"选项的强制值？
我正在尝试设置 Whatsapp 业务 API。引用Link用于设置。我正在使用 Windows 10 操作系统。 -- 仅供引用。在初始设置部分，使用命令 docker-compose up
php - Facebook 业务 PHP SDK : Cannot access an object not managed by the business owning this app
我正在尝试使用 Facebook Business SDK 创建一个 facebook Adaccount .但是当我使用方法 createAdAccount 时，它会给我一个错误。请参阅下面的图片。
mono - 是否可以在 OSX(通过 Mono)上使用 Razor 作为独立库(没有任何 asp.net 业务)
我想写一个概念证明 MonoMac使用 c# 和 Razor 呈现 html“ View ”的应用程序。这可能吗？如果没有，是否有人推荐与 Razor 的简单性相比的任何其他模板引擎。如果必须的话
android studio 3.0 : Could not resolve project :fun:push. 要求:项目:业务:日记
无法解析 ':business:diary@debug/compileClasspath': Could not resolve project :fun:push. 的依赖关系无法解析项目:fun
c# - "Why can' t 我编辑这个文件？这个项目需要一个 Xamarin 业务......”当打开某些与 Xamarin 无关的 XML 时
当我尝试在 Visual Studio Professional 2015 14.0.23107.0 中打开某些 XML 文件时，XML 编辑器出现白屏并显示以下文本: 为什么我不能编辑这个文件？此项

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城