namespace java com.aniu.service
namespace py thrift_demo
struct Person {  // 定義 Person 結(jié)構(gòu)體
    1: required string name;   // 姓名，必選字段
    2: required i32 age;       // 年齡，必選字段
    3: optional string sex;    // 性別，可選字段
}
service PersonService {  // 定義 PersonService 服務(wù)接口
    Person getByName(1: string name);  // 根據(jù)姓名獲取 Person 信息
    bool save(1: Person person);       // 保存 Person 信息
}

package com.aniu.server;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;
import com.aniu.service.PersonService;
import com.aniu.service.impl.PersonServiceImpl;
public class Server {
    public static void main(String[] args) {
        try{
            // 創(chuàng)建一個(gè)新的 Thrift 服務(wù)端套接字，監(jiān)聽(tīng)在端口 9000 上
            TServerSocket socket = new TServerSocket(9000);
            // 創(chuàng)建一個(gè) PersonService 的 Processor。Processor 是 Thrift 中用于處理請(qǐng)求的接口，它需要一個(gè)實(shí)現(xiàn)了 PersonService 接口的對(duì)象作為參數(shù)。
            PersonService.Processor<PersonServiceImpl> processor = new PersonService.Processor<>(new PersonServiceImpl());
            // 創(chuàng)建一個(gè)二進(jìn)制協(xié)議工廠對(duì)象。Thrift 支持多種協(xié)議，如 TBinaryProtocol、TCompactProtocol、TJSONProtocol 等，這里選擇的是二進(jìn)制協(xié)議。
            TBinaryProtocol.Factory factory = new TBinaryProtocol.Factory();
            // 創(chuàng)建一個(gè) TSimpleServer 的參數(shù)對(duì)象 args1，并將之前創(chuàng)建的套接字、Processor 和協(xié)議工廠設(shè)置為其屬性。
            TServer.Args args1 = new TSimpleServer.Args(socket);
            args1.processor(processor);
            args1.protocolFactory(factory);
            // 使用之前設(shè)置好的參數(shù)創(chuàng)建 TSimpleServer 對(duì)象
            TSimpleServer tSimpleServer = new TSimpleServer(args1);
            // 開(kāi)始執(zhí)行 TSimpleServer，開(kāi)始監(jiān)聽(tīng)并處理客戶端的請(qǐng)求。
            tSimpleServer.serve();
        }catch (Exception e){
            System.out.println(e);
        }
    }
}

package com.aniu.service.impl;
import com.aniu.service.Person;
import com.aniu.service.PersonService;
import org.apache.thrift.TException;
public class PersonServiceImpl implements PersonService.Iface {
    @Override
    public Person getByName(String name) throws TException {
        return new Person(name,18);
    }
    @Override
    public boolean save(Person person) throws TException {
        return false;
    }
}

pip install thrift

from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift_demo import PersonService
# 創(chuàng)建Thrift服務(wù)端的地址和端口
host = 'localhost'
port = 9000
# 創(chuàng)建Thrift傳輸層和協(xié)議層
t_socket = TSocket.TSocket(host, port)
transport = TTransport.TBufferedTransport(t_socket)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
# 創(chuàng)建Thrift客戶端
client = PersonService.Client(protocol)
# 打開(kāi)Thrift傳輸層連接
transport.open()
# 調(diào)用Thrift客戶端提供的接口
try:
    # 調(diào)用getName方法
    person = client.getByName("aniu")
    print(person)
except Exception as e:
    print('Error:', str(e))
# 關(guān)閉Thrift傳輸層連接
transport.close()