远程过程调用(Remote Procedure Call)

文章来源

远程调用服务是什么?待会解释。不如先从我们写Hello World服务开始,很简单

本地服务

就一个项目而言,比如一个hello的服务类.先定义一个HelloService接口:

public interface HelloService {
	String sayHello(String name);
}

接着写出实现类:

public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        String result = "hello " + name;
        System.out.println(result);
        return result;
    }
}

然后就可以本地调用了:

public class HelloWorldTest(){
	public static void main(String[] args){
		HelloService helloService = new HelloServiceImpl();
		helloService.sayHello("world");
	}
}

这种服务的提供方和消费方都是本地程序,我们在学习阶段必备. 但是在大的公司企业,项目不再是这种自给自足的项目了。 项目也需要开始分工合作,共用的服务有专人维护,并且给其它项目提供服务接口。于是我们可能采用如下方式:

基于HTTP协议的Web Service

随着项目的扩大,项目开始进行业务拆分及封装。 一个项目需要调用另外一个项目的服务,同时也可能给其它项目提供服务。

于是,一种简单的做法是,将项目部署成一个基于HTTP协议的Web Service 服务的提供方server需要向外发布所提供服务的HTTP调用接口约定文档。如:

GET /server-url/hello?name={name} HTTP/1.1
Host server-host
HTTP/1.1 200 OK

Hello {name}

此时服务消费方client通过发送HTTP请求获取服务的结果,通过http,我们现在一个服务可以供其它所有项目同时使用了,既有方便的地方也有不足之处。

优点

跨平台

缺点

client调用复杂,每调用一个服务都要写一坨网络通信的代码,容易出错;性能不如基于TCP协议的RPC(两方面 传输方式及序列化)

如何发布自己的服务?

如何让别人使用我们的服务呢?有同学说很简单嘛,告诉使用者服务的IP以及端口就可以了啊。确实是这样,这里问题的关键在于是自动告知还是人肉告知。

人肉告知的方式:如果你发现你的服务一台机器不够,要再添加一台,这个时候就要告诉调用者我现在有两个ip了,你们要轮询调用来实现负载均衡;调用者咬咬牙改了,结果某天一台机器挂了,调用者发现服务有一半不可用,他又只能手动修改代码来删除挂掉那台机器的ip。现实生产环境当然不会使用人肉方式。

有没有一种方法能实现自动告知,即机器的增添、剔除对调用方透明,调用者不再需要写死服务提供方地址?当然可以,现如今zookeeper被广泛用于实现服务自动注册与发现功能!

简单来讲,zookeeper可以充当一个服务注册表(Service Registry),让多个服务提供者形成一个集群,让服务消费者通过服务注册表获取具体的服务访问地址(ip+端口)去访问具体的服务提供者。如下图所示:

zookeeper

具体来说,zookeeper就是个分布式文件系统,每当一个服务提供者部署后都要将自己的服务注册到zookeeper的某一路径上: /{service}/{version}/{ip:port}, 比如我们的HelloWorldService部署到两台机器,那么zookeeper上就会创建两条目录:分别为/HelloWorldService/1.0.0/100.19.20.01:16888 /HelloWorldService/1.0.0/100.19.20.02:16888。

zookeeper提供了“心跳检测”功能,它会定时向各个服务提供者发送一个请求(实际上建立的是一个 socket 长连接),如果长期没有响应,服务中心就认为该服务提供者已经“挂了”,并将其剔除,比如100.19.20.02这台机器如果宕机了,那么zookeeper上的路径就会只剩/HelloWorldService/1.0.0/100.19.20.01:16888。

服务消费者会去监听相应路径(/HelloWorldService/1.0.0),一旦路径上的数据有任务变化(增加或减少),zookeeper都会通知服务消费方服务提供者地址列表已经发生改变,从而进行更新。

更为重要的是zookeeper 与生俱来的容错容灾能力(比如leader选举),可以确保服务注册表的高可用性。

如何调用他人的远程服务?

如果有一种方式能让我们像调用本地服务一样调用远程服务,而让调用者对网络通信这些细节透明,那么将大大提高生产力,比如服务消费方在执行helloWorldService.sayHello(“test”)时,实质上调用的是远端的服务。这种方式其实就是RPC(Remote Procedure Call Protocol),在各大互联网公司中被广泛使用,如阿里巴巴的hsf、dubbo(开源)、Facebook的thrift(开源)、Google grpc(开源)、Twitter的finagle等。

我是没有看懂,请参见占利军博客

什么是RPC

什么是RPC?Remote Procedure Call,远程过程调用。也就是说,调用过程代码并不是在调用者本地运行,而是要实现调用者与被调用者二地之间的连接与通信。比较严格的定义是:Remote procedure call (RPC) is a protocol that allows a computer program running on one computer to cause a subroutine on another computer to be executed without the programmer explicitly coding the details for this interaction. When the software in question is written using object-oriented principles, RPC may be referred to as remote invocation or remote method invocation. 这样一讲,容易联想到C/S模式的程序设计,我想是对的。RPC的基本通信模型是基于Client/Server进程间相互通信模型的一种同步通信形式;它对Client提供了远程服务的过程抽象,其底层消息传递操作对Client是透明的。在RPC中,Client即是请求服务的调用者(Caller),而Server则是执行Client的请求而被调用的程序 (Callee)。

一些开源的RPC框架

https://github.com/alibaba/dubbo

http://thrift.apache.org/