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为例:

《JAVA常用的RPC框架》 image

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

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框架)

《JAVA常用的RPC框架》 image

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

欢迎加入学习交流群569772982,大家一起学习交流

    原文作者:java部落
    原文地址: https://www.jianshu.com/p/22bb1bac5820
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