电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Spring Boot FeignClient 如何捕獲業務異常信息

瀏覽:45日期:2023-07-05 10:19:01
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;@ControllerAdvicepublic 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')@Repositorypublic 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 */@Configurationpublic 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正常編寫即可!以上為個人經驗,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 活性炭-果壳木质煤质柱状粉状蜂窝活性炭厂家价格多少钱 | Q361F全焊接球阀,200X减压稳压阀,ZJHP气动单座调节阀-上海戎钛 | 酒糟烘干机-豆渣烘干机-薯渣烘干机-糟渣烘干设备厂家-焦作市真节能环保设备科技有限公司 | 水篦子|雨篦子|镀锌格栅雨水篦子|不锈钢排水篦子|地下车库水箅子—安平县云航丝网制品厂 | 气动机械手-搬运机械手-气动助力机械手-山东精瑞自动化设备有限公司 | 公交驾校-北京公交驾校欢迎您! 工作心得_读书心得_学习心得_找心得体会范文就上学道文库 | 江苏大隆凯科技有限公司 | 聚天冬氨酸,亚氨基二琥珀酸四钠,PASP,IDS - 远联化工 | 软文发布平台 - 云软媒网络软文直编发布营销推广平台 | 冲锋衣滑雪服厂家-冲锋衣定制工厂-滑雪服加工厂-广东睿牛户外(S-GERT) | 定制防伪标签_防伪标签印刷_防伪标签厂家-510品保防伪网 | 通用磨耗试验机-QUV耐候试验机|久宏实业百科 | 河南不锈钢水箱_地埋水箱_镀锌板水箱_消防水箱厂家-河南联固供水设备有限公司 | 洗砂机械-球磨制砂机-洗沙制砂机械设备_青州冠诚重工机械有限公司 | 搪玻璃冷凝器_厂家-越宏化工设备| MES系统-WMS系统-MES定制开发-制造执行MES解决方案-罗浮云计算 | 济南网站建设_济南网站制作_济南网站设计_济南网站建设公司_富库网络旗下模易宝_模板建站 | 彼得逊采泥器-定深式采泥器-电动土壤采样器-土壤样品风干机-常州索奥仪器制造有限公司 | 长江船运_国内海运_内贸船运_大件海运|运输_船舶运输价格_钢材船运_内河运输_风电甲板船_游艇运输_航运货代电话_上海交航船运 | PCB接线端子_栅板式端子_线路板连接器_端子排生产厂家-置恒电气 喷码机,激光喷码打码机,鸡蛋打码机,手持打码机,自动喷码机,一物一码防伪溯源-恒欣瑞达有限公司 假肢-假肢价格-假肢厂家-河南假肢-郑州市力康假肢矫形器有限公司 | T恤衫定做,企业文化衫制作订做,广告T恤POLO衫定制厂家[源头工厂]-【汉诚T恤定制网】 | 999范文网_优质范文下载写作帮手| 合肥角钢_合肥槽钢_安徽镀锌管厂家-昆瑟商贸有限公司 | 环氧树脂地坪_防静电地坪漆_环氧地坪漆涂料厂家-地壹涂料地坪漆 环球电气之家-中国专业电气电子产品行业服务网站! | 工装定制/做厂家/公司_工装订做/制价格/费用-北京圣达信工装 | 首页 - 军军小站|张军博客| 20年条刷老厂-条刷-抛光-工业毛刷辊-惠众毛刷| 螺杆泵_中成泵业 | 无线讲解器-导游讲解器-自助讲解器-分区讲解系统 品牌生产厂家[鹰米讲解-合肥市徽马信息科技有限公司] | 煤机配件厂家_刮板机配件_链轮轴组_河南双志机械设备有限公司 | 骨密度检测仪_骨密度分析仪_骨密度仪_动脉硬化检测仪专业生产厂家【品源医疗】 | 发电机组|柴油发电机组-批发,上柴,玉柴,潍柴,康明斯柴油发电机厂家直销 | 仓储货架_南京货架_钢制托盘_仓储笼_隔离网_环球零件盒_诺力液压车_货架-南京一品仓储设备制造公司 | 新型游乐设备,360大摆锤游乐设备「诚信厂家」-山东方鑫游乐设备 新能源汽车电池软连接,铜铝复合膜柔性连接,电力母排-容发智能科技(无锡)有限公司 | 气弹簧定制-气动杆-可控气弹簧-不锈钢阻尼器-工业气弹簧-可调节气弹簧厂家-常州巨腾气弹簧供应商 | 水厂自动化|污水处理中控系统|水利信息化|智慧水务|智慧农业-山东德艾自动化科技有限公司 | 电动垃圾车,垃圾清运车-江苏速利达机车有限公司 | 软文发布平台 - 云软媒网络软文直编发布营销推广平台 | 儿童乐园|游乐场|淘气堡招商加盟|室内儿童游乐园配套设备|生产厂家|开心哈乐儿童乐园 | RV减速机-蜗轮蜗杆减速机-洗车机减速机-减速机厂家-艾思捷 | 箱式破碎机_移动方箱式破碎机/价格/厂家_【华盛铭重工】 |