Lumen中使用Thrift

保护私人版权，尊重他人版权。转载请注明出处并附带页面链接

Thrift是什么

Thrift 最初由Facebook开发，而后捐献给Apache，目前已广泛应用于业界。Thrift 正如其官方主页介绍的，“是一种可扩展、跨语言的服务开发框架”。简而言之，它主要用于各个服务之间的RPC通信，其服务端和客户端可以用不同的语言来开发。只需要依照IDL（Interface Description Language）定义一次接口，Thrift工具就能自动生成 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml等语言的代码。

性能方面gRPC和Thrift的对比网上已经有很多了，总体上来说Thrift性能要优于gRPC，但是gRPC在设计上更为规范，基于HTTP/2标准设计，带来诸如双向流控、头部压缩、单TCP连接上的多复用请求等特性。

安装

• Mac：brew install thrift

• Linux：http://thrift.apache.org/download

IDL教程

http://diwakergupta.github.io/thrift-missing-guide

结合到Lumen中使用

服务端

定义服务

vi thrift/server/education.thrift

namespace php App.Library.Thrift.Server

exception RpcException{
    1: i32 code;
    2: string message;
}

service EducationService {
    string searchStudent(1:string userId, 2:string studentName) throws (1:RpcException e),
}

生成代码

thrift --gen php:server -out ./ education.thrift

执行该命令会在当前目录生成thrift的代码，然后把这些代码拷贝到定义的命名空间下

安装依赖

composer require apache/thrift

这里扩展包的版本要跟你系统安装的thrift版本一致

实现Server端接口

vi app/Library/Rpc/Server.php

<?php

namespace App\Library\Rpc;
  
use App\Library\Thrift\Server\EducationServiceIf;
  
class Server implements EducationServiceIf
{
  
    /**
     * @param string $userId
     * @param string $studentName
     *
     * @return string
     * @throws RpcException
     */
    public function searchStudent($userId, $studentName)
    {
        try {
            // 自行实现业务代码
            $logic = new UserStudentRelationLogic();
            $ret = $logic->searchStudent($userId, $studentName);
            return json_encode($ret);
        } catch (\Exception $e) {
            $this->handleException($e);
        }
    }
    
    /**
     * @param \Exception $e
     *
     * @throws RpcException
     */
    protected function handleException(\Exception $e)
    {
        $err = [
            'code'    => $e->getCode(),
            'message' => $e->getMessage(),
        ];
        throw new RpcException($err);
    }
}

启动

vi app/Console/Commands/Thrift/RpcStart.php

<?php

namespace App\Console\Commands\Thrift;

use App\Library\Rpc\Server;
use App\Library\Thrift\Server\EducationServiceProcessor;
use Illuminate\Console\Command;
use Thrift\Exception\TException;
use Thrift\Factory\TBinaryProtocolFactory;
use Thrift\Factory\TTransportFactory;
use Thrift\Server\TSimpleServer;
use Thrift\Server\TServerSocket;
use Thrift\TMultiplexedProcessor;

class RpcStart extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'thrift:rpc_start';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '启动rpc';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $host = '127.0.0.1';
        $port = '8900';
        $serviceName = 'serviceName';

        try {
            $thriftProcess = new EducationServiceProcessor(new Server());
            $tFactory = new TTransportFactory();
            $pFactory = new TBinaryProtocolFactory();
            $processor = new TMultiplexedProcessor();

            $processor->registerProcessor($serviceName, $thriftProcess);
            $transport = new TServerSocket($host, $port);
            $server = new TSimpleServer($processor, $transport, $tFactory, $tFactory, $pFactory, $pFactory);
            $this->info(date('Y-m-d H:i:s') . ' 服务启动成功 ' . $host . ':' . $port);
            $server->serve();
        } catch (TException $e) {
            $errMsg = date('Y-m-d H:i:s') . ' [thrift rpc] 出错, msg: ' . $e->getMessage() . ' code: ' . $e->getCode();
            $this->error($errMsg);
        }
    }
}

客户端

安装依赖

composer require apache/thrift

生成代码

需要用到服务端的thrift文件

thrift --gen php -out ./ education.thrift

和服务端一样把生成的代码拷贝到相应的命名空间

Client端调用接口方法

<?php

use Thrift\Protocol\TBinaryProtocol;
use Thrift\Protocol\TMultiplexedProtocol;
use Thrift\Transport\TBufferedTransport;
use Thrift\Transport\TSocket;

class RpcClient
{
    protected static function _request()
    {
        $host = '127.0.0.1';
        $port = '8900';
        $serviceName = 'serviceName';
    
        $socket = new TSocket($host, $port);
        $socket->setRecvTimeout(30000);
        $socket->setDebug(false);
        $transport = new TBufferedTransport($socket, 1024, 1024);
        $protocol = new TBinaryProtocol($transport);
        $thriftProtocol = new TMultiplexedProtocol($protocol, $serviceName);
        $client = new EducationServiceClient($thriftProtocol);
        $transport->open();

        return $client;
    }
    
    public static function searchStudent($userId, $searchField)
    {
        try {
            $client = self::_request();
            $ret = $client->searchStudent($userId, $searchField);
            return json_decode($ret, true) ?: [];
        } catch (\Exception $e) {
            // 自行对异常处理
            throw $e;
        }
    }
}

Sub

扫码关注微信公众号，随时随地，掌握最新技术资讯

微信