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

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

image

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

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

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,525评论 6 507
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,203评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,862评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,728评论 1 294
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,743评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,590评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,330评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,244评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,693评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,885评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,001评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,723评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,343评论 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,919评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,042评论 1 270
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,191评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,955评论 2 355

推荐阅读更多精彩内容