Hadoop中RPC使用
2017-04-21 15:10
218 查看
具体程序如下:
服务端:需要至少2个类1个接口
public LoginService{
public static final long versionID = 1L;
public String login(String name);
}
实现类
public LoginServiceImpl implements LoginService{
public String login(String name){
return name+":loginSuccess";
}
}
启动类
public class Starter {
public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
Builder builder = new RPC.Builder(new Configuration());
builder.setBindAddress("hadoop0").setPort(3000).setProtocol(LoginService.class).setInstance(new LoginServiceImpl());
Server server = builder.build();
server.start();
}
}
客户端:1个接口 1个类
接口:
public LoginService{
public static final long versionID = 1L;
public String login(String name);
}
启动类:
public class Controller {
public static void main(String[] args) throws IOException {
LoginService proxy = RPC.getProxy(LoginService.class, 1L, new InetSocketAddress("hadoop0",3000),new Configuration());
String result = proxy.login("yinchong");
System.out.println(result);
}
}
相关文章推荐
- Hadoop RPC整个使用流程——以DataNode向NameNode注册为例
- Hadoop RPC整个使用流程——以DataNode向NameNode注册为例
- hadoop-Rpc使用实例
- Hadoop V2 RPC框架使用实例
- Hadoop学习笔记—3.Hadoop RPC机制、原理及使用
- 直接使用HADOOP-RPC的编码实例
- 使用Hadoop中的RPC框架
- Hadoop RPC使用方法(1)
- Hadoop学习笔记—3.Hadoop RPC机制的使用
- Hadoop1.X中使用RPC
- 轻松使用Hadoop RPC
- hadoop中RPC的使用方法---DEMO
- Hadoop RPC整个使用流程——以DataNode向NameNode注册为例 4000
- Hadoop的RPC框架使用
- 轻松使用Hadoop RPC
- 轻松使用Hadoop RPC
- 如何使用hadoop RPC机制
- 轻松使用Hadoop RPC
- 使用hadoop中的RPC框架实现远程调用
- Hadoop2.X中使用RPC