com.alibaba.dubbo.rpc.cluster.directory.StaticDirectory源码实例Demo-星河码客

类com.alibaba.dubbo.rpc.cluster.directory.StaticDirectory源码实例Demo

下面列出了怎么用com.alibaba.dubbo.rpc.cluster.directory.StaticDirectory的API类实例代码及写法，或者点击链接到github查看源代码。

源代码1 项目： dubbo-plus 文件： DefaultTracingCollectorFactory.java

@Override
protected TracingCollector createTracingCollector(List<URL> urls) {

    Invoker<TracingCollector> invoker;
    if(urls.size()==1){
        invoker = protocol.refer(TracingCollector.class,urls.get(0));
    }else{
        List<Invoker<TracingCollector>> invokers = new ArrayList<Invoker<TracingCollector>>();
        URL registryURL = null;
        for (URL url : urls) {
            invokers.add(protocol.refer(TracingCollector.class, url));
            if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
                registryURL = url; // 用了最后一个registry url
            }
        }
        if (registryURL != null) { // 有 注册中心协议的URL
            // 对有注册中心的Cluster 只用 AvailableCluster
            URL u = registryURL.addParameter(Constants.CLUSTER_KEY, AvailableCluster.NAME);
            invoker = cluster.join(new StaticDirectory(u, invokers));
        }  else { // 不是 注册中心的URL
            invoker = cluster.join(new StaticDirectory(invokers));
        }
    }
    TracingCollector tracingCollector = proxyFactory.getProxy(invoker);
    return tracingCollector;
}

源代码2 项目： dubbo-2.6.5 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({"unchecked"})
@Before
public void setUp() throws Exception {
    invocation.setMethodName("sayHello");

    invoker1 = mock(Invoker.class);
    invoker2 = mock(Invoker.class);
    invoker3 = mock(Invoker.class);
    invoker4 = mock(Invoker.class);
    invoker5 = mock(Invoker.class);
    mockedInvoker1 = mock(Invoker.class);

    URL turl = URL.valueOf("test://test:11/test");

    given(invoker1.isAvailable()).willReturn(false);
    given(invoker1.getInterface()).willReturn(IHelloService.class);
    given(invoker1.getUrl()).willReturn(turl.setPort(1).addParameter("name", "invoker1"));

    given(invoker2.isAvailable()).willReturn(true);
    given(invoker2.getInterface()).willReturn(IHelloService.class);
    given(invoker2.getUrl()).willReturn(turl.setPort(2).addParameter("name", "invoker2"));

    given(invoker3.isAvailable()).willReturn(false);
    given(invoker3.getInterface()).willReturn(IHelloService.class);
    given(invoker3.getUrl()).willReturn(turl.setPort(3).addParameter("name", "invoker3"));

    given(invoker4.isAvailable()).willReturn(true);
    given(invoker4.getInterface()).willReturn(IHelloService.class);
    given(invoker4.getUrl()).willReturn(turl.setPort(4).addParameter("name", "invoker4"));

    given(invoker5.isAvailable()).willReturn(false);
    given(invoker5.getInterface()).willReturn(IHelloService.class);
    given(invoker5.getUrl()).willReturn(turl.setPort(5).addParameter("name", "invoker5"));

    given(mockedInvoker1.isAvailable()).willReturn(false);
    given(mockedInvoker1.getInterface()).willReturn(IHelloService.class);
    given(mockedInvoker1.getUrl()).willReturn(turl.setProtocol("mock"));

    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };

    cluster_nocheck = new AbstractClusterInvoker(dic, url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };

}

源代码3 项目： dubbo-2.6.5 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

