`

Dubbo之Activate

阅读更多

Activate:可以被框架中自动激活加载扩展,此Annotation用于配置扩展被自动激活加载条件。

Activate,看起来有点不好理解,它的意思是条件激活,用户通过group和value配置激活条件。被activate注解的扩展点在满足某种条件时会被激活,它一般用来配合filter和Invokelistener,声明他们的使用场景。我们先来看看源码

 

 

首先你对的dubbo的 SPI机制有一定的了解和研究,

 

我们看看他的用法,来看一个测试例子的流程:

 

对应的配置文件:



接口

@SPI("order1")
public interface ActivateExt1 {
    String echo(String msg);
}

 

对应不同的实现类:

 

@Activate(group = {"default_group"})
public class ActivateExt1Impl1 implements ActivateExt1 {
    public String echo(String msg) {
        return msg;
    }
}

@Activate(group = {"group1", "group2"})
public class GroupActivateExtImpl implements ActivateExt1 {
    public String echo(String msg) {
        return msg;
    }
}

 

@Activate(order = 2, group = {"order"})
public class OrderActivateExtImpl1 implements ActivateExt1 {
    public String echo(String msg) {
        return msg;
    }
}

@Activate(order = 1, group = {"order"})
public class OrderActivateExtImpl2 implements ActivateExt1 {
    public String echo(String msg) {
        return msg;
    }
}

@Activate(value = {"value1"}, group = {"value"})
public class ValueActivateExtImpl implements ActivateExt1 {
    public String echo(String msg) {
        return msg;
    }
}

 

下面是测试案例

/**
     * 默认实现
     */
    @Test
    public void testDefault() {
        ExtensionLoader<ActivateExt1> loader = ExtensionLoader.getExtensionLoader(ActivateExt1.class);
        URL url = URL.valueOf("test://localhost/test");
       //他会去加载默认的实现 根据default_group 查找对应的实现方法
        List<ActivateExt1> list = loader.getActivateExtension(url, new String[]{}, "default_group");
        //activateext1impl1-----------@com.alibaba.dubbo.common.extension.Activate(after=[], before=[],        value=[], order=0, group=[default_group])
        //找到key了再用spi找到对应的实现类
        System.out.println(list.size()); // 1
        // com.alibaba.dubbo.common.extensionloader.activate.impl.ActivateExt1Impl1
        System.out.println(list.get(0).getClass());
    }

 

/**
     * group 实现的测试
     */
    @Test
    public void testGroup() {
        URL url = URL.valueOf("test://localhost/test");
        // group == group1  或者 group2
        List<ActivateExt1> list  =    ExtensionLoader.getExtensionLoader(ActivateExt1.class).getActivateExtension(url, new String[]{}, "group2");
        //group-----------@com.alibaba.dubbo.common.extension.Activate(after=[], before=[], value=[], order=0, group=[group1, group2])
        System.out.println(list.size());
        //com.alibaba.dubbo.common.extensionloader.activate.impl.GroupActivateExtImpl
        System.out.println(list.get(0).getClass());
    }

 

/**
     * 测试 testValue
     */
    @Test
    public void testValue() {
        URL url = URL.valueOf("test://localhost/test");
        //根据   key = value1,group =  value             
        //@Activate(value = {"value1"}, group = {"value"})来激活扩展
        url = url.addParameter("value1", "value");
        List<ActivateExt1> list  = ExtensionLoader.getExtensionLoader(ActivateExt1.class).getActivateExtension(url, new String[]{}, "value");
        //value-----------@com.alibaba.dubbo.common.extension.Activate(after=[], before=[], value=[value1], order=0, group=[value])
        System.out.println(list.size());
        //com.alibaba.dubbo.common.extensionloader.activate.impl.ValueActivateExtImpl
        System.out.println(list.get(0).getClass());
    }

 

/**
     * 测试 testOrder
     * 测试多group = order
     * 其中 int order() default 0;  排序字段
     */
    @Test
    public void testOrder() {
        URL url = URL.valueOf("test://localhost/test");
        List<ActivateExt1> list = ExtensionLoader.getExtensionLoader(ActivateExt1.class).getActivateExtension(url, new String[]{}, "order");
        //order1-----------@com.alibaba.dubbo.common.extension.Activate(after=[], before=[], value=[], order=2, group=[order])
        //order2-----------@com.alibaba.dubbo.common.extension.Activate(after=[], before=[], value=[], order=1, group=[order])
        System.out.println(list.size());
        //com.alibaba.dubbo.common.extensionloader.activate.impl.OrderActivateExtImpl2  因为order = 1,先输出
        System.out.println(list.get(0).getClass());
        //com.alibaba.dubbo.common.extensionloader.activate.impl.OrderActivateExtImpl1 order = 2
        System.out.println(list.get(1).getClass());
    }

 

 

 

 

 

 

 

 

 

 

 

 

  • 大小: 48.3 KB
  • 大小: 30.9 KB
  • 大小: 69.2 KB
  • 大小: 55.5 KB
0
0
分享到:
评论

相关推荐

    Dubbo之《尚硅谷》学习笔记.md

    Dubbo之《尚硅谷》学习笔记

    dubbo资源 dubbo-admin dubbo demo

    dubbo资源 dubbo-admin dubbo demo

    dubbo示例代码dubbo-sample

    dubbo示例代码dubbo-sample

    dubbo视频教程|基于Dubbo的分布式系统架构实战

    Dubbo是阿里巴巴开源的分布式服务化治理框架(微服务框架),久经阿里巴巴电商平台的大规模复杂业务的高并发考验,到目前为止Dubbo仍然是开源界中体系最完善的服务化治理框架,因此Dubbo被国内大量的的互联网公司和...

    incubator-dubbo-dubbo-2.6.1

    incubator-dubbo-dubbo-2.6.1

    尚硅谷最新dubbo视频

    本套视频从分布式系统的基本概念出发,由浅入深,讲解了RPC原理,Dubbo基本使用,Dubbo高可用场景以及Dubbo原理,涉及了分布式系统中服务注册、服务发现、负载均衡、灰度发布、集群容错、服务降级等核心概念的讲解及...

    Dubbo入门之hello world(简单测试版和使用注解加强版)

    用maven构建项目使用spring和multicast广播注册中心方式实现Dubbo入门之hello world(用maven构建项目使用spring和multicast广播注册中心方式实现Dubbo入门之hello world(简单测试版)文档说明以及源码

    dubbo接口测试调试工具

    前段时间排查某问题的时候,想要快速知道某些dubbo接口(三无)的响应结果,但不想启动项目(因为这些项目不是你负责的,不会部署而且超级笨重),也不想新建一个dubbo客户端项目(占地方),也不想开telnet客户端...

    dubbodubbo.zip

    dubbo资源包

    dubbo源码解析2

    dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.dubbo源码解析2.

    dubbo捕获自定义异常_dubbo异常捕获_dubbo异常_自定义异常_捕捉异常_

    解决dubbo接口自定义异常的捕捉问题,dubbo消费者可以捕捉到提供者所抛出的自定义异常。

    Dubbo培训与实战

    首先,从知识层面对Dubbo有一个了解和认识,请看《Dubbo培训与实战.pptx》,然后把Dubbo用到实际项目中来,请看实例代码《Dubbo实例代码(Sping+Dubbo+Maven).zip》,里面包括dubboDemoProvide和dubboDemoConsumer...

    dubbo-2.8.4.jar

    at com.alibaba.dubbo.remoting.exchange.support.DefaultFuture.returnFromResponse(DefaultFuture.java:190) at com.alibaba.dubbo.remoting.exchange.support.DefaultFuture.get(DefaultFuture.java:110) at ...

    【BAT必备】dubbo面试题

    【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题【BAT必备】dubbo面试题...

    最简单的Dubbo案例之二:SpringBoot + dubbo 无zookeeper方式点对点直连

    本项目只适合dubbo入门学习者,高手请不要浪费金钱; 本项目技术栈 springboot, dubbo ,无 zookeeper 本项目旨在提供最单纯的 dubbo 服务提供者 和消费者的点对点直连,而摒弃任何多余技术对dubbo直连的理解

    dubbo+zookeeper缓存方案

    dubbo+zookeeper缓存方案 dubbo+zookeeper缓存方案dubbo+zookeeper缓存方案dubbo+zookeeper缓存方案

    spring_dubbo spring_dubbo spring_dubbo

    spring_dubbo spring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_dubbospring_...

    dubbo找不到dubbo.xsd报错

    构建dubbo项目的时候会遇到: Multiple annotations found at this line: - cvc-complex-type.2.4.c: The matching wildcard is strict, but no declaration can be found for element 'dubbo:application'. - ...

    dubbo admin管理平台及dubbo monitor监控中心

    Dubbo是Alibaba开源的分布式服务框架,我们可以非常容易地通过Dubbo来构建分布式服务,并根据自己实际业务应用场景来选择合适的集群容错模式,这个对于很多应用都是迫切希望的,只需要通过简单的配置就能够实现...

    Dubbo监控系统配置

    Dubbo监控系统配置Dubbo监控系统配置Dubbo监控系统配置

Global site tag (gtag.js) - Google Analytics