快捷導(dǎo)航

dubbo自定義異常的完整步驟與測試

更新時間：2022年06月13日 09:27:02 作者：逆風(fēng)飛翔的小叔

最近在項目上遇到一個有關(guān)dubbo的問題,想著給大家總結(jié)下,這篇文章主要給大家介紹了關(guān)于dubbo自定義異常的完整步驟與測試的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下

前言

在很多公司，使用dubbo做微服務(wù)治理也是很常見的一種方式，簡單來說，就是服務(wù)提供者一方將服務(wù)注冊并發(fā)布到注冊中心，消費(fèi)者訂閱服務(wù)，然后像調(diào)用本地接口一樣；

但是在實(shí)際實(shí)踐中，經(jīng)常有這么一種場景，就是對于服務(wù)消費(fèi)者來說，當(dāng)調(diào)用服務(wù)生產(chǎn)者的服務(wù)接口時，一旦服務(wù)提供者的接口拋出異常，如果消費(fèi)端不使用 try-catch 捕捉的話，在進(jìn)行問題排查、故障分析時，將會是個頭疼的問題；

對于消費(fèi)端來說，不可能在所有的調(diào)用dubbo接口的地方都用 try-catch進(jìn)行包裹吧？有沒有一種辦法，用來統(tǒng)一處理這樣的服務(wù)接口調(diào)用異常方式呢？答案是肯定的，可以使用dubbo自定義過濾器，通過過濾器統(tǒng)一攔截調(diào)用異常問題；

操作步驟

一、創(chuàng)建一個公共的用于處理異常的工程

ComnonFilter 類，只需要實(shí)現(xiàn)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目錄下創(chuàng)建相關(guān)的目錄，注意文件路徑和文件名稱是固定的，文件內(nèi)容如下

二、生產(chǎn)端配置文件改造

1、pom中導(dǎo)入上面這個公共依賴的maven工程坐標(biāo)，然后在配置文件中，將過濾器的名稱配置進(jìn)去

2、生產(chǎn)端提供的服務(wù)中手動添加一個異常

三、消費(fèi)端配置

消費(fèi)端暫時無需做其他配置

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);
 
    }
}