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

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-02http://-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);

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。