RPC与thrift入门

RPC服务

RPC：Remote Procedure Call，远程过程调用。可类比http服务，简单理解都是一个节点请求另一个节点提供的服务。
区别在于RPC服务建立在TCP/IP协议上，而HTTP服务建立在HTTP协议上。一般来说，RPC服务主要针对大型企业，而HTTP服务主要是针对小企业，因为RPC效率更高，而HTTP服务开发迭代会更快。

thrift协议

thrift是接口定义语言和通讯协议，放在远程的接口，实现跨语言开发。

建立thrift服务的步骤：

1. 服务端建立IDL文件（xx.thrift文件），定义接口（不实现函数）。这里可以选择Python、Java等多种语言。以Python为例：

namespace py example
#consist of 2 parts:struct and service


# struct:字段前需要index
struct Data {
    
    1: string text
    2: i32 id
}

# service：类似interface，只写函数声明，不写方法体
service format_data {
    
    Data do_format(1:Data data),
}

2. 终端输入thrift --gen py xx.thrift；–gen java xx.thrift，生成服务接口文件（gen-language）（如server端用java，client端用python，则生成gen- java和gen-py。

3. server端用java编写server函数，创建服务。import gen-java中的文件，并实现thrift声明的方法（这里只有用python的例子）

import sys
sys.path.append('./gen-py')

from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer
from example.format_data import Processor
from example import ttypes

__HOST = 'localhost'
__PORT = 9000

class FormatDataHandler(object):
    # 实现thrift中定义的函数（service）
    def do_format(self, data):
        print(data.text, data.id)
        # do something
        return ttypes.Data(data.text.upper(), data.id)

# 启动服务
if __name__ == '__main__':
    handler = FormatDataHandler()

    processor = Processor(handler)
    transport = TSocket.TServerSocket(__HOST,__PORT)
    # 传输方式，使用buffer
    tfactory = TTransport.TBufferedTransportFactory()
    # 传输的数据类型：二进制
    pfactory = TBinaryProtocol.TBinaryProtocolFactory()

    # 创建一个thrift 服务
    rpcServer = TServer.TSimpleServer(processor, transport, tfactory, pfactory)

    print('Starting the rpc server at', __HOST, ':', __PORT)
    rpcServer.serve()
    print('done')

4. client端用python编写client函数，消费服务。import gen-py中的文件，并调用server定义的方法

import sys
sys.path.append('./gen-py')
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from example.format_data import Client
from example.format_data import Data
__HOST = 'localhost'
__PORT = 9000

tsocket = TSocket.TSocket(__HOST, __PORT)
transport = TTransport.TBufferedTransport(tsocket)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = Client(protocol)

data=Data('hello world!', 123)
transport.open()

print('client-requests')
res = client.do_format(data)
print('server-answer',res)

transport.close()

5. 运行server→运行client（需要同时运行）