JAVA常用的RPC框架

RPC(Remote Process Call)，远程过程调用。RPC将本地调用转化为远程调用（非本地调用，个人理解为不同服务器之间的调用），可以降低大项目的维护成本和提高项目的扩展性。

①：降低维护成本：某一个服务有问题，只要停止其中一个去维护升级，其他服务不用关闭。

②：提高项目的扩展性：在现有的基础上，可以增加分支，好比一颗树，可以增加其他树枝，保留现有树枝。

难点：个人认为应该是项目的耦合度问题，如果耦合度太高，相互依赖问题太多，牵一发而动全身的话，上面两点基本可以忽视了。这样的项目只能做成一个。

理解不对的话欢迎拍砖。

当一个项目有RPC需求的时候，如果平时的调用量不是很大，可以直接使用http（appache的HttpClient），调用不同应用之间的服务。使用http的调用一般使用的是json数据格式，进行应用之间的数据传输。这样就会有一个问题，如果我们两个应用之间的数据量很大，比如A应用发送个B应用一个JSON数据格式，用于B应用进行查询后，返回来一个数据库结果集。一方面数据量大，另一方面http的连接和释放本身就需要占用大量的资源，并且不好做服务路由和负载均衡。在这样的背景下（也许是别的背景，我自己YY的，^_^），RPC框架诞生了。

RPC的主流框架：RMI，Hessian，Dubbo等。

对于RPC有一个逻辑关系图，以RMI为例：

                                                                   

这个图，是我从网上找的，稍微解释一下。

server：就是服务端了，服务端把服务写好以后，把他自己的信息注册到注册登记处(Registry)；

Registry：负责登记哪些服务写好了，都来我这里登记一下，登记内容先不管，肯定是我们在Client端拿到这些登记信息能找到服务的。

Clent：这就是消费端了，它去Registry处lookup服务信息，拿到服务信息后 invoke服务的接口。

其他的RPC服务框架大概的流程也是一样的，区别是啥？其实我也没看过具体的原理，只能告诉你我搜到的结论：

区别在于对象的序列化方法，传输对象的通讯协议，以及注册中心的管理与failover设计（利用zookeeper）。

想一个问题，如果数据需要在不同的服务之间调用，那java怎么把数据发送出去，只能序列化了。

如果都序列化好了，那序列化好的数据怎么能快速的传输到别的应用，现实世界我们可以用水管把水放到别的容器，或者用桶，用杯子，用。。。领过去倒入到别的容器中。数据的传输会涉及哪些东西？传输协议。

所以 RPC的主要依赖技术是序列化（准备外传数据）、反序列化（反序列化读取数据）和传输协议，

JAVA里对应的就是对象的序列化、反序列化以及序列化后数据的传输。RMI的序列化和反序列化是JAVA自带的，

Hessian里的序列化和反序列化是私有的，传输协议则是HTTP，

Dubbo的序列化可以多种选择，一般使用Hessian的序列化协议，传输则是TCP协议，使用了高性能的NIO框架Netty

列举RMI的大概实现：

服务端接口定义：

/**
 * Created by 清茶 on 2017/11/21.
 */
public interface AService extends Remote {

    String doSomething(String... param);
}

服务端接口实现：

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

/**
 * @author 清茶
 * @create 2017-11-21 16:39
 */
public class AServiceImpl extends UnicastRemoteObject implements AService {

    private static final long serialVersionUID = 8836190780945225408L;

    protected AServiceImpl() throws RemoteException {
        super();
    }

    @Override
    public String doSomething(String... param) {
        return "hello java rmi";
    }
}

注册管理局实现：

import java.rmi.AlreadyBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

/**
 * @author 清茶
 * @create 2017-11-21 16:56
 */
public class MyRegistry {
    public static void main(String[] args) {
        Registry registry = null;
        try {
            // 创建一个注册管理局
            registry = LocateRegistry.createRegistry(8080);
        } catch (RemoteException e) {
            e.printStackTrace();
        }

        try {
            AService aService = new AServiceImpl();
            // 把A服务注册到管理局
            registry.bind("AService",aService);
        } catch (RemoteException e) {
            e.printStackTrace();
        } catch (AlreadyBoundException e) {
            e.printStackTrace();
        }
    }
}

消费端Client实现：

import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

/**
 * @author 清茶
 * @create 2017-11-21 16:49
 */
public class Client {

    public static void main(String[] args) {

        Registry registry = null;
        try {
            registry = LocateRegistry.getRegistry("127.0.0.1", 8080);
            // 列出所有注册的服务
            String[] listService = registry.list();
            for (String service : listService) {
                // 打印所有的服务
                System.out.println(service);
            }
        } catch (RemoteException e) {
            System.out.println("获取服务注册管理局出错");
        }

        try {
            AService aService = (AService) registry.lookup("AService");
            String result = aService.doSomething("你好","你好","你好","你好","你好","你好");
            System.out.println(result);
        } catch (RemoteException e) {
            System.out.println("获取服务注册管理局出错");
        } catch (NotBoundException e) {
            System.out.println("服务注册管理局没有这个服务注册信息");
        }
    }
}

大概的流程就这样

Dubbo（淘宝开源的基于TCP的RPC框架）

 

 Dubbo的注册管理主要用的就是zookeeper，详细了解Dubbo可以看下阿里的Dubbo介绍，里面很详细。有时间再分析一下它吧