摘要：源碼分析一該類實(shí)現(xiàn)了，是服務(wù)引用監(jiān)聽器的包裝類。取消暴露遍歷監(jiān)聽集合監(jiān)聽取消暴露該方法是對(duì)每個(gè)取消服務(wù)暴露的監(jiān)聽。五暴露服務(wù)取消暴露服務(wù)該類是服務(wù)暴露監(jiān)聽器的適配類，沒有做實(shí)際的操作。

目標(biāo)：介紹dubbo-rpc-api中的各種listener監(jiān)聽器的實(shí)現(xiàn)邏輯，內(nèi)容略少，隨便撇兩眼，不是重點(diǎn)。

本文介紹監(jiān)聽器的相關(guān)邏輯。在服務(wù)引用和服務(wù)發(fā)現(xiàn)中監(jiān)聽器處于的位置請(qǐng)看下面的圖：

服務(wù)暴露：

服務(wù)引用：

這兩個(gè)監(jiān)聽器所做的工作不是很多，來看看源碼理解一下。

該類實(shí)現(xiàn)了Invoker，是服務(wù)引用監(jiān)聽器的包裝類。

/**
 * invoker對(duì)象
 */
private final Invoker invoker;

/**
 * 監(jiān)聽器集合
 */
private final List listeners;

用到了裝飾模式，其中很多實(shí)現(xiàn)方法直接調(diào)用了invoker的方法。

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()) {
        // 遍歷監(jiān)聽器
        for (InvokerListener listener : listeners) {
            if (listener != null) {
                try {
                    // 調(diào)用在服務(wù)引用的時(shí)候進(jìn)行監(jiān)聽
                    listener.referred(invoker);
                } catch (Throwable t) {
                    logger.error(t.getMessage(), t);
                }
            }
        }
    }
}

構(gòu)造方法中直接調(diào)用了監(jiān)聽器的服務(wù)引用。

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

該方法是把服務(wù)引用的監(jiān)聽器銷毀。

public abstract class InvokerListenerAdapter implements InvokerListener {

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

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

}

該類是服務(wù)引用監(jiān)聽器的適配類，沒有做實(shí)際的操作。

@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 {
        // 當(dāng)該引用的服務(wù)被廢棄時(shí)，打印錯(cuò)誤日志
        if (invoker.getUrl().getParameter(Constants.DEPRECATED_KEY, false)) {
            LOGGER.error("The service " + invoker.getInterface().getName() + " is DEPRECATED! Declare from " + invoker.getUrl());
        }
    }

}

該類是當(dāng)調(diào)用廢棄的服務(wù)時(shí)候打印錯(cuò)誤日志。

該類是服務(wù)暴露監(jiān)聽器包裝類。

/**
 * 服務(wù)暴露者
 */
private final Exporter exporter;

/**
 * 服務(wù)暴露監(jiān)聽者集合
 */
private final List listeners;

用到了裝飾模式，其中很多實(shí)現(xiàn)方法直接調(diào)用了exporter的方法。

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;
        // 遍歷服務(wù)暴露監(jiān)聽集合
        for (ExporterListener listener : listeners) {
            if (listener != null) {
                try {
                    // 暴露服務(wù)監(jiān)聽
                    listener.exported(this);
                } catch (RuntimeException t) {
                    logger.error(t.getMessage(), t);
                    exception = t;
                }
            }
        }
        if (exception != null) {
            throw exception;
        }
    }
}

該方法中對(duì)于每個(gè)服務(wù)暴露進(jìn)行監(jiān)聽。

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

該方法是對(duì)每個(gè)取消服務(wù)暴露的監(jiān)聽。

public abstract class ExporterListenerAdapter implements ExporterListener {

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

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

}

該類是服務(wù)暴露監(jiān)聽器的適配類，沒有做實(shí)際的操作。

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

該文章講解了在服務(wù)引用和服務(wù)暴露中的各種listener監(jiān)聽器，其中內(nèi)容很少。接下來我將開始對(duì)rpc模塊的協(xié)議protocol進(jìn)行講解。