namespace java com.penngo

namespace php com.penngo

namespace py com.penngo

struct User {             定义的是一个结构体,用于同一的放回结果

    : i64 id,

    : string name,

    : string password

}

service LoginService{    定义服务,服务先可以有多个方法,方法返回值为上面定义的结果User

    User login(:string name, :string psw);

} 

service FaceService{     方法的返回值为 string类型

    string getFace(:string name, :string psw);

}

service RegisterService{

    User createUser(:string name, :string psw);

}

.\thrift-0.9..exe -gen  py .\test.thrift   //python

.\thrift-0.9..exe -gen  csharp.\test.thrift  //C#

.\thrift-0.9..exe -gen  java.\test.thrift    //java

.\thrift-0.9..exe -gen  php.\test.thrift　　　//php

        try {

            TServerSocket serverTransport = new TServerSocket(8848);

            // 用户登录

            LoginService.Processor loginProcessor = new LoginService.Processor(

                    new LoginServiceImpl());

            //人脸识别

            FaceService.Processor faceProcessor=new FaceService.Processor(new FaceServiceImpl());

            // 用户注册

            RegisterService.Processor registerProcessor = new RegisterService.Processor(

                    new RegisterServiceImpl());

            TMultiplexedProcessor processor = new TMultiplexedProcessor();

            processor.registerProcessor("LoginService", loginProcessor);

            processor.registerProcessor("RegisterService", registerProcessor);

            processor.registerProcessor("FaceService", faceProcessor);

            TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(

                    serverTransport).processor(processor));

            System.out.println("Starting server on port 8848 ...");

            server.serve();

        } catch (TTransportException e) {

            e.printStackTrace();

        } catch (Exception e) {

            e.printStackTrace();

        }

<?php

namespace com\penngo;

require_once __DIR__.'/../../php/lib/Thrift/ClassLoader/ThriftClassLoader.php';        //按照自己的目录来,不能导入错了

//echo __DIR__.'/../../lib/Thrift/ClassLoader/ThriftClassLoader.php';

use Thrift\ClassLoader\ThriftClassLoader;

$GEN_DIR = realpath(dirname(__FILE__)).'/../../../gen-php';   //按照自己的目录来,不能导入错了

$loader = new ThriftClassLoader();

$loader->registerNamespace('Thrift', __DIR__ . '/../../php/lib');  //按照自己的目录来,不能导入错了,注册命名空间

//$loader->registerDefinition('shared', $GEN_DIR);

$loader->registerDefinition('com', $GEN_DIR);

$loader->register();

if (php_sapi_name() == 'cli') {

    ini_set("display_errors", "stderr");

}

use Thrift\Protocol\TBinaryProtocol;

use Thrift\Protocol\TMultiplexedProtocol;

use Thrift\Transport\TSocket;

use Thrift\Transport\THttpClient;

use Thrift\Transport\TBufferedTransport;

use Thrift\Exception\TException;

use com\penngo\RegisterServiceClient;

use com\penngo\LoginServiceClient;

try {

    $socket = new TSocket('127.0.0.1', 8848);

    $socket->setSendTimeout(100000);   //设置超时时间

    $socket->setRecvTimeout(100000);

    $transport = new TBufferedTransport($socket, 1024, 1024);

    $protocol = new TBinaryProtocol($transport);

//    $loginProtocol = new TMultiplexedProtocol($protocol, "LoginService");

    $faceProtocol = new TMultiplexedProtocol($protocol, "FaceService");

    // $registerProtocol = new TMultiplexedProtocol($protocol, "RegisterService");

    $faceClient = new FaceServiceClient($faceProtocol);

    // $registerClient = new RegisterServiceClient($registerProtocol);

    $transport->open();

    $faceinfo = $faceClient->getFace("123","asdasd");

    print_r($faceinfo);

    $transport->close();

} catch (TException $tx) {

    print 'TException: '.$tx->getMessage()."\n";

    print 'TException: '.$tx->getTraceAsString()."\n";

}

pip install thrift

# -*- coding:utf-8 -*-

import sys

sys.path.append('..')

from thrift.TMultiplexedProcessor import TMultiplexedProcessor

from thrift.protocol.TMultiplexedProtocol import TMultiplexedProtocol

from thrift.transport import TSocket

from thrift.transport import TTransport

from thrift.protocol import TBinaryProtocol

from thrift.server import TServer

#根据实际的包结构去引入

import FaceService

def client():

    transport = TSocket.TSocket(host='localhost', port=8848)

    transport = TTransport.TBufferedTransport(transport)

    protocol = TBinaryProtocol.TBinaryProtocol(transport)

    face_protocol = TMultiplexedProtocol(protocol, "FaceService") #如果服务端使用TMultiplexedProcessor接收处理，客户端必须用TMultiplexedProtocol并且指定serviceName和服务端的一致 

    face_client = FaceService.Client(face_protocol)#msg客户端 

    transport.open() 

    print face_client.getFace("","啊实打实多")

    transport.close()

if __name__ == '__main__':

    client()
    

using Thrift.Protocol;
using Thrift.Server;
using Thrift.Transport;

  public void TMclient()

        {

            TSocket transport = new TSocket("127.0.0.1",);

            TBinaryProtocol protocol = new TBinaryProtocol(transport);

            TMultiplexedProtocol tprocessor = new TMultiplexedProtocol(protocol, "FaceService");

            FaceService.Client faceclient = new FaceService.Client(tprocessor);

            transport.Open();

            String info=faceclient.getFace("PHP","JAVA");

            Console.WriteLine(info);

            transport.Close();

        }