dubbo源碼解析（二十一）遠程調用——Listener

simpleapples 發布于2019-08-16 14:16 / 2889人閱讀

摘要：源碼分析一該類實現了，是服務引用監聽器的包裝類。取消暴露遍歷監聽集合監聽取消暴露該方法是對每個取消服務暴露的監聽。五暴露服務取消暴露服務該類是服務暴露監聽器的適配類，沒有做實際的操作。

遠程調用——Listener

目標：介紹dubbo-rpc-api中的各種listener監聽器的實現邏輯，內容略少，隨便撇兩眼，不是重點。

前言

本文介紹監聽器的相關邏輯。在服務引用和服務發現中監聽器處于的位置請看下面的圖：

服務暴露：

服務引用：

這兩個監聽器所做的工作不是很多，來看看源碼理解一下。

源碼分析 （一）ListenerInvokerWrapper

該類實現了Invoker，是服務引用監聽器的包裝類。

1.屬性

/**
 * invoker對象
 */
private final Invoker invoker;

/**
 * 監聽器集合
 */
private final List listeners;

用到了裝飾模式，其中很多實現方法直接調用了invoker的方法。

2.構造方法

public ListenerInvokerWrapper(Invoker invoker, List listeners) {
    // 如果invoker為空則拋出異常
    if (invoker == null) {
        throw new IllegalArgumentException("invoker == null");
    }
    this.invoker = invoker;
    this.listeners = listeners;
    if (listeners != null && !listeners.isEmpty()) {
        // 遍歷監聽器
        for (InvokerListener listener : listeners) {
            if (listener != null) {
                try {
                    // 調用在服務引用的時候進行監聽
                    listener.referred(invoker);
                } catch (Throwable t) {
                    logger.error(t.getMessage(), t);
                }
            }
        }
    }
}

構造方法中直接調用了監聽器的服務引用。

3.destroy

@Override
public void destroy() {
    try {
        // 銷毀invoker
        invoker.destroy();
    } finally {
        // 銷毀所有監聽的實體域
        if (listeners != null && !listeners.isEmpty()) {
            for (InvokerListener listener : listeners) {
                if (listener != null) {
                    try {
                        listener.destroyed(invoker);
                    } catch (Throwable t) {
                        logger.error(t.getMessage(), t);
                    }
                }
            }
        }
    }
}

該方法是把服務引用的監聽器銷毀。

（二）InvokerListenerAdapter

public abstract class InvokerListenerAdapter implements InvokerListener {

    /**
     * 引用服務
     * @param invoker
     * @throws RpcException
     */
    @Override
    public void referred(Invoker invoker) throws RpcException {
    }

    /**
     * 銷毀
     * @param invoker
     */
    @Override
    public void destroyed(Invoker invoker) {
    }

}

該類是服務引用監聽器的適配類，沒有做實際的操作。

（三）DeprecatedInvokerListener

@Activate(Constants.DEPRECATED_KEY)
public class DeprecatedInvokerListener extends InvokerListenerAdapter {

    private static final Logger LOGGER = LoggerFactory.getLogger(DeprecatedInvokerListener.class);

    @Override
    public void referred(Invoker invoker) throws RpcException {
        // 當該引用的服務被廢棄時，打印錯誤日志
        if (invoker.getUrl().getParameter(Constants.DEPRECATED_KEY, false)) {
            LOGGER.error("The service " + invoker.getInterface().getName() + " is DEPRECATED! Declare from " + invoker.getUrl());
        }
    }

}

該類是當調用廢棄的服務時候打印錯誤日志。

（四）ListenerExporterWrapper

該類是服務暴露監聽器包裝類。

1.屬性

/**
 * 服務暴露者
 */
private final Exporter exporter;

/**
 * 服務暴露監聽者集合
 */
private final List listeners;

用到了裝飾模式，其中很多實現方法直接調用了exporter的方法。

2.構造方法

public ListenerExporterWrapper(Exporter exporter, List listeners) {
    if (exporter == null) {
        throw new IllegalArgumentException("exporter == null");
    }
    this.exporter = exporter;
    this.listeners = listeners;
    if (listeners != null && !listeners.isEmpty()) {
        RuntimeException exception = null;
        // 遍歷服務暴露監聽集合
        for (ExporterListener listener : listeners) {
            if (listener != null) {
                try {
                    // 暴露服務監聽
                    listener.exported(this);
                } catch (RuntimeException t) {
                    logger.error(t.getMessage(), t);
                    exception = t;
                }
            }
        }
        if (exception != null) {
            throw exception;
        }
    }
}

該方法中對于每個服務暴露進行監聽。

3.unexport

