Skip to content

Commit a718948

Browse files
committed
RPC测试代码类
1 parent a5229a9 commit a718948

File tree

1 file changed

+31
-0
lines changed

1 file changed

+31
-0
lines changed

src/org/jee/rpc/RpcTest.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
package org.jee.rpc;
2+
3+
import java.io.IOException;
4+
import java.net.InetSocketAddress;
5+
6+
/**
7+
* 描述:RPC测试代码类
8+
* Created by bysocket on 16/2/29.
9+
*/
10+
public class RpcTest {
11+
public static void main(String[] args) {
12+
// 启动服务提供者
13+
new Thread(new Runnable() {
14+
@Override
15+
public void run() {
16+
try {
17+
RpcExporter.exporter("localhost",8088);
18+
} catch (IOException e) {
19+
e.printStackTrace();
20+
}
21+
}
22+
}).start();
23+
24+
// 创建服务本地代理
25+
RpcImporter<EchoService> importer = new RpcImporter<>();
26+
27+
// 从服务本地代理获取服务对象类
28+
EchoService echo = importer.importer(EchoServiceImpl.class,new InetSocketAddress("localhost",8088));
29+
System.out.println(echo.echo("Are you OK?"));
30+
}
31+
}

0 commit comments

Comments
 (0)