基于dubbo中Listener的實(shí)現(xiàn)方法

更新時(shí)間：2017年08月11日 07:58:25 投稿：jingxian

下面小編就為大家?guī)硪黄赿ubbo中Listener的實(shí)現(xiàn)方法。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧

這里繼續(xù)dubbo的源碼旅程，在過程中學(xué)習(xí)它的設(shè)計(jì)和技巧，看優(yōu)秀的代碼，我想對(duì)我們?nèi)粘叹幋a必然有幫助的。而那些開源的代碼正是千錘百煉的東西，希望和各位共勉。

拿ProtocolListenerWrapper為例子，看源碼的時(shí)候發(fā)現(xiàn)它是一個(gè)裝飾類的標(biāo)準(zhǔn)實(shí)現(xiàn)有一個(gè)自身的復(fù)制構(gòu)造函數(shù),把被包裝者復(fù)制進(jìn)來，然后結(jié)合裝飾部分的操作。看下ProtocolListenerWrapper類有這樣的代碼：

public class ProtocolListenerWrapper implements Protocol {

  private final Protocol protocol;

  public ProtocolListenerWrapper(Protocol protocol){
    if (protocol == null) {
      throw new IllegalArgumentException("protocol == null");
    }
    this.protocol = protocol;
  }

  public int getDefaultPort() {
    return protocol.getDefaultPort();
  }

  public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
    if (Constants.REGISTRY_PROTOCOL.equals(invoker.getUrl().getProtocol())) {
      return protocol.export(invoker);
    }
    return new ListenerExporterWrapper<T>(protocol.export(invoker),
        Collections.unmodifiableList(ExtensionLoader.getExtensionLoader(ExporterListener.class)
            .getActivateExtension(invoker.getUrl(), Constants.EXPORTER_LISTENER_KEY)));
  }

  public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
    if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
      return protocol.refer(type, url);
    }
    return new ListenerInvokerWrapper<T>(protocol.refer(type, url),
        Collections.unmodifiableList(
            ExtensionLoader.getExtensionLoader(InvokerListener.class)
            .getActivateExtension(url, Constants.INVOKER_LISTENER_KEY)));
  }

  public void destroy() {
    protocol.destroy();
  }

}

而我們在ExtensionLoader里找到了這份代碼片段clazz.getConstructor()方法就是去匹配前面提到的裝飾模式用到的方式。

而這些類作為插件會(huì)被放入cachedWrapperClasses進(jìn)行緩存。而對(duì)這個(gè)緩存的使用就是解開listenter調(diào)用實(shí)現(xiàn)的鑰匙。

try {
  clazz.getConstructor(type);
  Set<Class<?>> wrappers = cachedWrapperClasses;
  if (wrappers == null) {
    cachedWrapperClasses = new ConcurrentHashSet<Class<?>>();
    wrappers = cachedWrapperClasses;
  }
  wrappers.add(clazz);
} catch (NoSuchMethodException e) {

上面也可以看到用一場作為一個(gè)判斷邏輯。

ExtensionLoader中g(shù)etExtension(String name)方法中會(huì)調(diào)用createExtension(String name)這個(gè)方法中將cachedWrapperClasses利用了起來，具體實(shí)現(xiàn)就是將被裝飾類實(shí)例作為參數(shù)調(diào)用warpper類的自身復(fù)制構(gòu)造函數(shù)，這樣就會(huì)把被裝飾累包裝起來，從而達(dá)到，當(dāng)有調(diào)用被裝飾類的方法是就可以執(zhí)行到warpper中的邏輯代碼了，實(shí)現(xiàn)都是調(diào)用了clazz.getConstructor方法，代碼片段：

Set<Class<?>> wrapperClasses = cachedWrapperClasses;
if (wrapperClasses != null && wrapperClasses.size() > 0) {
  for (Class<?> wrapperClass : wrapperClasses) {
    instance = injectExtension((T) wrapperClass.getConstructor(type).newInstance(instance));
  }
}

再回去看一下ProtocolListenerWrapper，我們可以發(fā)現(xiàn)繼承Protocol中的export方法是對(duì)外開放service的入口方法，它返回exporter，代碼中實(shí)際是返回了ListenerExporterWrapper，這也是個(gè)裝飾類，不過沒有使用上面提到的機(jī)制，只是把exporter和listener進(jìn)行類包裝，在構(gòu)造函數(shù)里將listener執(zhí)行。至此我們終于找到了執(zhí)行l(wèi)istener的代碼。

在dubbo的開發(fā)中l(wèi)istener是及其重要的一個(gè)擴(kuò)展口子，在服務(wù)對(duì)外時(shí)執(zhí)行一些自己想做的事情就些各類繼承ExporterListener

在引用服務(wù)的時(shí)候想做些自己的事就寫個(gè)類繼承InvokerListener。

另外，ExporterListener為例，發(fā)現(xiàn)他的子類中有一個(gè)ExporterListenerAdapter，兩個(gè)空方法，代碼：

public abstract class ExporterListenerAdapter implements ExporterListener {

  public void exported(Exporter<?> exporter) throws RpcException {
  }

  public void unexported(Exporter<?> exporter) throws RpcException {
  }

}

這是個(gè)技巧吧，剛剛上面提到自己要寫擴(kuò)展類的時(shí)候就不直接繼承ExporterListener了，因?yàn)橹苯永^承接口會(huì)強(qiáng)制要求實(shí)現(xiàn)兩個(gè)方法的，而實(shí)際編碼中dubbo的作者應(yīng)該也發(fā)現(xiàn)這兩個(gè)方法是完全不同的業(yè)務(wù)時(shí)使用，所有我們可以只繼承ExporterListenerAdapter，如此自己的業(yè)務(wù)代碼中就不需要出現(xiàn)一個(gè)空方法了。

以上這篇基于dubbo中Listener的實(shí)現(xiàn)方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。