一、基础知识
原理 http://www.cnblogs.com/edisonchou/p/4285817.html，这个谢了一些rpc与hadoop的例子。
用到了java的动态代理，服务端实现一个接口，客户端得到这个接口的实现类，客户端通过自定义的versionID来标志一对服务端和客户端。
二、代码
2.1 接口
package rpc;
import org.apache.hadoop.ipc.VersionedProtocol;
//默认情况下，不同版本号的RPC Client和Server之间不能相互通信，因此客户端和服务端通过版本号标识。
public interface RPCable extends VersionedProtocol {
public static final long versionID = 10010;
public String sayHi(String name) ;
}
我原来没继承VersionedProtocol接口，也成功了。接口不能在实现接口
2.2 服务端
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 class RPCServer implements RPCable{
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;
};
}
我原来没继承VersionedProtocol类，那么服务端不需要下面的两个方法，继承了以后必须写。
2.3 客户端
package rpc;
import java.io.IOException;
import java.net.InetSocketAddress;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
//打印在客户端 拼接字符串确实在服务端
public class RPCClient {
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
//协议一般是.class
RPCable proxy = RPC.getProxy(RPCable.class, 10010,
new InetSocketAddress("localhost",9527), new Configuration());
String res = proxy.sayHi("！！！！！！！！！！！！");
System.out.println(res);
RPC.stopProxy(proxy);
}
}
三、结束
rpc不受系统、地理位置的限制。
不相信的话可以在和护短打断点，一步一步发现进入了；额服务器端。
做的时候如果不知道使用那个类哭下的东西，可以打开对应类的class文件，可能是黑色，不是源码，那么点击attach source找到hadoop的源码包就可以了，导进去就看到的是普通的和咱的java类似的文件，可以看看里面的蚕食来自那个包。
