dubbo 自定义异常

前言

在很多公司,使用dubbo做微服务治理也是很常见的一种方式,简单来说,就是服务提供者一方将服务注册并发布到注册中心,消费者订阅服务,然后像调用本地接口一样;

但是在实际实践中,经常有这么一种场景,就是对于服务消费者来说,当调用服务生产者的服务接口时,一旦服务提供者的接口抛出异常,如果消费端不使用 try-catch 捕捉的话,在进行问题排查、故障分析时,将会是个头疼的问题;

对于消费端来说,不可能在所有的调用dubbo接口的地方都用 try-catch进行包裹吧?有没有一种办法,用来统一处理这样的服务接口调用异常方式呢?答案是肯定的,可以使用dubbo自定义过滤器,通过过滤器统一拦截调用异常问题;

操作步骤

一、创建一个公共的用于处理异常的工程

ComnonFilter 类,只需要实现dubbo提供的Filter 接口即可

package com.congge.filter;

import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import org.apache.dubbo.common.Constants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.rpc.*;
import org.apache.dubbo.rpc.service.GenericService;

import java.util.Date;

@Activate(group = {Constants.PROVIDER,Constants.CONSUMER})
public class CommonFilter implements Filter {

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {

        Result result = null;
        try {
            result = invoker.invoke(invocation);
            if (result.hasException() && GenericService.class != invoker.getInterface()) {
                Throwable exception = result.getException();
                String data = String.format("\r\n[level]:Error,[createTime]:%s,[serviceName]:%s,[methodName]:%s,[inputParam]:%s",
                        DateUtil.formatDateTime(new Date()),
                        invoker.getInterface().getName(),
                        invocation.getMethodName(),
                        JSON.toJSONString(invocation.getArguments()));
                System.out.println(data);
                System.out.println(exception);
            }
        }catch (RuntimeException e){
            String data = String.format("\r\n[level]:Error," +
                    "[createTime]:%s," +
                    "[serviceName]:%s," +
                    "[methodName]:%s," +
                    "[inputParam]:%s",
                    DateUtil.formatDateTime(new Date()),
                    invoker.getInterface().getName(),
                    invocation.getMethodName(),
                    JSON.toJSONString(invocation.getArguments()));
            System.out.println(data);
            System.out.println(e);
        }
        return result;
    }
}

在resources目录下创建相关的目录,注意文件路径和文件名称是固定的,文件内容如下

 

二、生产端配置文件改造 

1、pom中导入上面这个公共依赖的maven工程坐标,然后在配置文件中,将过滤器的名称配置进去

 

2、生产端提供的服务中手动添加一个异常

 

三、消费端配置

消费端暂时无需做其他配置

import com.congge.service.HelloService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

public class ConsumerMain {
    public static void main(String[] args) throws Exception {
   
        ApplicationContext ac = new ClassPathXmlApplicationContext("spring-consumer.xml");
        HelloService service = (HelloService) ac.getBean("helloService");
        String hello = service.hello("Hello Provider");
        System.out.println(hello);

    }
}

测试

1、启动本地的zk服务

2、启动生产端服务

 

3、启动消费端服务模拟服务调用

消费端报出的异常信息

 由于我们将过滤器配置在生产端了,这时再去观察生产端的控制台,可以看到,调用异常的信息也输出了

使用场景说明

通常来说,在微服务的调用链路比较长的时候,在消费端采用上面的方式进行配置,是有一定意义的,可以较快的定位到调用的服务接口,以及抛出的具体的问题原因,便于服务提供者快速进行问题定位和修复

 


原文连接:https://blog.csdn.net/congge_study/article/details/125239509

相关推荐

云徙科技CTO李楠:技术和技术人,与数字化共同进化

Java通过反射注解赋值

Java开发学习(十五)----AOP入门案例及其工作流程解析

2022-07-21 第四组 java之继承

JavaScript进阶内容——BOM详解

注意 new BigDecimal(double val) 的使用

创建私有CA,我就用openSSL

JavaScript必须掌握的四大基础知识(数据类型、原型和原型链、闭包、异步 promise)

百度APP Android包体积优化实践(二)Dex行号优化

814. 二叉树剪枝 : 简单递归运用题

【综合笔试题】难度 3.5\u002F5,多解法热门二叉树笔试题

【java刷算法】牛客—剑指offer3栈、数组、递归、二分法的初步练习

JavaScript中一些流行的模块、vite快速搭建、vue3简梳理

JavaScript进阶内容——DOM详解

JavaScript基础系列(6):`this`这六种使用方式

【跟着大佬学JavaScript】之数组去重(结果对比)

Java开发学习(十四)----Spring整合Mybatis及Junit

Java代码优化的30个小技巧

JavaScript 中的单例内置对象(Global & Math)

JavaScript:聊聊作用域、作用域链与它的一些优化