service ExchangeData {
    string dataConversion(1:string jsonData)
}

gen-py/

├── ExchangeData

│   ├── constants.py

│   ├── ExchangeData.py

│   ├── ExchangeData-remote

│   ├── __init__.py

│   └── ttypes.py

└── __init__.py

from thrift.protocol import TBinaryProtocol
from thrift.server import TServer
from thrift.transport import TSocket
from thrift.transport import TTransport

from ExchangeData import ExchangeData


class ExchangeDataHandler:
    def __init__(self):
        pass

    """ 定义的接口必须和定义的文件一致 """
    def dataConversion(self, jsonData):
        """ 编写业务逻辑"""
        ret = "test"
        return ret


# handler processer类
exchangeDataHandler = ExchangeDataHandler()
processor = ExchangeData.Processor(exchangeDataHandler)

""" 客户端和服务端的地址和端口必须一致 """
transport = TSocket.TServerSocket("127.0.0.1", 8989)
# 传输方式，使用buffer
tfactory = TTransport.TBufferedTransportFactory()
# 传输的数据类型：二进制
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
# 创建一个thrift 服务~
server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory)
print("Starting thrift server in python...")
server.serve()
print("done!")

<dependency>
  <groupId>org.apache.thrift</groupId>
  <artifactId>libthrift</artifactId>
  <version>0.14.0</version>
</dependency>

package org.example;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;

/**
 * Hello world!
 */
public class ThriftClient {
    public void startClient() {
        TTransport transport;
        try {
            System.out.println("thrift client connext server at 8989 port ");
            /**
             * 必须和服务端端地址和端口一致
             */
            transport = new TSocket("127.0.0.1", 8989);
            TProtocol protocol = new TBinaryProtocol(transport);

            /**
             * 构建客户端例子
             */
            ExchangeData.Client client = new ExchangeData.Client(protocol);
            transport.open();

            /**
             * 调用接口
             */
            System.out.println(client.dataConversion("11111111"));
            transport.close();
            System.out.println("thrift client close connextion");
        } catch (TTransportException e) {
            e.printStackTrace();
        } catch (TException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        System.out.println("thrift client init ");
        ThriftClient client = new ThriftClient();
        System.out.println("thrift client start ");
        client.startClient();
        System.out.println("thrift client end ");
    }
}