@Override
public void unexport() {
    try {
        // 取消暴露
        exporter.unexport();
    } finally {
        if (listeners != null && !listeners.isEmpty()) {
            RuntimeException exception = null;
            // 遍歷監聽集合
            for (ExporterListener listener : listeners) {
                if (listener != null) {
                    try {
                        // 監聽取消暴露
                        listener.unexported(this);
                    } catch (RuntimeException t) {
                        logger.error(t.getMessage(), t);
                        exception = t;
                    }
                }
            }
            if (exception != null) {
                throw exception;
            }
        }
    }
}

該方法是對每個取消服務暴露的監聽。

（五）ExporterListenerAdapter

public abstract class ExporterListenerAdapter implements ExporterListener {

    /**
     * 暴露服務
     * @param exporter
     * @throws RpcException
     */
    @Override
    public void exported(Exporter exporter) throws RpcException {
    }

    /**
     * 取消暴露服務
     * @param exporter
     * @throws RpcException
     */
    @Override
    public void unexported(Exporter exporter) throws RpcException {
    }

}

該類是服務暴露監聽器的適配類，沒有做實際的操作。

后記

該部分相關的源碼解析地址：https://github.com/CrazyHZM/i...

該文章講解了在服務引用和服務暴露中的各種listener監聽器，其中內容很少。接下來我將開始對rpc模塊的協議protocol進行講解。

云服務器 GPU云服務器二十一 dubbo源碼調用遠程遠程調用

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/72891.html

dubbo源碼解析（四十八）異步化改造

摘要：大揭秘異步化改造目標從源碼的角度分析的新特性中對于異步化的改造原理。看源碼解析四十六消費端發送請求過程講到的十四的，在以前的邏輯會直接在方法中根據配置區分同步異步單向調用。改為關于可以參考源碼解析十遠程通信層的六。 2.7大揭秘——異步化改造目標：從源碼的角度分析2.7的新特性中對于異步化的改造原理。前言 dubbo中提供了很多類型的協議，關于協議的系列可以查看下面的文章： du...

lijinke666 2019-08-19 10:18 評論0 收藏0
dubbo源碼解析（四十六）消費端發送請求過程

摘要：可以參考源碼解析二十四遠程調用協議的八。十六的該類也是用了適配器模式，該類主要的作用就是增加了心跳功能，可以參考源碼解析十遠程通信層的四。二十的可以參考源碼解析十七遠程通信的一。 2.7大揭秘——消費端發送請求過程目標：從源碼的角度分析一個服務方法調用經歷怎么樣的磨難以后到達服務端。前言前一篇文章講到的是引用服務的過程，引用服務無非就是創建出一個代理。供消費者調用服務的相關方法。...

fish 2019-08-16 17:52 評論0 收藏0
dubbo源碼解析（四十七）服務端處理請求過程

摘要：而存在的意義就是保證請求或響應對象可在線程池中被解碼，解碼完成后，就會分發到的。 2.7大揭秘——服務端處理請求過程目標：從源碼的角度分析服務端接收到請求后的一系列操作，最終把客戶端需要的值返回。前言上一篇講到了消費端發送請求的過程，該篇就要將服務端處理請求的過程。也就是當服務端收到請求數據包后的一系列處理以及如何返回最終結果。我們也知道消費端在發送請求的時候已經做了編碼，所以我...

yzzz 2019-08-16 17:59 評論0 收藏0
dubbo源碼解析（二十二）遠程調用——Protocol

摘要：七該類也實現了，也是裝飾了接口，但是它是在服務引用和暴露過程中加上了監聽器的功能。如果是注冊中心，則暴露該創建一個暴露者監聽器包裝類對象該方法是在服務暴露上做了監聽器功能的增強，也就是加上了監聽器。遠程調用——Protocol 目標：介紹遠程調用中協議的設計和實現，介紹dubbo-rpc-api中的各種protocol包的源碼，是重點內容。前言在遠程調用中協議是非常重要的一層，看...

孫淑建 2019-08-16 14:22 評論0 收藏0
dubbo源碼解析（四十四）服務暴露過程

摘要：服務暴露過程目標從源碼的角度分析服務暴露過程。導出服務，包含暴露服務到本地，和暴露服務到遠程兩個過程。其中服務暴露的第八步已經沒有了。將泛化調用版本號或者等信息加入獲得服務暴露地址和端口號，利用內數據組裝成。 dubbo服務暴露過程目標：從源碼的角度分析服務暴露過程。前言本來這一篇一個寫異步化改造的內容，但是最近我一直在想，某一部分的優化改造該怎么去撰寫才能更加的讓讀者理解。我覺...

light 2019-08-16 16:55 評論0 收藏0