場景

Thrift介紹以及Java中使用Thrift實現RPC示例：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/108689413

在上面講了在Java中使用Thrift實現遠程過程調用。實現了在客戶端調用服務端的方法。

但是這都是在Java項目中。

Thrift的強大之處并不止于此，如果想實現在兩個不同的語言的服務端可客戶端中實現RPC,

比如在Java客戶端中調用Python服務端的方法或者在Python客戶端中調用Java服務端的方法。

注：

博客：
https://blog.csdn.net/badao_liumang_qizhi
關注公眾號
霸道的程序猿
獲取編程相關電子書、教程推送與免費下載。

實現

前面在使用Thrift生成Java代碼時的thrift文件為

namespace java thrift.generatedtypedef i16 short typedef i32 int typedef i64 long typedef bool boolean typedef string Stringstruct Person {1:optional String username,2:optional int age,3:optional boolean married }exception DataException {1:optional String message,2:optional String callback,3:optional String date }service PersonService {Person getPersonByUsername(1:required String username) throws (1:DataException dataException),void savePerson(1:required Person person) throws(1:DataException dataException) }

為了能生成代碼，添加一個py的namespace

namespace py py.thrift.generated

添加之后的完成代碼

namespace java thrift.generated namespace py py.thrift.generatedtypedef i16 short typedef i32 int typedef i64 long typedef bool boolean typedef string Stringstruct Person {1:optional String username,2:optional int age,3:optional boolean married }exception DataException {1:optional String message,2:optional String callback,3:optional String date }service PersonService {Person getPersonByUsername(1:required String username) throws (1:DataException dataException),void savePerson(1:required Person person) throws(1:DataException dataException) }

之前已經將thrift的編譯器添加進環境變量，所以在IDEA中的Ternimal中使用其生成Python代碼

thrift --gen py src/thrift/MyData.thrift

后面跟的是thrift文件的位置

?

此時會在項目根目錄下生成gen-py目錄，里面就是生成的python代碼

新建Python項目PyThrift，這里使用PyCharm再打開Ternimal,使用pip安裝thrift

pip install thrift

然后將上面生成的python代碼的gen-py下面的py目錄和__init_.py復制到Pycharm中的Python項目中

?

Python客戶端請求Java服務端

在Python項目中新建py_client.py

# -*- coding:utf-8 -*- __author__='公眾號:霸道的程序猿'from py.thrift.generated import PersonService from py.thrift.generated import ttypes from thrift import Thrift from thrift.transport import TSocket from thrift. transport import TTransport from thrift. protocol import TCompactProtocoltry:tSocket = TSocket.TSocket('localhost',8899)tSocket.setTimeout(600)transport = TTransport.TFramedTransport(tSocket)protocol = TCompactProtocol.TCompactProtocol(transport)client = PersonService.Client(protocol)transport.open()person = client.getPersonByUsername("公眾號:霸道的程序猿")print (person.username)print (person.age)print(person.married)print('--------------------')newPerson = ttypes.Person()newPerson.username('公眾號:霸道的程序猿')newPerson.age = 50newPerson.married = Trueclient.savePerson(newPerson)transport.close()except Thrift.TException as tx:print(tx.message)

注意這里的Python客戶端所使用的通信層和傳輸層的協議要和上面博客中Java客戶端使用的一致。

然后運行Java中的服務端，以及Python中的客戶端

?

可以看到Python的客戶端調用了Java服務端的兩個方法成功。

Java客戶端調用Python服務端

在Python項目中新建PersonServiceImpl.py作用與之前Java服務端的實現類相同都是實現

thrift中struct中定義的接口方法。

# -*- coding:utf-8 -*- __author__='公眾號:霸道的程序猿'from py.thrift.generated import ttypesclass PersonServiceImpl:def getPersonByUsername(self,username):print('Python 服務端獲取到客戶端傳來的參數:'+username)person = ttypes.Person()person.username = usernameperson.age = 50person.married = Truereturn? persondef savePerson(self,person):print('Python 服務端獲取客戶端的參數:')print(person.username)print(person.age)print(person.married)

然后再新建服務端py_server.py

# -*- coding:utf-8 -*- __author__='公眾號:霸道的程序猿'from py.thrift.generated import PersonService from PersonServiceImpl import PersonServiceImpl from thrift import Thrift from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import? TCompactProtocol from thrift.server import TServertry:personServiceHandler = PersonServiceImpl()processor = PersonService.Processor(personServiceHandler)serverSocket = TSocket.TServerSocket(host='127.0.0.1',port=8899)transportFactory = TTransport.TFramedTransportFactory()protocolFactory = TCompactProtocol.TCompactProtocolFactory()server = TServer.TSimpleServer(processor,serverSocket,transportFactory,protocolFactory)server.serve()except Thrift.TException as ex:print(ex.message)

注意這里的TServerSocket中的參數不僅要有端口還要有port，并且這里的host如果設置localhost的話

會提示拒絕連接，所以這使用的是127.0.0.1

運行Python的服務端，然后再運行Java的客戶端

?

在Java客戶端中調用Python服務端的方法成功。

示例代碼下載

https://download.csdn.net/download/BADAO_LIUMANG_QIZHI/12869384

?

?

總結

以上是生活随笔為你收集整理的Thrift中实现Java与Python的RPC互相调用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。