在分布式时代的今天，我们经常使用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.......................");
    }
}

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

常用的RPC架构---RMI

RPC的原理

常见的RPC框架

RMI

RMI简单入手

RMI穿透防火墙

推荐阅读

java村支书

目录