脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → dubbo中Listener的实现

基于dubbo中Listener的实现方法

 更新时间：2017年08月11日 07:58:25   投稿：jingxian  
下面小编就为大家带来一篇基于dubbo中Listener的实现方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧

这里继续dubbo的源码旅程，在过程中学习它的设计和技巧，看优秀的代码，我想对我们日程编码必然有帮助的。而那些开源的代码正是千锤百炼的东西，希望和各位共勉。

拿ProtocolListenerWrapper为例子，看源码的时候发现它是一个装饰类的标准实现有一个自身的复制构造函数,把被包装者复制进来，然后结合装饰部分的操作。看下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()方法就是去匹配前面提到的装饰模式用到的方式。

而这些类作为插件会被放入cachedWrapperClasses进行缓存。而对这个缓存的使用就是解开listenter调用实现的钥匙。

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

上面也可以看到用一场作为一个判断逻辑。

ExtensionLoader中getExtension(String name)方法中会调用createExtension(String name)这个方法中将cachedWrapperClasses利用了起来，具体实现就是将被装饰类实例作为参数调用warpper类的自身复制构造函数，这样就会把被装饰累包装起来，从而达到，当有调用被装饰类的方法是就可以执行到warpper中的逻辑代码了，实现都是调用了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，我们可以发现继承Protocol中的export方法是对外开放service的入口方法，它返回exporter，代码中实际是返回了ListenerExporterWrapper，这也是个装饰类，不过没有使用上面提到的机制，只是把exporter和listener进行类包装，在构造函数里将listener执行。至此我们终于找到了执行listener的代码。

在dubbo的开发中listener是及其重要的一个扩展口子，在服务对外时执行一些自己想做的事情就些各类继承ExporterListener

在引用服务的时候想做些自己的事就写个类继承InvokerListener。

另外，ExporterListener为例，发现他的子类中有一个ExporterListenerAdapter，两个空方法，代码：

public abstract class ExporterListenerAdapter implements ExporterListener {

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

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

}

这是个技巧吧，刚刚上面提到自己要写扩展类的时候就不直接继承ExporterListener了，因为直接继承接口会强制要求实现两个方法的，而实际编码中dubbo的作者应该也发现这两个方法是完全不同的业务时使用，所有我们可以只继承ExporterListenerAdapter，如此自己的业务代码中就不需要出现一个空方法了。

以上这篇基于dubbo中Listener的实现方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

相关文章

  • java仿微信摇一摇实现播放音乐

    java仿微信摇一摇实现播放音乐

    这篇文章主要为大家详细介绍了java仿微信摇一摇实现播放音乐，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-06-06
  • Java字符串相关类使用方法详解

    Java字符串相关类使用方法详解

    String、StringBuilder、StringBuffer还傻傻分不清,下面这篇文章主要给大家介绍了关于Java字符串相关类使用的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-07-07
  • 源码解析带你了解LinkedHashMap

    源码解析带你了解LinkedHashMap

    大多数情况下，只要不涉及线程安全问题，Map基本都可以使用HashMap，不过HashMap有一个问题，就是迭代HashMap的顺序并不是HashMap放置的顺序，也就是无序。HashMap的这一缺点往往会带来困扰，所以LinkedHashMap就闪亮登场了，这篇文章通过源码解析带你了解LinkedHashMap
    2021-09-09
  • SpringBoot解决ajax跨域问题的方法

    SpringBoot解决ajax跨域问题的方法

    这篇文章主要为大家详细介绍了SpringBoot解决ajax跨域问题的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-03-03
  • SpringBoot接收与响应xml报文请求的实现

    SpringBoot接收与响应xml报文请求的实现

    我们在进行接口对接时,会出现报文形式的信息传递,这篇文章主要给大家介绍了关于SpringBoot接收与响应xml报文请求的相关资料,需要的朋友可以参考下
    2023-06-06
  • java文件下载设置中文名称的实例(response.addHeader)

    java文件下载设置中文名称的实例(response.addHeader)

    下面小编就为大家分享一篇java文件下载设置中文名称的实例(response.addHeader)，具有很好的参考价值，希望对大家有所帮助
    2017-12-12
  • 有关Java常见的误解小结(来看一看)

    有关Java常见的误解小结(来看一看)

    下面小编就为大家带来一篇有关Java常见的误解小结(来看一看)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • 从0构建Oauth2Server服务之Refreshing-access-tokens

    从0构建Oauth2Server服务之Refreshing-access-tokens

    这篇文章主要为大家介绍了从0构建Oauth2Server服务之Refreshing-access-tokens刷新令牌示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-05-05
  • Java中使用Closeable接口自动关闭资源详解

    Java中使用Closeable接口自动关闭资源详解

    这篇文章主要介绍了Java中使用Closeable接口自动关闭资源详解,Closeable接口继承于AutoCloseable,主要的作用就是自动的关闭资源,其中close()方法是关闭流并且释放与其相关的任何方法,如果流已被关闭,那么调用此方法没有效果,需要的朋友可以参考下
    2023-12-12
  • java selenium处理Iframe中的元素示例

    java selenium处理Iframe中的元素示例

    本文主要介绍java selenium处理Iframe中的元素,这里整理了相关资料并附有示例代码和实现方法，有需要的小伙伴可以参考下
    2016-08-08

最新评论