快捷導(dǎo)航

dubbo3 filter(過(guò)濾器)如何自定義過(guò)濾器

更新時(shí)間：2025年03月06日 14:28:36 作者：帥氣的人123

dubbo3filter（過(guò)濾器）類似于javaweb中的filter和springmvc中的intercaptor,用于在請(qǐng)求發(fā)送前或到達(dá)前進(jìn)行預(yù)處理工作,完成限流和監(jiān)控,在dubbo中,過(guò)濾器運(yùn)行在consumer和provider兩端,分別在調(diào)用鏈中執(zhí)行

dubbo3 filter（過(guò)濾器）

簡(jiǎn)介

類似于 java web 中的 filter
也和 spring mvc 中的 intercaptor
在請(qǐng)求的發(fā)送后或者是請(qǐng)求到達(dá)前集中的做一些預(yù)處理工作
在 dubbo 中也會(huì)通過(guò)過(guò)濾器來(lái)完成限流和監(jiān)控的工作

dubbo 過(guò)濾器運(yùn)行時(shí)機(jī)

consumer 在調(diào)用的時(shí)候負(fù)載均衡已經(jīng)選擇了一個(gè)具體的實(shí)例進(jìn)行調(diào)用，那么會(huì)依次執(zhí)行 conusmer 端端調(diào)用鏈（調(diào)用鏈?zhǔn)?filter），然后到達(dá) provider ，會(huì)繼續(xù)執(zhí)行 provider 的調(diào)用鏈（這里是 filter），完成響應(yīng)的時(shí)候也會(huì)依次調(diào)用這些鏈

自定義 filter

在 dubbo 中自定義 filter 可以有兩種方式。

第一種 @Active 注解激活

在項(xiàng)目目錄下面創(chuàng)建文件夾 META-INF/dubbo 下面創(chuàng)建 filter 的權(quán)限定類名，（org.apache.dubbo.rpc.Filter），然后在文件內(nèi)部寫入我們的注冊(cè)信息，名字=自定義 filter 的權(quán)限定類名，注冊(cè)成功以后需要激活我們的配置，@Activate(group = CommonConstants.PROVIDER)

myProviderFilter=com.rpc.dubbo.provider.filter.MyProviderFilter

代碼：

package com.rpc.dubbo.provider.filter;

import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.constants.CommonConstants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.rpc.*;

/**
 * @author xl-9527
 * @since 2025/1/11
 **/
@Slf4j
@Activate(group = CommonConstants.PROVIDER) // active 中 group 的設(shè)置是表示他運(yùn)行在 consumer 還是 provider 端，這是必須要要配置的
public class MyProviderFilter implements Filter {

    /**
     * @param invoker    實(shí)際這次的調(diào)用
     * @param invocation 本次調(diào)用的參數(shù)
     * @return 調(diào)用結(jié)果，這里的調(diào)用結(jié)果是從 provider 端調(diào)用過(guò)來(lái)的
     */
    @Override
    public Result invoke(final Invoker<?> invoker, final Invocation invocation) throws RpcException {
        System.out.println("invoker.getUrl() = " + invoker.getUrl());
        System.out.println("invocation.getMethodName() = " + invocation.getMethodName());
        System.out.println("invocation.getServiceModel().getServiceName() = " + invocation.getServiceModel().getServiceName());
        log.info("MyProviderFilter invoke");
        return invoker.invoke(invocation);
    }
}