Python Thrift通信无BUG版

谁践踏了优雅 2023-01-16 06:44 105阅读 0赞

1、安装Thrift包

sudo pip install thrift

2、下载thrift.exe  
从[官网][Link 1] 上下载 windows 版的 thrift.exe：（我这里用的是0.9.3版本）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70]3、将thrift-0.9.3.exe改名为thrift.exe  
4、编写一个简单接IDL文件helloworld.thrift

const string HELLO_WORLD = "world"
    
    service HelloWorld { 
        void ping(),
        string sayHello(),
        string sayMsg(1:string msg)
    }

5、执行thrift.exe（打开命令窗口将路径切换到thrift.exe和helloworld.thrift所在路径下在执行下述命令）

thrift -r --gen py helloworld.thrift

执行完成后生成gen-py文件夹![在这里插入图片描述][20210424163904917.png]  
6、在工程目录thrift下新建一个PythonServer.py（开头部分红色报错没关系，如图）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 1]

import sys
    
    sys.path.append('./gen-py')
    
    from helloworld import HelloWorld
    from helloworld.ttypes import *
    
    from thrift.transport import TSocket
    from thrift.transport import TTransport
    from thrift.protocol import TBinaryProtocol
    from thrift.server import TServer
    
    import socket
    
    
    class HelloWorldHandler:
        def __init__(self):
            self.log = { }
    
        def ping(self):
            print("ping()")
            
    
        def sayHello(self):
            print("sayHello()")
            return "say hello from " + socket.gethostbyname(socket.gethostname())
    
        def sayMsg(self, msg):
            print("sayMsg(" + msg + ")")
            return "say " + msg + " from " + socket.gethostbyname(socket.gethostname())
    
    
    handler = HelloWorldHandler()
    processor = HelloWorld.Processor(handler)
    transport = TSocket.TServerSocket('127.0.0.1', 30303)
    tfactory = TTransport.TBufferedTransportFactory()
    pfactory = TBinaryProtocol.TBinaryProtocolFactory()
    
    server = TServer.TSimpleServer(processor, transport, tfactory, pfactory)
    
    print("Starting python server...")
    server.serve()
    print("done!")

7、在工程目录thrift下新建一个PythonClient.py（开头部分红色报错没关系，如图）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 2]

import sys
    
    sys.path.append('./gen-py')
    
    from helloworld import HelloWorld
    from helloworld.ttypes import *
    from helloworld.constants import *
    
    from thrift import Thrift
    from thrift.transport import TSocket
    from thrift.transport import TTransport
    from thrift.protocol import TBinaryProtocol
    
    try:
        # Make socket
        transport = TSocket.TSocket('127.0.0.1', 30303)
    
        # Buffering is critical. Raw sockets are very slow
        transport = TTransport.TBufferedTransport(transport)
    
        # Wrap in a protocol
        protocol = TBinaryProtocol.TBinaryProtocol(transport)
    
        # Create a client to use the protocol encoder
        client = HelloWorld.Client(protocol)
    
        # Connect!
        transport.open()
    
        client.ping()
        print("ping()")
        
    
        msg = client.sayHello()
        print(msg)
        
        msg = client.sayMsg("HELLO_WORLD")
        print(msg)
        
        transport.close()
    
    except Thrift.TException as tx:
        print("%s" % (tx.message))

8、运行PythonServer，报错。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 3]  
点击红色箭头处，加了个.  
![在这里插入图片描述][20210424165137589.png]![在这里插入图片描述][20210424165203838.png]  
再次运行：  
![在这里插入图片描述][20210424165346960.png]  
9、运行PythonClient，报错。  
![在这里插入图片描述][20210424165452421.png]点击红色箭头处，加了个.  
![在这里插入图片描述][20210424165550341.png]  
![在这里插入图片描述][20210424165602122.png]  
再次运行，成功！！  
![在这里插入图片描述][20210424165625607.png]

[Link 1]: http://archive.apache.org/dist/thrift/0.9.3/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70]: /images/20221022/9954d174403d41628038c1841b7b950f.png
[20210424163904917.png]: /images/20221022/755eb3f0b56a4b6a873dcb727983339a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 1]: /images/20221022/3db45aaafb864b27a1de61103ed3db2e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 2]: /images/20221022/e781b7a3bc334865bc2ebcc8937da8a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk2NzYwMA_size_16_color_FFFFFF_t_70 3]: /images/20221022/f2368167cb6d4aaea106c212954c1b56.png
[20210424165137589.png]: https://img-blog.csdnimg.cn/20210424165137589.png
[20210424165203838.png]: /images/20221022/1bbe74fc8c09424a8600df169dcb5b06.png
[20210424165346960.png]: /images/20221022/b28e19d26c65498a8c15f55bc7d3336b.png
[20210424165452421.png]: /images/20221022/f63f1b55d69b4049ac6d082a2ec1cd35.png
[20210424165550341.png]: /images/20221022/c4df6243a7044f9192bb3c7d765b8638.png
[20210424165602122.png]: /images/20221022/d218de3e4e6547f1ad162119a550b11a.png
[20210424165625607.png]: /images/20221022/36cbd55292f84051b311b5a58a11c77f.png