源代码4 项目： dubbox 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({ "unchecked" })
@Before
public void setUp() throws Exception {
	invocation.setMethodName("sayHello");
    
    invoker1 = EasyMock.createMock(Invoker.class);
    invoker2 = EasyMock.createMock(Invoker.class);
    invoker3 = EasyMock.createMock(Invoker.class);
    invoker4 = EasyMock.createMock(Invoker.class);
    invoker5 = EasyMock.createMock(Invoker.class);
    mockedInvoker1 = EasyMock.createMock(Invoker.class);
    
    URL turl = URL.valueOf("test://test:11/test");
    
    EasyMock.expect(invoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker1.getUrl()).andReturn(turl.addParameter("name", "invoker1")).anyTimes();
    
    EasyMock.expect(invoker2.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker2.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker2.getUrl()).andReturn(turl.addParameter("name", "invoker2")).anyTimes();
    
    EasyMock.expect(invoker3.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker3.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker3.getUrl()).andReturn(turl.addParameter("name", "invoker3")).anyTimes();
    
    EasyMock.expect(invoker4.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker4.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker4.getUrl()).andReturn(turl.addParameter("name", "invoker4")).anyTimes();
    
    EasyMock.expect(invoker5.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker5.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker5.getUrl()).andReturn(turl.addParameter("name", "invoker5")).anyTimes();
    
    EasyMock.expect(mockedInvoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(mockedInvoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(mockedInvoker1.getUrl()).andReturn(turl.setProtocol("mock")).anyTimes();
    
    EasyMock.replay(invoker1,invoker2,invoker3,invoker4,invoker5,mockedInvoker1);
    
    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
    cluster_nocheck = new AbstractClusterInvoker(dic,url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
}

源代码5 项目： dubbox 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

源代码6 项目： dubbox-hystrix 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({ "unchecked" })
@Before
public void setUp() throws Exception {
	invocation.setMethodName("sayHello");
    
    invoker1 = EasyMock.createMock(Invoker.class);
    invoker2 = EasyMock.createMock(Invoker.class);
    invoker3 = EasyMock.createMock(Invoker.class);
    invoker4 = EasyMock.createMock(Invoker.class);
    invoker5 = EasyMock.createMock(Invoker.class);
    mockedInvoker1 = EasyMock.createMock(Invoker.class);
    
    URL turl = URL.valueOf("test://test:11/test");
    
    EasyMock.expect(invoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker1.getUrl()).andReturn(turl.addParameter("name", "invoker1")).anyTimes();
    
    EasyMock.expect(invoker2.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker2.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker2.getUrl()).andReturn(turl.addParameter("name", "invoker2")).anyTimes();
    
    EasyMock.expect(invoker3.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker3.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker3.getUrl()).andReturn(turl.addParameter("name", "invoker3")).anyTimes();
    
    EasyMock.expect(invoker4.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker4.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker4.getUrl()).andReturn(turl.addParameter("name", "invoker4")).anyTimes();
    
    EasyMock.expect(invoker5.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker5.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker5.getUrl()).andReturn(turl.addParameter("name", "invoker5")).anyTimes();
    
    EasyMock.expect(mockedInvoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(mockedInvoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(mockedInvoker1.getUrl()).andReturn(turl.setProtocol("mock")).anyTimes();
    
    EasyMock.replay(invoker1,invoker2,invoker3,invoker4,invoker5,mockedInvoker1);
    
    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
    cluster_nocheck = new AbstractClusterInvoker(dic,url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
}

源代码7 项目： dubbox-hystrix 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

源代码8 项目： dubbo3 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({ "unchecked" })
@Before
public void setUp() throws Exception {
	invocation.setMethodName("sayHello");
    
    invoker1 = EasyMock.createMock(Invoker.class);
    invoker2 = EasyMock.createMock(Invoker.class);
    invoker3 = EasyMock.createMock(Invoker.class);
    invoker4 = EasyMock.createMock(Invoker.class);
    invoker5 = EasyMock.createMock(Invoker.class);
    mockedInvoker1 = EasyMock.createMock(Invoker.class);
    
    URL turl = URL.valueOf("test://test:11/test");
    
    EasyMock.expect(invoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker1.getUrl()).andReturn(turl.addParameter("name", "invoker1")).anyTimes();
    
    EasyMock.expect(invoker2.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker2.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker2.getUrl()).andReturn(turl.addParameter("name", "invoker2")).anyTimes();
    
    EasyMock.expect(invoker3.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker3.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker3.getUrl()).andReturn(turl.addParameter("name", "invoker3")).anyTimes();
    
    EasyMock.expect(invoker4.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker4.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker4.getUrl()).andReturn(turl.addParameter("name", "invoker4")).anyTimes();
    
    EasyMock.expect(invoker5.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker5.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker5.getUrl()).andReturn(turl.addParameter("name", "invoker5")).anyTimes();
    
    EasyMock.expect(mockedInvoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(mockedInvoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(mockedInvoker1.getUrl()).andReturn(turl.setProtocol("mock")).anyTimes();
    
    EasyMock.replay(invoker1,invoker2,invoker3,invoker4,invoker5,mockedInvoker1);
    
    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
    cluster_nocheck = new AbstractClusterInvoker(dic,url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
}

源代码9 项目： dubbo3 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

源代码10 项目： dubbox 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({ "unchecked" })
@Before
public void setUp() throws Exception {
	invocation.setMethodName("sayHello");
    
    invoker1 = EasyMock.createMock(Invoker.class);
    invoker2 = EasyMock.createMock(Invoker.class);
    invoker3 = EasyMock.createMock(Invoker.class);
    invoker4 = EasyMock.createMock(Invoker.class);
    invoker5 = EasyMock.createMock(Invoker.class);
    mockedInvoker1 = EasyMock.createMock(Invoker.class);
    
    URL turl = URL.valueOf("test://test:11/test");
    
    EasyMock.expect(invoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker1.getUrl()).andReturn(turl.addParameter("name", "invoker1")).anyTimes();
    
    EasyMock.expect(invoker2.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker2.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker2.getUrl()).andReturn(turl.addParameter("name", "invoker2")).anyTimes();
    
    EasyMock.expect(invoker3.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker3.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker3.getUrl()).andReturn(turl.addParameter("name", "invoker3")).anyTimes();
    
    EasyMock.expect(invoker4.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker4.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker4.getUrl()).andReturn(turl.addParameter("name", "invoker4")).anyTimes();
    
    EasyMock.expect(invoker5.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker5.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker5.getUrl()).andReturn(turl.addParameter("name", "invoker5")).anyTimes();
    
    EasyMock.expect(mockedInvoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(mockedInvoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(mockedInvoker1.getUrl()).andReturn(turl.setProtocol("mock")).anyTimes();
    
    EasyMock.replay(invoker1,invoker2,invoker3,invoker4,invoker5,mockedInvoker1);
    
    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
    cluster_nocheck = new AbstractClusterInvoker(dic,url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
}

源代码11 项目： dubbox 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

源代码12 项目： dubbox 文件： AbstractClusterInvokerTest.java

@SuppressWarnings({ "unchecked" })
@Before
public void setUp() throws Exception {
	invocation.setMethodName("sayHello");
    
    invoker1 = EasyMock.createMock(Invoker.class);
    invoker2 = EasyMock.createMock(Invoker.class);
    invoker3 = EasyMock.createMock(Invoker.class);
    invoker4 = EasyMock.createMock(Invoker.class);
    invoker5 = EasyMock.createMock(Invoker.class);
    mockedInvoker1 = EasyMock.createMock(Invoker.class);
    
    URL turl = URL.valueOf("test://test:11/test");
    
    EasyMock.expect(invoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker1.getUrl()).andReturn(turl.addParameter("name", "invoker1")).anyTimes();
    
    EasyMock.expect(invoker2.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker2.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker2.getUrl()).andReturn(turl.addParameter("name", "invoker2")).anyTimes();
    
    EasyMock.expect(invoker3.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker3.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker3.getUrl()).andReturn(turl.addParameter("name", "invoker3")).anyTimes();
    
    EasyMock.expect(invoker4.isAvailable()).andReturn(true).anyTimes();
    EasyMock.expect(invoker4.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker4.getUrl()).andReturn(turl.addParameter("name", "invoker4")).anyTimes();
    
    EasyMock.expect(invoker5.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(invoker5.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(invoker5.getUrl()).andReturn(turl.addParameter("name", "invoker5")).anyTimes();
    
    EasyMock.expect(mockedInvoker1.isAvailable()).andReturn(false).anyTimes();
    EasyMock.expect(mockedInvoker1.getInterface()).andReturn(IHelloService.class).anyTimes();
    EasyMock.expect(mockedInvoker1.getUrl()).andReturn(turl.setProtocol("mock")).anyTimes();
    
    EasyMock.replay(invoker1,invoker2,invoker3,invoker4,invoker5,mockedInvoker1);
    
    invokers.add(invoker1);
    dic = new StaticDirectory<IHelloService>(url, invokers, null);
    cluster = new AbstractClusterInvoker(dic) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
    cluster_nocheck = new AbstractClusterInvoker(dic,url.addParameterIfAbsent(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Boolean.FALSE.toString())) {
        @Override
        protected Result doInvoke(Invocation invocation, List invokers, LoadBalance loadbalance)
                throws RpcException {
            return null;
        }
    };
    
}

源代码13 项目： dubbox 文件： FileRouterEngineTest.java

private void initDic(URL url) {
    dic = new StaticDirectory<FileRouterEngineTest>(url, invokers, Arrays.asList(routerFactory.getRouter(url)));
}

类所在包

com.alibaba.dubbo.rpc

类方法

同包方法

com.alibaba.dubbo.rpc.RpcContext

com.alibaba.dubbo.rpc.Invocation

com.alibaba.dubbo.rpc.Invoker

com.alibaba.dubbo.rpc.RpcException

com.alibaba.dubbo.rpc.Result

com.alibaba.dubbo.rpc.Filter

com.alibaba.dubbo.rpc.service.GenericService

com.alibaba.dubbo.rpc.RpcResult

com.alibaba.dubbo.rpc.RpcInvocation

com.alibaba.dubbo.rpc.support.RpcUtils

com.alibaba.dubbo.rpc.protocol.dubbo.FutureAdapter

com.alibaba.dubbo.rpc.cluster.LoadBalance

com.alibaba.dubbo.rpc.Exporter

com.alibaba.dubbo.rpc.service.GenericException

com.alibaba.dubbo.rpc.Protocol

com.alibaba.dubbo.rpc.cluster.loadbalance.RandomLoadBalance

com.alibaba.dubbo.rpc.ProxyFactory

com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol

com.alibaba.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance

com.alibaba.dubbo.rpc.service.EchoService

com.alibaba.dubbo.rpc.cluster.directory.StaticDirectory

com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker

com.alibaba.dubbo.rpc.protocol.dubbo.filter.FutureFilter

com.alibaba.dubbo.rpc.protocol.AbstractInvoker

com.alibaba.dubbo.rpc.protocol.AbstractProxyProtocol

com.alibaba.dubbo.rpc.cluster.loadbalance.LeastActiveLoadBalance

com.alibaba.dubbo.rpc.proxy.InvokerInvocationHandler

com.alibaba.dubbo.rpc.cluster.Directory

com.alibaba.dubbo.rpc.cluster.support.AvailableCluster

com.alibaba.dubbo.rpc.cluster.Cluster

com.alibaba.dubbo.rpc.cluster.router.MockInvoker

com.alibaba.dubbo.rpc.listener.ListenerExporterWrapper

com.alibaba.dubbo.rpc.protocol.AbstractProtocol

com.alibaba.dubbo.rpc.support.MyInvoker

com.alibaba.dubbo.rpc.support.MockProtocol

com.alibaba.dubbo.rpc.ExporterListener

com.alibaba.dubbo.rpc.support.MockInvoker

com.alibaba.dubbo.rpc.cluster.configurator.AbstractConfigurator

com.alibaba.dubbo.rpc.support.ProtocolUtils

com.alibaba.dubbo.rpc.protocol.dubbo.support.RemoteService

com.alibaba.dubbo.rpc.cluster.support.FailoverCluster

com.alibaba.dubbo.rpc.cluster.Router

com.alibaba.dubbo.rpc.cluster.directory.AbstractDirectory

com.alibaba.dubbo.rpc.cluster.RouterFactory

com.alibaba.dubbo.rpc.cluster.Configurator

com.alibaba.dubbo.rpc.filter.tps.TPSLimiter

com.alibaba.dubbo.rpc.protocol.dubbo.support.DemoService

com.alibaba.dubbo.rpc.support.Type

com.alibaba.dubbo.rpc.protocol.dubbo.support.RemoteServiceImpl

com.alibaba.dubbo.rpc.protocol.dubbo.filter.TraceFilter

com.alibaba.dubbo.rpc.cluster.router.script.ScriptRouterFactory

com.alibaba.dubbo.rpc.protocol.injvm.InjvmProtocol

com.alibaba.dubbo.rpc.support.MockInvocation

com.alibaba.dubbo.rpc.protocol.dubbo.support.ProtocolUtils

com.alibaba.dubbo.rpc.protocol.dubbo.DubboInvoker

com.alibaba.dubbo.rpc.RpcStatus

com.alibaba.dubbo.rpc.cluster.router.MockInvokersSelector

com.alibaba.dubbo.rpc.protocol.dubbo.support.Type

com.alibaba.dubbo.rpc.InvokerListener

com.alibaba.dubbo.rpc.cluster.ConfiguratorFactory

com.alibaba.dubbo.rpc.protocol.InvokerWrapper

com.alibaba.dubbo.rpc.cluster.merger.MergerFactory

com.alibaba.dubbo.rpc.protocol.AbstractExporter

com.alibaba.dubbo.rpc.protocol.dubbo.support.NonSerialized

com.alibaba.dubbo.rpc.cluster.filter.DemoService

com.alibaba.dubbo.rpc.protocol.rest.support.ContentType

com.alibaba.dubbo.rpc.filter.tps.DefaultTPSLimiter

com.alibaba.dubbo.rpc.cluster.support.AbstractClusterInvoker

com.alibaba.dubbo.rpc.cluster.support.ClusterUtils

com.alibaba.dubbo.rpc.cluster.Merger

com.alibaba.dubbo.rpc.protocol.dubbo.support.DemoServiceImpl

com.alibaba.dubbo.rpc.CustomArgument

com.alibaba.dubbo.rpc.support.DemoService

com.alibaba.dubbo.rpc.proxy.AbstractProxyFactory

com.alibaba.dubbo.rpc.listener.ListenerInvokerWrapper

com.alibaba.dubbo.rpc.StaticContext

com.alibaba.dubbo.rpc.protocol.thrift.io.RandomAccessByteArrayOutputStream

com.alibaba.dubbo.rpc.protocol.dubbo.DubboExporter

com.alibaba.dubbo.rpc.cluster.support.FailfastCluster

com.alibaba.dubbo.rpc.protocol.thrift.ThriftUtils

com.alibaba.dubbo.rpc.protocol.thrift.ThriftCodec

com.alibaba.dubbo.rpc.ServiceClassHolder

com.alibaba.dubbo.rpc.gen.dubbo.Demo

com.alibaba.dubbo.rpc.protocol.thrift.ext.MultiServiceProcessor

com.alibaba.dubbo.rpc.gen.thrift.Demo

com.alibaba.dubbo.rpc.protocol.hessian.HessianServiceImpl.MyException

com.alibaba.dubbo.rpc.cluster.router.script.ScriptRouter

com.alibaba.dubbo.rpc.benchmark.AbstractClientRunnable

com.alibaba.dubbo.rpc.benchmark.DemoService

com.alibaba.dubbo.rpc.benchmark.ServiceFactory