联系人列表为空，请先登录

  1. 查询
  2. 包列表
  3. 类列表
  4. 类:com.alibaba.dubbo.rpc.service.EchoService

类com.alibaba.dubbo.rpc.service.EchoService源码实例Demo

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

源代码1 项目： dubbo-2.6.5   文件： RmiProtocolTest.java 
@Ignore
@Test
public void testRmiProtocol_echoService() throws Exception {
    DemoService service = new DemoServiceImpl();
    Exporter<?> rpcExporter = protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
    assertEquals(echo.$echo("test"), "test");
    assertEquals(echo.$echo("abcdefg"), "abcdefg");
    assertEquals(echo.$echo(1234), 1234);

    rpcExporter.unexport();

    RemoteService remoteService = new RemoteServiceImpl();
    rpcExporter = protocol.export(proxy.getInvoker(remoteService, RemoteService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));

    // cast to EchoService
    echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
    assertEquals(echo.$echo("test"), "test");
    assertEquals(echo.$echo("abcdefg"), "abcdefg");
    assertEquals(echo.$echo(1234), 1234);

    rpcExporter.unexport();
}
源代码2 项目： dubbo-2.6.5   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));

    RemoteService remote = new RemoteServiceImpl();
    protocol.export(proxy.getInvoker(remote, RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));

    service.sayHello("world");

    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));

    EchoService serviceEcho = (EchoService) service;
    assertEquals(serviceEcho.$echo("test"), "test");

    EchoService remoteEecho = (EchoService) remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码3 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception
{
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    
    RemoteService remote = new RemoteServiceImpl();
    protocol.export(proxy.getInvoker(remote, RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    
    service.sayHello("world");
    
    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));
    
    EchoService serviceEcho = (EchoService)service;
    assertEquals(serviceEcho.$echo("test"), "test");
    
    EchoService remoteEecho = (EchoService)remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码4 项目： dubbox   文件： AbstractProxyFactory.java 
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i ++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
    }
    return getProxy(invoker, interfaces);
}
源代码5 项目： dubbox   文件： RmiProtocolTest.java 
@Ignore
@Test
public void testRmiProtocol_echoService() throws Exception
   {
    DemoService service = new DemoServiceImpl();
    Exporter<?> rpcExporter = protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       
    // cast to EchoService
       EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
       
       RemoteService remoteService = new RemoteServiceImpl();
       rpcExporter = protocol.export(proxy.getInvoker(remoteService, RemoteService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       
       // cast to EchoService
       echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
   }
源代码6 项目： dubbox-hystrix   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception
{
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    
    RemoteService remote = new RemoteServiceImpl();
    protocol.export(proxy.getInvoker(remote, RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    
    service.sayHello("world");
    
    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));
    
    EchoService serviceEcho = (EchoService)service;
    assertEquals(serviceEcho.$echo("test"), "test");
    
    EchoService remoteEecho = (EchoService)remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码7 项目： dubbox-hystrix   文件： AbstractProxyFactory.java 
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i ++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
    }
    return getProxy(invoker, interfaces);
}
源代码8 项目： dubbox-hystrix   文件： RmiProtocolTest.java 
@Ignore
@Test
public void testRmiProtocol_echoService() throws Exception
   {
    DemoService service = new DemoServiceImpl();
    Exporter<?> rpcExporter = protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       
    // cast to EchoService
       EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
       
       RemoteService remoteService = new RemoteServiceImpl();
       rpcExporter = protocol.export(proxy.getInvoker(remoteService, RemoteService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       
       // cast to EchoService
       echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
   }
源代码9 项目： dubbo-spring-boot-starter   文件： DubboHealthIndicator.java 
@Override
public void doHealthCheck(Health.Builder builder) throws Exception {
  boolean up = true;
  for (ClassIdBean classIdBean : ConsumerSubscribeListener.SUBSCRIBEDINTERFACES_SET) {
    Object service = DubboConsumerAutoConfiguration.getDubboReference(classIdBean);
    EchoService echoService = (EchoService) service;
    if (echoService != null) {
      try {
        echoService.$echo("Hello");
        builder.withDetail(classIdBean.toString(), Status.UP.getCode());
      } catch (Throwable t) {
        up = false;
        builder.withDetail(classIdBean.toString(),
            Status.DOWN.getCode() + ", message: " + t.getMessage());
      }
    }
  }
  if (up) {
    builder.up();
  } else {
    builder.down();
  }
}
源代码10 项目： dubbo3   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception
{
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    
    RemoteService remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));

    service.sayHello("world");

    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));
    
    EchoService serviceEcho = (EchoService)service;
    assertEquals(serviceEcho.$echo("test"), "test");
    
    EchoService remoteEecho = (EchoService)remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码11 项目： dubbo3   文件： AbstractProxyFactory.java 
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i ++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
    }
    return getProxy(invoker, interfaces);
}
源代码12 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception
{
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    
    RemoteService remote = new RemoteServiceImpl();
    protocol.export(proxy.getInvoker(remote, RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    
    service.sayHello("world");
    
    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));
    
    EchoService serviceEcho = (EchoService)service;
    assertEquals(serviceEcho.$echo("test"), "test");
    
    EchoService remoteEecho = (EchoService)remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码13 项目： dubbox   文件： AbstractProxyFactory.java 
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i ++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
    }
    return getProxy(invoker, interfaces);
}
源代码14 项目： dubbox   文件： RmiProtocolTest.java 
@Ignore
@Test
public void testRmiProtocol_echoService() throws Exception
   {
    DemoService service = new DemoServiceImpl();
    Exporter<?> rpcExporter = protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       
    // cast to EchoService
       EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
       
       RemoteService remoteService = new RemoteServiceImpl();
       rpcExporter = protocol.export(proxy.getInvoker(remoteService, RemoteService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       
       // cast to EchoService
       echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
   }
源代码15 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolMultiService() throws Exception
{
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    
    RemoteService remote = new RemoteServiceImpl();
    protocol.export(proxy.getInvoker(remote, RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    remote = proxy.getProxy(protocol.refer(RemoteService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + RemoteService.class.getName())));
    
    service.sayHello("world");
    
    // test netty client
    assertEquals("world", service.echo("world"));
    assertEquals("hello [email protected]" + RemoteServiceImpl.class.getName(), remote.sayHello("world"));
    
    EchoService serviceEcho = (EchoService)service;
    assertEquals(serviceEcho.$echo("test"), "test");
    
    EchoService remoteEecho = (EchoService)remote;
    assertEquals(remoteEecho.$echo("ok"), "ok");
}
源代码16 项目： dubbox   文件： AbstractProxyFactory.java 
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i ++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
    }
    return getProxy(invoker, interfaces);
}
源代码17 项目： dubbox   文件： RmiProtocolTest.java 
@Ignore
@Test
public void testRmiProtocol_echoService() throws Exception
   {
    DemoService service = new DemoServiceImpl();
    Exporter<?> rpcExporter = protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       
    // cast to EchoService
       EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/TestService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
       
       RemoteService remoteService = new RemoteServiceImpl();
       rpcExporter = protocol.export(proxy.getInvoker(remoteService, RemoteService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       
       // cast to EchoService
       echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("rmi://127.0.0.1:9002/remoteService")));
       assertEquals(echo.$echo("test"), "test");
       assertEquals(echo.$echo("abcdefg"), "abcdefg");
       assertEquals(echo.$echo(1234), 1234);
       
       rpcExporter.unexport();
   }
源代码18 项目： dubbo-2.6.5   文件： AbstractProxyFactory.java 
@Override
public <T> T getProxy(Invoker<T> invoker, boolean generic) throws RpcException {
    Class<?>[] interfaces = null;
    String config = invoker.getUrl().getParameter("interfaces");
    if (config != null && config.length() > 0) {
        String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
        if (types != null && types.length > 0) {
            interfaces = new Class<?>[types.length + 2];
            interfaces[0] = invoker.getInterface();
            interfaces[1] = EchoService.class;
            for (int i = 0; i < types.length; i++) {
                interfaces[i + 1] = ReflectUtils.forName(types[i]);
            }
        }
    }
    if (interfaces == null) {
        interfaces = new Class<?>[]{invoker.getInterface(), EchoService.class};
    }

    if (!invoker.getInterface().equals(GenericService.class) && generic) {
        int len = interfaces.length;
        Class<?>[] temp = interfaces;
        interfaces = new Class<?>[len + 1];
        System.arraycopy(temp, 0, interfaces, 0, len);
        interfaces[len] = GenericService.class;
    }

    return getProxy(invoker, interfaces);
}
源代码19 项目： dubbo-2.6.5   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocol() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
    assertEquals(service.enumlength(new Type[]{}), Type.Lower);
    assertEquals(service.getSize(null), -1);
    assertEquals(service.getSize(new String[]{"", "", ""}), 3);
    Map<String, String> map = new HashMap<String, String>();
    map.put("aa", "bb");
    Set<String> set = service.keys(map);
    assertEquals(set.size(), 1);
    assertEquals(set.iterator().next(), "aa");
    service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");

    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
    // test netty client
    StringBuffer buf = new StringBuffer();
    for (int i = 0; i < 1024 * 32 + 32; i++)
        buf.append('A');
    System.out.println(service.stringLength(buf.toString()));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
    assertEquals(echo.$echo(buf.toString()), buf.toString());
    assertEquals(echo.$echo("test"), "test");
    assertEquals(echo.$echo("abcdefg"), "abcdefg");
    assertEquals(echo.$echo(1234), 1234);
}
源代码20 项目： dubbo-2.6.5   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolWithMina() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.SERVER_KEY, "mina")));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.CLIENT_KEY, "mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(service.enumlength(new Type[]{}), Type.Lower);
        assertEquals(service.getSize(null), -1);
        assertEquals(service.getSize(new String[]{"", "", ""}), 3);
    }
    Map<String, String> map = new HashMap<String, String>();
    map.put("aa", "bb");
    for (int i = 0; i < 10; i++) {
        Set<String> set = service.keys(map);
        assertEquals(set.size(), 1);
        assertEquals(set.iterator().next(), "aa");
        service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");
    }

    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    // test netty client
    StringBuffer buf = new StringBuffer();
    for (int i = 0; i < 1024 * 32 + 32; i++)
        buf.append('A');
    System.out.println(service.stringLength(buf.toString()));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(echo.$echo(buf.toString()), buf.toString());
        assertEquals(echo.$echo("test"), "test");
        assertEquals(echo.$echo("abcdefg"), "abcdefg");
        assertEquals(echo.$echo(1234), 1234);
    }
}
源代码21 项目： dubbo-samples   文件： Consumer.java 
private void testGetUser() throws Exception {
    try {
        EchoService echoService = (EchoService)userProvider;
        Object status = echoService.$echo("OK");
        System.out.println("echo: "+status);
        User user1 = userProvider.GetUser("A003");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user1.getId() + ", name:" + user1.getName() + ", sex:" + user1.getSex().toString()
                + ", age:" + user1.getAge() + ", time:" + user1.getTime().toString());
        User user2 = userProvider.GetUser0("A003","Moorse");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user2.getId() + ", name:" + user2.getName() + ", sex:" + user2.getSex().toString()
                + ", age:" + user2.getAge() + ", time:" + user2.getTime().toString());
        User user3 = userProvider.getUser(1);
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user3.getId() + ", name:" + user3.getName() + ", sex:" + user3.getSex().toString()
                + ", age:" + user3.getAge() + ", time:" + user3.getTime());
        User user4 = userProvider.getUser(1, "name");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user4.getId() + ", name:" + user4.getName() + ", sex:" + user4.getSex().toString()
                + ", age:" + user4.getAge() + ", time:" + user4.getTime());
        userProvider.GetUser3();
        System.out.println("GetUser3 succ");

        User user9 = userProvider.GetUser1("A003");
    } catch (Throwable e) {
        System.out.println("*************exception***********");
        e.printStackTrace();
    }
    try {
        userProvider.GetErr("A003");
    } catch (Throwable t) {
        System.out.println("*************exception***********");
        t.printStackTrace();
    }
}
源代码22 项目： dubbo-samples   文件： Consumer.java 
private void testGetUser1() throws Exception {
    try {
        EchoService echoService = (EchoService)userProvider1;
        Object status = echoService.$echo("OK");
        System.out.println("echo: "+status);
        User user1 = userProvider1.GetUser("A003");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user1.getId() + ", name:" + user1.getName() + ", sex:" + user1.getSex().toString()
                + ", age:" + user1.getAge() + ", time:" + user1.getTime().toString());
        User user2 = userProvider1.GetUser0("A003","Moorse");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user2.getId() + ", name:" + user2.getName() + ", sex:" + user2.getSex().toString()
                + ", age:" + user2.getAge() + ", time:" + user2.getTime().toString());
        User user3 = userProvider1.getUser(1);
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user3.getId() + ", name:" + user3.getName() + ", sex:" + user3.getSex().toString()
                + ", age:" + user3.getAge() + ", time:" + user3.getTime());
        User user4 = userProvider1.getUser(1, "name");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user4.getId() + ", name:" + user4.getName() + ", sex:" + user4.getSex().toString()
                + ", age:" + user4.getAge() + ", time:" + user4.getTime());
        userProvider1.GetUser3();
        System.out.println("GetUser3 succ");

        User user9 = userProvider1.GetUser1("A003");
    } catch (Throwable e) {
        System.out.println("*************exception***********");
        e.printStackTrace();
    }
    try {
        userProvider1.GetErr("A003");
    } catch (Throwable t) {
        System.out.println("*************exception***********");
        t.printStackTrace();
    }
}
源代码23 项目： dubbo-samples   文件： Consumer.java 
private void testGetUser2() throws Exception {
    try {
        EchoService echoService = (EchoService)userProvider2;
        Object status = echoService.$echo("OK");
        System.out.println("echo: "+status);
        User user1 = userProvider2.GetUser("A003");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user1.getId() + ", name:" + user1.getName() + ", sex:" + user1.getSex().toString()
                + ", age:" + user1.getAge() + ", time:" + user1.getTime().toString());
        User user2 = userProvider2.GetUser0("A003","Moorse");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user2.getId() + ", name:" + user2.getName() + ", sex:" + user2.getSex().toString()
                + ", age:" + user2.getAge() + ", time:" + user2.getTime().toString());
        User user3 = userProvider2.getUser(1);
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user3.getId() + ", name:" + user3.getName() + ", sex:" + user3.getSex().toString()
                + ", age:" + user3.getAge() + ", time:" + user3.getTime());
        User user4 = userProvider2.getUser(1, "name");
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] " +
                " UserInfo, Id:" + user4.getId() + ", name:" + user4.getName() + ", sex:" + user4.getSex().toString()
                + ", age:" + user4.getAge() + ", time:" + user4.getTime());
        userProvider2.GetUser3();
        System.out.println("GetUser3 succ");

        User user9 = userProvider2.GetUser1("A003");
    } catch (Throwable e) {
        System.out.println("*************exception***********");
        e.printStackTrace();
    }
    try {
        userProvider2.GetErr("A003");
    } catch (Throwable t) {
        System.out.println("*************exception***********");
        t.printStackTrace();
    }
}
源代码24 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocol() throws Exception
{
	DemoService service = new DemoServiceImpl();
	protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	assertEquals(service.enumlength(new Type[]{}), Type.Lower);
	assertEquals(service.getSize(null), -1);
	assertEquals(service.getSize(new String[]{"", "", ""}), 3);
	Map<String, String> map = new HashMap<String, String>();
	map.put("aa", "bb");
	Set<String> set = service.keys(map);
	assertEquals(set.size(), 1);
	assertEquals(set.iterator().next(), "aa");
	service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");

	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	// test netty client
	StringBuffer buf = new StringBuffer();
	for(int i=0;i<1024*32+32;i++)
		buf.append('A');
	System.out.println(service.stringLength(buf.toString()));

	// cast to EchoService
	EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	assertEquals(echo.$echo(buf.toString()), buf.toString());
	assertEquals(echo.$echo("test"), "test");
	assertEquals(echo.$echo("abcdefg"), "abcdefg");
	assertEquals(echo.$echo(1234), 1234);
}
源代码25 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolWithMina() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.SERVER_KEY, "mina")));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.CLIENT_KEY, "mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(service.enumlength(new Type[]{}), Type.Lower);
        assertEquals(service.getSize(null), -1);
        assertEquals(service.getSize(new String[]{"", "", ""}), 3);
    }
    Map<String, String> map = new HashMap<String, String>();
    map.put("aa", "bb");
    for(int i = 0; i < 10; i++) {
        Set<String> set = service.keys(map);
        assertEquals(set.size(), 1);
        assertEquals(set.iterator().next(), "aa");
        service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");
    }

    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    // test netty client
    StringBuffer buf = new StringBuffer();
    for (int i = 0; i < 1024 * 32 + 32; i++)
        buf.append('A');
    System.out.println(service.stringLength(buf.toString()));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(echo.$echo(buf.toString()), buf.toString());
        assertEquals(echo.$echo("test"), "test");
        assertEquals(echo.$echo("abcdefg"), "abcdefg");
        assertEquals(echo.$echo(1234), 1234);
    }
}
源代码26 项目： dubbox-hystrix   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocol() throws Exception
{
	DemoService service = new DemoServiceImpl();
	protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	assertEquals(service.enumlength(new Type[]{}), Type.Lower);
	assertEquals(service.getSize(null), -1);
	assertEquals(service.getSize(new String[]{"", "", ""}), 3);
	Map<String, String> map = new HashMap<String, String>();
	map.put("aa", "bb");
	Set<String> set = service.keys(map);
	assertEquals(set.size(), 1);
	assertEquals(set.iterator().next(), "aa");
	service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");

	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	// test netty client
	StringBuffer buf = new StringBuffer();
	for(int i=0;i<1024*32+32;i++)
		buf.append('A');
	System.out.println(service.stringLength(buf.toString()));

	// cast to EchoService
	EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	assertEquals(echo.$echo(buf.toString()), buf.toString());
	assertEquals(echo.$echo("test"), "test");
	assertEquals(echo.$echo("abcdefg"), "abcdefg");
	assertEquals(echo.$echo(1234), 1234);
}
源代码27 项目： dubbox-hystrix   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolWithMina() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.SERVER_KEY, "mina")));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.CLIENT_KEY, "mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(service.enumlength(new Type[]{}), Type.Lower);
        assertEquals(service.getSize(null), -1);
        assertEquals(service.getSize(new String[]{"", "", ""}), 3);
    }
    Map<String, String> map = new HashMap<String, String>();
    map.put("aa", "bb");
    for(int i = 0; i < 10; i++) {
        Set<String> set = service.keys(map);
        assertEquals(set.size(), 1);
        assertEquals(set.iterator().next(), "aa");
        service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");
    }

    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    // test netty client
    StringBuffer buf = new StringBuffer();
    for (int i = 0; i < 1024 * 32 + 32; i++)
        buf.append('A');
    System.out.println(service.stringLength(buf.toString()));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(echo.$echo(buf.toString()), buf.toString());
        assertEquals(echo.$echo("test"), "test");
        assertEquals(echo.$echo("abcdefg"), "abcdefg");
        assertEquals(echo.$echo(1234), 1234);
    }
}
源代码28 项目： dubbo3   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocol() throws Exception
{
	DemoService service = new DemoServiceImpl();
	protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	assertEquals(service.enumlength(new Type[]{}), Type.Lower);
	assertEquals(service.getSize(null), -1);
	assertEquals(service.getSize(new String[]{"", "", ""}), 3);
	Map<String, String> map = new HashMap<String, String>();
	map.put("aa", "bb");
	Set<String> set = service.keys(map);
	assertEquals(set.size(), 1);
	assertEquals(set.iterator().next(), "aa");
	service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");

	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	// test netty client
	StringBuffer buf = new StringBuffer();
	for(int i=0;i<1024*32+32;i++)
		buf.append('A');
	System.out.println(service.stringLength(buf.toString()));

	// cast to EchoService
	EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	assertEquals(echo.$echo(buf.toString()), buf.toString());
	assertEquals(echo.$echo("test"), "test");
	assertEquals(echo.$echo("abcdefg"), "abcdefg");
	assertEquals(echo.$echo(1234), 1234);
}
源代码29 项目： dubbo3   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocolWithMina() throws Exception {
    DemoService service = new DemoServiceImpl();
    protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.SERVER_KEY, "mina")));
    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName()).addParameter(Constants.CLIENT_KEY, "mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(service.enumlength(new Type[]{}), Type.Lower);
        assertEquals(service.getSize(null), -1);
        assertEquals(service.getSize(new String[]{"", "", ""}), 3);
    }
    Map<String, String> map = new HashMap<String, String>();
    map.put("aa", "bb");
    for(int i = 0; i < 10; i++) {
        Set<String> set = service.keys(map);
        assertEquals(set.size(), 1);
        assertEquals(set.iterator().next(), "aa");
        service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");
    }

    service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    // test netty client
    StringBuffer buf = new StringBuffer();
    for (int i = 0; i < 1024 * 32 + 32; i++)
        buf.append('A');
    System.out.println(service.stringLength(buf.toString()));

    // cast to EchoService
    EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=mina")));
    for (int i = 0; i < 10; i++) {
        assertEquals(echo.$echo(buf.toString()), buf.toString());
        assertEquals(echo.$echo("test"), "test");
        assertEquals(echo.$echo("abcdefg"), "abcdefg");
        assertEquals(echo.$echo(1234), 1234);
    }
}
源代码30 项目： dubbox   文件： DubboProtocolTest.java 
@Test
public void testDubboProtocol() throws Exception
{
	DemoService service = new DemoServiceImpl();
	protocol.export(proxy.getInvoker(service, DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName())));
	assertEquals(service.enumlength(new Type[]{}), Type.Lower);
	assertEquals(service.getSize(null), -1);
	assertEquals(service.getSize(new String[]{"", "", ""}), 3);
	Map<String, String> map = new HashMap<String, String>();
	map.put("aa", "bb");
	Set<String> set = service.keys(map);
	assertEquals(set.size(), 1);
	assertEquals(set.iterator().next(), "aa");
	service.invoke("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "", "invoke");

	service = proxy.getProxy(protocol.refer(DemoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	// test netty client
	StringBuffer buf = new StringBuffer();
	for(int i=0;i<1024*32+32;i++)
		buf.append('A');
	System.out.println(service.stringLength(buf.toString()));

	// cast to EchoService
	EchoService echo = proxy.getProxy(protocol.refer(EchoService.class, URL.valueOf("dubbo://127.0.0.1:9010/" + DemoService.class.getName() + "?client=netty")));
	assertEquals(echo.$echo(buf.toString()), buf.toString());
	assertEquals(echo.$echo("test"), "test");
	assertEquals(echo.$echo("abcdefg"), "abcdefg");
	assertEquals(echo.$echo(1234), 1234);
}
 类所在包
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