Hadoop的RPC分析

5imobi

package rpc;　　

　　
import java.io.IOException;
　　

　　
import org.apache.hadoop.conf.Configuration;
　　
import org.apache.hadoop.ipc.ProtocolSignature;
　　
import org.apache.hadoop.ipc.RPC;
　　
import org.apache.hadoop.ipc.RPC.Server;
　　

　　

　　
//动态代理：客户端和服务端同时实现一个接口
　　
//可以在linux和win下   
　　
//不同main进程下相互调用
　　

　　
//是不同进程见的方法调用
　　
//底层走的是jav的rmi
　　


　　
public>　　

　　
public String sayHi(String name) {
　　
return "HI！"+name;
　　
}
　　

　　
public static void main(String[] args) throws Exception {
　　
// TODO Auto-generated method stub
　　
Configuration conf = new Configuration();
　　
//方法的调用连   因为每次调用返回的是this
　　
Server server = new RPC.Builder(conf).setProtocol(RPCable.class).
　　
setInstance(new RPCServer()).setBindAddress("localhost").
　　
setPort(9527).build();
　　
server.start();
　　

　　
}
　　

　　
@Override
　　
public ProtocolSignature getProtocolSignature(String arg0, long arg1,
　　
int arg2) throws IOException {
　　
// TODO Auto-generated method stub
　　
return null;
　　
}
　　

　　
@Override
　　
public long getProtocolVersion(String arg0, long arg1) throws IOException {
　　
// TODO Auto-generated method stub
　　
return 0;
　　
};
　　

　　
}