在分布式时代的今天，我们经常使用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在客户端与服务端之间传递请求以及响应信息

常见的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方法。控制台已经打印;

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.......................");
 }
 }

本人水平有限，难免有错误或遗漏之处，望大家指正和谅解，提出宝贵意见，愿与之交流。