在分布式时代的今天，我们经常使用rpc技术来实现不同机器的系统相互调用。原则上来说系统间跨进程的调用都属于RPC范畴。
RPC的原理
RPC也就是远程过程调用，一般用来实现部署在不同机器的系统之间的相互调用，使得调用方像访问本地资源一样通过网络传输去访问远端系统资源。
在rpc架构种有几个重要的概念（角色）：
- Client code：客户端调用方式代码，也就是我们经常说的消费方。负责发起rpc调用，为调用方客户提供api。
- Server code：服务端提供调用方式代码，简单的，既然有了调用方，那么就得有服务提供方。也就是生产端，服务端实现具体的业务逻辑。
- Serializable/Deserialization：在rpc调用过程中，负责对通过网络传输的数据进行序列化与反序列化，不同的rpc产品有不同的实现方式。主要分为文本和二进制两大类。文本最为常见，就是我们经常使用的xml以及json。二进制的序列化机制包括java原生的序列化机制，也包括常见的Hessian，protobuf，Thrift，MessagePack等。
- Stub proxy：可以看做一个代理对象，屏蔽了rpc调用过程中复杂的网络处理逻辑。使得rpc调用就像是本地调用一样的代码风格。
- Transport：rpc底层的通信传输模块，通过Socket在客户端与服务端之间传递请求以及响应信息
file
常见的RPC框架
常见的RPC框架有RMI，WebService，Thrift，gRPC，Http Client等等。今天着重了解RMI。
RMI
Java RMI是一种基于Java的远程方法调用技术，是Java实现的一种rpc。它能使部署在不同机器上的Java对象之间进行通信，方法调用
RMI有以下几个特点：
- 支持多态性。这是RMI有区别于其他RPC框架的主要优势之一。
- 只支持java语言。
- 使用了java原生的序列化机制。也就是必须实现java.io.Serializable接口。
- 底层基于BIO实现Socket。
由于BIO机制的原因，导致性能较差，所以在高性能的场景下不建议使用RMI。
RMI简单入手
1）创建UserService接口：
public interface UserService extends Remote {
public void save(String username) throws Exception ;
}
2）创建UserServiceImpl实现类
public class UserServiceImpl extends UnicastRemoteObject implements UserService, Serializable {
private static final long serialVersionUID = -9206357578911294402L;
@Override
public void save(String username) throws Exception {
System.out.println("rmi..................username="+username);
}
public UserServiceImpl ()throws Exception{
}
}
服务端的实现要继承UnicastRemoteObject，该类定义了服务调用方与服务提供方对象实例，并建立一对一的连接
3）UserServer服务注册端
public class UserServer {
public static void main(String[] args) throws Exception {
UserService userService = new UserServiceImpl();
//注册服务
LocateRegistry.createRegistry(8866);
Naming.bind("rmi://localhost:8866/userService",userService);
System.out.println("Server code init finish.......................");
}
}
4）UserClient：
public class UserClient {
public static void main(String[] args) throws Exception {
UserService userService = (UserService) Naming.lookup("rmi://localhost:8866/userService");
userService.save("张三");
}
}
5）先运行UserServer的main方法，然后再运行UserClient的main方法。控制台已经打印;
file
RMI穿透防火墙
RMI的通信端口是随机产生的，因此有可能被防火墙拦截。为了防止被拦截，需要强制RMI指定的通信接口。一般通过自定义RMISocketFactory类来实现。
public class UserSocketFactory extends RMISocketFactory {
@Override
public Socket createSocket(String host, int port) throws IOException {
return new Socket(host, port);
}
@Override
public ServerSocket createServerSocket(int port) throws IOException {
if(port == 0){
port = 8866;
}
return new ServerSocket(port);
}
}
然后在使用的时候注入即可：
public static void main(String[] args) throws Exception {
UserService userService = new UserServiceImpl();
//使用UserSocketFactory，指定通信接口，防止防火墙拦截
RMISocketFactory.setSocketFactory(new UserSocketFactory());
//注册服务
LocateRegistry.createRegistry(8866);
Naming.bind("rmi://localhost:8866/userService",userService);
System.out.println("Server code init finish.......................");
}
}
本人水平有限，难免有错误或遗漏之处，望大家指正和谅解，提出宝贵意见，愿与之交流。
