• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    python实现Thrift服务端的方法

    近期在项目中存在跨编程语言协作的需求,使用到了Thrift。本文将记录用python实现Thrift服务端的方法。

    环境准备

    编写.thrift文件

    .thrift文件定义了Thrift服务端和Thrift客户端的通信接口,在该文件中定义的接口需由服务端实现,并可被客户端调用。Thrift编译器会调用.thrift文件生成不同语言的thrift代码,用于之后实现thrift服务端或thrift客户端。

    .thrift文件的编写规则可参考Thrift白皮书。下面将以demo.thrift文件举例

    service DemoService{
        string ping(1:string param)
        mapi32,string> get_int_string_mapping_result(1:i32 key, 2:string value)
        bool get_bool_result()
    }

    生成python对应的thrift代码

    使用以下命令可以生成不同语言的thrift代码:

    thrift --gen language> Thrift filename>

     通过thrift-0.9.3.exe --gen py demo.thrift 命令生成python版本的thrift文件,文件夹为gen-py,如下所示:

    编写服务端

    编写服务端server.py,用于实现在demo.thrift文件中定义的接口功能。

    from thrift.transport import TSocket
    from thrift.transport import TTransport
    from thrift.protocol import TBinaryProtocol
    from thrift.server import TServer
    import sys
    
    sys.path.append("./gen-py/")
    from demo import DemoService
    import random
    
    
    class DemoServer:
        def __init__(self):
            self.log = {}
    
        def ping(self, param):
            return "echo:" + param
    
        def get_int_string_mapping_result(self, key, value):
            return {key: value}
    
        def get_bool_result(self):
            return random.choice([True, False])
    
    
    if __name__ == '__main__':
        # 创建处理器
        handler = DemoServer()
        processor = DemoService.Processor(handler)
    
        # 监听端口
        transport = TSocket.TServerSocket(host="0.0.0.0", port=9999)
    
        # 选择传输层
        tfactory = TTransport.TBufferedTransportFactory()
    
        # 选择传输协议
        pfactory = TBinaryProtocol.TBinaryProtocolFactory()
    
        # 创建服务端
        server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory)
    
        # 设置连接线程池数量
        server.setNumThreads(5)
    
        # 启动服务
        server.serve()

    编写客户端用于测试

    编写客户端client.py,用于测试服务端功能是否可用。

    from thrift import Thrift
    from thrift.transport import TSocket
    from thrift.transport import TTransport
    from thrift.protocol import TBinaryProtocol
    import sys
    sys.path.append("./gen-py/")
    
    from demo import DemoService
    
    
    if __name__ == '__main__':
        transport = TSocket.TSocket('127.0.0.1', 9999)
        transport = TTransport.TBufferedTransport(transport)
        protocol = TBinaryProtocol.TBinaryProtocol(transport)
        client = DemoService.Client(protocol)
    
        # 连接服务端
        transport.open()
    
        recv = client.ping("test")
        print(recv)
    
        recv = client.get_int_string_mapping_result(10, "MyThrift")
        print(recv)
    
        recv = client.get_bool_result()
        print(recv)
    
        # 断连服务端
        transport.close()

    编写完成后,整个项目结构如下图所示:

    测试服务端

    运行服务端server.py后,运行客户端client.py,打印的内容如下:

    echo:test
    {10: 'MyThrift'}
    True

    此时客户端能够正常调用服务端所提供的接口。(PS:在调试过程中,也许需要修改gen-py文件夹中Thrift编译器生成的python代码)

    以上就是python实现Thrift服务端的方法的详细内容,更多关于python实现Thrift服务端的资料请关注脚本之家其它相关文章!

    您可能感兴趣的文章:
    • python thrift搭建服务端和客户端测试程序
    • python thrift 实现 单端口多服务的过程
    • python3.7通过thrift操作hbase的示例代码
    • python使用thrift教程的方法示例
    • python利用thrift服务读取hbase数据的方法
    • python 如何用urllib与服务端交互(发送和接收数据)
    • Python连接Java Socket服务端的实现方法
    • python 实现客户端与服务端的通信
    • python网络编程socket实现服务端、客户端操作详解
    • Python Websocket服务端通信的使用示例
    上一篇:利用pygame完成动画精灵和碰撞检测
    下一篇:python 自动刷新网页的两种方法
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    python实现Thrift服务端的方法 python,实现,Thrift,服务,端,