好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

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

Spring Boot FeignClient 捕获业务异常信息

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

1.全局异常处理

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

import com.bossien测试数据mon测试数据m.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

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

import com.alibaba.fastjson.JSONObject;

import com.ocean测试数据mon测试数据m.entity.ResponseDto;

import com.ocean测试数据mon.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接口

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

package com.bossien.usercenter.user.feign;

import com.bossien测试数据mon测试数据m.entity.ResponseDto;

import com.bossien测试数据mon测试数据m.util.PageModel;

import com.bossien测试数据mon测试数据m.constant.SearchEntity;

import com.bossien测试数据mon.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

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

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加入到容器中

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

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

?

1

2

3

4

5

6

7

8

9

@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 如何捕获业务异常信息的详细内容...

  阅读:20次