类com.alibaba.dubbo.rpc.protocol.dubbo.support.RemoteService源码实例Demo

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

源代码1 项目: 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");
}
 
源代码2 项目: 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");
}
 
源代码3 项目: 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");
}
 
源代码4 项目: 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");
}
 
源代码5 项目: 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");
}
 
源代码6 项目: 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");
}
 
 类所在包
 类方法
 同包方法