thrift实现跨语言的调用

Posted 2021-04-24 记录技术记录我

笔者在工作中有这么一个应用场景:使用python调用java的服务,客户端是:python;服务器端是:java

具体要怎么做呢?

一，对python而言

0,准备好 thrift 文件,shared.thrift(namespace py shared ,这句话很关键),tutorial.thrift(同样，namespace py tutorial 这句话很关键);

1,thrift --gen py tutorial.thrift

2,thrift --gen py shared.thrift

最终会生成一个文件夹:gen-py,ta下面有shared,tutorial

shared(constants.py,ttypes.py,SharedService.py)

tutorial(Calculator.py,constants.py,ttypes.py)

二，对java而言

0,准备好 thrift 文件,shared.thrift(namespace java shared ,这句话很关键),tutorial.thrift(同样，namespace java tutorial 这句话很关键);

1,thrift --gen java tutorial.thrift

2,thrift --gen java shared.thrift

最终会生成一个文件夹:gen-java,ta下面有shared,tutorial

shared(SharedService.java,SharedStruct.java)

tutorial(Calculator.java,tutorialConstants.java,InvalidOperation.java,Work.java,Operation.java)

三，服务端源码:

package statMetricsToGra.thrift;

import org.apache.thrift.server.TServer;

import org.apache.thrift.server.TSimpleServer;

import org.apache.thrift.transport.TServerSocket;

import org.apache.thrift.transport.TServerTransport;

public class JavaServer {

    private static CalculatorHandler handler;

    private static Calculator.Processor processor;

    public static void main(String[] args) {

        try {

            handler = new CalculatorHandler();

            processor = new Calculator.Processor(handler);

            Runnable simple = new Runnable() {

                public void run() {

                    simple(processor);

                }

            };

            new Thread(simple).start();

        } catch (Exception x) {

            x.printStackTrace();

        }

    }

    private static void simple(Calculator.Processor processor) {

        try {

            TServerTransport serverTransport = new TServerSocket(9090);

            TServer server = new TSimpleServer(new TServer.Args(serverTransport).processor(processor));

            System.out.println("Starting the simple server...");

            server.serve();

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

}

四，客户端源码

import Calculator

from ttypes import InvalidOperation, Operation, Work

from thrift import Thrift

from thrift.transport import TSocket

from thrift.transport import TTransport

from thrift.protocol import TBinaryProtocol

def main():

    transport = TSocket.TSocket('localhost', 9090)

    transport = TTransport.TBufferedTransport(transport)

    protocol = TBinaryProtocol.TBinaryProtocol(transport)

    client = Calculator.Client(protocol)

    transport.open()

    client.ping()

    print('ping()')

    sum_ = client.add(1, 1)

    print('1+1=%d' % sum_)

    work = Work()

    work.op = Operation.DIVIDE

    transport.close()

if __name__ == '__main__':

    try:

        main()

    except Thrift.TException as tx:

        print('%s' % tx.message)