1、RPC

RPC是Remote Procedure Call的简称，中文叫远程过程调用。

RPC 框架的目标就是让远程服务调用更加简单、透明，RPC 框架负责屏蔽底层的传输方式（TCP 或者 UDP或者HTTP）、序列化方式（XML/Json/ 二进制）和通信细节。服务调用者可以像调用本地接口一样调用远程的服务提供者，而不需要关心底层通信细节和调用过程，使得开发网络分布式程序在内的应用程序更加容易。

说的白话一点，可以这么理解：现在有两台服务器A和B。部署在A服务器上的应用，想调用部署在B服务器上的另一个应用提供的方法，由于不在一个内存空间，不能直接调用，需要通过网络来达到调用的效果。

现在，我们在A服务的一个本地方法中封装调用B的逻辑，然后只需要在本地使用这个方法，就达到了调用B的效果。对使用者来说，屏蔽了细节。你只需要知道调用这个方法返回的结果，而无需关注底层逻辑。

那，从封装的那个方法角度来看，调用B之前我们需要知道什么？

当然是一些约定。比如：
1、调用的语义，也可以理解为接口规范。(比如RESTful)
2、网络传输协议。 (比如HTTP)
3、数据序列化反序列化规范(比如JSON)。

有了这些约定，我就知道如何给你发数据，发什么样的数据，你返回给我的又是什么样的数据。

从上图中可以看出，RPC是一种客户端-服务端（Client/Server）模式。

HTTP 和 RPC 有什么区别？

首先这个问题本身不太严谨。HTTP只是一个通信协议，工作在OSI第七层。而RPC是一个完整的远程调用方案。它包含了:接口规范、传输协议、数据序列化反序列化规范。

这样看，RPC和 HTTP的关系只可能是包含关系。为什么是可能？因为RPC传输协议那块我可以不基于HTTP，可以基于TCP或UDP。

所以这个问题应该改成:基于HTTP的远程调用方案 (如:HTTP+RESTful+JSON) 和直接使用RPC远程调用方案有什么区别。

业界主流的 RPC 框架整体上分为三类：

• 支持多语言的 RPC 框架，比较成熟的有 Google 的 gRPC、Apache（Facebook）的 Thrift；
• 只支持特定语言的 RPC 框架，例如新浪微博的 Motan；
• 支持服务治理等服务化特性的分布式服务框架，其底层内核仍然是 RPC 框架, 例如阿里的
  Dubbo。《秒懂Dubbo框架（原理篇）》

---

2、gRPC

gRPC，则是RPC的一种，它是免费且开源的，由谷歌出品，主要面向移动应用开发且基于HTTP/2协议标准而设计，同时支持大多数流行的编程语言。

gRPC的典型特征就是使用protobuf（全称protocol buffers）作为其接口定义语言（Interface Definition Language，缩写IDL），同时底层的消息交换格式也是使用protobuf。

gRPC要求client存放一个stub（存根：提供与服务器相同的方法和功能），stub由gRPC框架自动生成。有了stub后，开发人员只需要关心具体的业务逻辑，而不需要关心网络通信相关实现原理。

client的stub是由编译.protoc文件后gRPC这个框架自动生成的，可以利用插件快速将.proto文件生成gRPC需要的stub。

参考文：

《什么是 gRPC ？什么是 RPC?》：大白话，首先解释了rpc，再解释rpc和gprc的关系，解释得很直白与明白。

《gRPC详解》

《初识gRPC》

《.net高级面试进阶篇(一)：GRPC》

多线程python

《Python 中的并发编程和异步编程》

《Python threading实现多线程 基础篇》

grpc代码

1、安装python需要的库：

安装grpc

pip install grpcio

安装gRPC tools

pip install grpcio-tools 

注：gRPC tools包含了protobuf的编译器protoc，以及编译插件grpc_python_out（后面编译会用到）。且里面已经自动安装了protobuf库，不用再单独 pip install protobuf 安装了。

---

2、grpc编程步骤

python实现grpc需要以下步骤：

1、编写.proto文件，即定义接口和数据类型规范
2、通过编译.proto文件 生成2份存根文件
3、编写服务端代码
4、编写客户端代码

---

3、Demo1

目录结构如下：

具体可以采用如下命令查看：

apt-get install tree

tree ./

3.1、编写 .proto文件，定义接口和数据类型

关于具体的proto常见语法可参考：《gRPC之proto语法》

// helloworld.proto：定义接口和数据类型规范

// 限定该文件使用的是proto3的语法
syntax = "proto3";

