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数学建模之整数规划

spring-boot - 需要知道spring-boot-starter-parent和spring-boot-parent的区别
有人可以解释一下 spring-boot-parent 和 spring-boot-starter-parent 之间的区别吗，正如我在下面附加的 GIT HUB 代码链接之一中看到的，他们为 spr
spring-boot - Spring Boot 应用程序卡在 Spring Boot Logo 上
我有与 jersey 框架集成的 Spring Boot 应用程序。现在，当我尝试运行该应用程序时，它只是停留在 Spring 启动徽标上，之后没有任何 react 。我也尝试添加 -X ，但徽标
spring-boot - Spring Boot AutoConfigure 与 Spring Boot 执行器
我指的是 Spring Boot 关于的文档自动配置和执行器模块: 自动配置: Spring Boot AutoConfiguration attempts to automatically
spring-boot - 找不到org.springframework.boot :spring-boot-starter-log4j
我正在尝试将 apache log4j 集成到我的 Spring boot 应用程序中。这是我的 build.gradle 文件: build.gradle buildscript { rep
spring-boot - Spring Boot Maven 插件 - spring-boot :run and production
使用 Spring Boot Maven 插件的以下命令在生产中启动 Spring Boot 应用程序是否是一个好主意或实践？ mvn spring-boot:run 最佳答案不，这是个坏主意。您
spring-boot - 如何隔离spring boot app redis和spring boot session global redis
据我所知，spring boot 和 spring session 为我们提供了一站式自动配置，但是当我的应用程序使用 session redis 和应用程序缓存 redis 时，不是同一个 redi
spring-boot - 适用于旧版本Java的Spring Boot
我希望使用Spring Boot创建一个新的Web应用程序。不幸的是，我的服务器在技术堆栈方面相当有限。它安装了Java 5。谁能告诉我spring boot是否可以在Java 1.5上运行以及什么
spring-boot - 使用CrudRepository中的外键进行Spring Boot
我有3个实体 CarWash(设置Wash) Wash(car_wash_id FK到CarWash) WashComment(wash_id FK到Wash) 有什么办法可以写这个查询 @Qu
spring-boot - 如何正确传播gRPC错误Spring-boot
我一直在关注this文章。我正在尝试在Spring-boot应用程序中优雅地处理gRPC错误，的主要目标是能够在gRPC客户端中获取错误状态。在上面的文章之后，我坚持为异常添加拦截器。如何在Spr
spring-boot - 自定义log4j插件和Spring Boot
我有一个要使用的自定义log4j布局插件。在IntelliJ中运行或与./gradlew bootRun一起运行时，插件可以正常工作。不使用./gradlew bootJar构建启动jar。启用-D
spring-boot - 给定范围内的随机服务器端口spring boot
我想在给定范围 (5001-5100) 的随机端口上启动 Spring Cloud 应用程序(Spring Boot 1.5.14，Spring Cloud Edgware.SR4)。我知道我们可以使
spring-boot - 如何在没有 spring boot gradle 插件的情况下在 gradle 中使用 spring boot
任何人都可以向我展示或指出不使用 spring boot gradle 插件的 spring boot gradle 项目。我正在寻找类似不使用 gradle 插件的 spring boot sta
spring-boot - spring-boot-starter-web 和 spring-boot-starter-webflux 的区别？
我当时尝试包含上述依赖项之一，但找不到任何区别: spring boot starter web:我可以看到 Flux 和 Mono 类并制作一个响应式(Reactive)休息 Controller
spring-boot - Spring Boot 1.X 和 Spring Boot 2.0 的区别
我们一直在为我们的应用程序使用 Springboot 1.X。现在准备开始一些新的应用程序，想知道我们是应该使用 SpringBoot2.0 还是坚持使用 SpringBoot 1.X？对一种方式
spring-boot - Spring Boot : When application. 属性和 application.yml 由 spring boot 应用程序加载
我希望记录应用程序正在加载 application-profile.propeties 或 application.yml。怎么做。在哪种方法中，我可以听取它并检测它是成功加载还是失败。最佳答案您
spring-boot - Spring Boot : error when add spring-boot-starter-data-jpa dependency
当我在 pom.xml 中添加简单的 spring-boot-starter-data-jpa 依赖项时，在 pom.xml 文件中出现错误。如果我删除该依赖项，则不会再有错误。我不确定为什么会发生这
spring-boot - Spring Boot : When application. 属性和 application.yml 由 spring boot 应用程序加载
我希望记录应用程序正在加载 application-profile.propeties 或 application.yml。怎么做。在哪种方法中，我可以听取它并检测它是成功加载还是失败。最佳答案您
spring-boot - Spring Boot Devtools 重启不会自动与 Spring Boot 1.5.4 一起使用
我在网上看了很多关于 spring-boot-devtools 的文章和问题，但仍然无法弄清楚为什么它对我不起作用。每次运行我的应用程序时，我都会得到以下信息: 17:54:28.057 [main]
spring-boot - Spring Boot 在使用 solrj 而不是 spring-boot-starter-data-solr 时爆炸
我正在尝试将现有的 Spring 应用程序移植到 Spring Boot。我不使用 spring-boot-starter-data-solr 启动器，但是我的类路径上有 apache solrj (
spring-boot - 为什么 Spring Boot 1.4 改变了它的 jar 布局来定位 BOOT-INF 下的应用程序类？
(这主要是一个历史问题。Pivotal 建议所有论坛讨论都在 StackOverflow 上进行，这就是我在这里问它的原因。) Spring Boot 项目用来证明将应用程序的类和依赖项从可执行 ja

qq735679552

个人简介

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

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城