// 可以为proto文件指定包名，防止消息命名冲突
package helloworld;

// 基础Demo
service Greeter {
    //一个服务中可以定义多个接口，也就是多个函数功能。
    //   方法名      方法参数                 返回值
    rpc SayHello (HelloRequest) returns (HelloResponse) {} 
}

// 简单请求
message HelloRequest {
    string name = 1; //数字1是参数的位置顺序，并不是对参数赋值
}

// 简单响应
message HelloResponse {
    string message = 1;
}

3.2、编译 .proto文件生成存根文件

利用编译工具把 .proto文件转化成 .py文件，直接在当前文件目录下运行下方代码即可。

cd test0_zct

python3 -m grpc_tools.protoc -I./proto --python_out=. --grpc_python_out=. proto/helloworld.proto

参数说明：

1. -m 指定通过protoc工具自动生成 .py文件（即存根文件）
2. -I 指定 .proto所在目录
3. –python_out指定生成.py文件的输出路径
4. hello.proto 输入的.proto文件

编译后会生成如下图所示，helloworld_pb2.py和helloworld_pb2_grpc.py两份存根文件（stub）。大致可以理解为：_pb2中定义了数据结构，_pb2_grpc中定义了相关的方法。

3.3、编写服务器端代码：

vim hello_server.py

代码内容如下：

# -*- coding: utf-8 -*-
# hello_server.py
'''
服务器端代码
'''

import grpc
from concurrent import futures
import helloworld_pb2
import helloworld_pb2_grpc

class Hello(helloworld_pb2_grpc.GreeterServicer):
    '''
    实现在helloworld.proto中'service'定义的SayHello方法。说明：

    1、定义一个类，要继承父类GreeterServicer。
    这里为何是GreeterServicer？因为helloworld_pb2_grpc.py是通过helloworld.proto编译后自动生成的，
    而在helloworld.proto文件中定义的'service'名为'Greeter'，编译后会自动生成'名+Servcier'，
    继承'GreeterServicer'就相当于是helloworld.proto的service Greeter。

    2、初始化

    3、具体实现SayHello方法。注意该方法的参数和返回值，要和helloworld.proto中'service'定义的SayHello方法相对应。
    此方法虽存在服务器端，但是通过rpc，客户端可以实现远程调用。
    具体实现细节是客户端可以调用本地的存根文件里的方法。存根文件来源于编译.proto文件后，grpc自动生成的。
    '''
    def __init__(self):
        pass

    def SayHello(self, request, context):
        '''
        这里具体实现之前定义的SayHello()
        :param request: request是在.proto文件中定义的HelloRequest消息类型
        :param context: context是保留字段，这里不用管
        :return: .proto文件中定义的HelloResponse类型
        '''
        # message = 'Hello {msg}'.format(msg=request.name)
        # return helloworld_pb2.HelloResponse(message)
        return helloworld_pb2.HelloResponse(message='Hello {msg}'.format(msg=request.name))

def serve():
    '''
    模拟服务启动
    :return:
    '''
    # 这里通过thread pool来并发处理server的任务
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    # 将对应的任务处理函数添加到rpc server中
    helloworld_pb2_grpc.add_GreeterServicer_to_server(Hello(), server)
    # 添加端口
    server.add_insecure_port('[::]:50054')
    # 开始监听
    server.start()
    print('gRPC 服务端已开启，端口为50054...')
    # 堵塞监测本地50054端口，等待接收数据
    server.wait_for_termination()
    # try:
    #     while True:
    #         time.sleep(_ONE_DAY_IN_SECONDS)
    # except KeyboardInterrupt:
    #     server.stop(0)

if __name__ == '__main__':
    serve()

3.4、编写客户端代码：

vim hello_client.py

代码内容如下：

# -*- coding: utf-8 -*-
# hello_client.py
'''
客户端代码
'''

import grpc
import helloworld_pb2, helloworld_pb2_grpc

def run():
    # 本次不使用SSL，所以channel是不安全的
    channel = grpc.insecure_channel('localhost:50054')
    # 客户端实例
    stub = helloworld_pb2_grpc.GreeterStub(channel)
    # 调用服务端方法，这里其实是通过调用client本地的存根文件中方法实现的
    response = stub.SayHello(helloworld_pb2.HelloRequest(name='World'))
    print("Greeter client received: " + response.message)

if __name__ == '__main__':
    run()

3.5、测试

一个终端运行hello_server.py

python3 hello_server.py

另一个终端运行hello_client.py

python3 hello_client.py

运行结果如下