thrift的使用中一般是一个Server对应一个Processor和一个Transport，如果有多个服务的话，那必须要启动多个Server，占用多个端口，这种方式显然不是我们想要的，所以thrift为我们提供了复用端口的方式，通过监听一个端口就可以提供多种服务，这种方式需要用到两个类：TMultiplexedProcessor和TMultiplexedProtocol。

创建 2 个 Laravel 项目，thrift-server (服务端) 和 thrift-client (客户端)

 

文件目录

testServer.thrift:

namespace php Rpc.Test

enum Operation {
  ADD = 1, SUBTRACT = 2, MULTIPLY = 3, DIVIDE = 4 } exception InvalidOperation { 1: i32 whatOp, 2: string why } service Calculator { double calculate(1:double num1, 2:double num2, 3:Operation op) throws (1:InvalidOperation ouch), string echoString(1: string str) , } service Echo { string echo(1: string str) , } 

每个service类对应一种服务，服务类下可有多个方法。

thrift-server根目录生成客户端类命令：

thrift -r --out ./ --gen php thriftSource/testServer.thrift

将生成的Rpc/Test文件夹剪切到thrift-client项目的Rpc目录中

在thrift-server根目录继续生成服务端类：

thrift -r --out ./ --gen php:server thriftSource/testServer.thrift

根目录创建Service目录，存放实现Calculator和Echo类的文件
Service/CalculatorService.php

<?php
/**
 *  实现Calculator服务
 */

namespace Service;

use Rpc\Test\CalculatorIf; use Rpc\Test\Operation; use Rpc\Test\InvalidOperation; class CalculatorService implements CalculatorIf { /** * @param double $num1 * @param double $num2 * @param int $op * @return double * @throws InvalidOperation */ public function calculate($num1, $num2, $op) { switch ($op) { case Operation::ADD: $val = $num1 + $num2; break; case Operation::SUBTRACT: $val = $num1 - $num2; break; case Operation::MULTIPLY: $val = $num1 * $num2; break; case Operation::DIVIDE: if ($num2 == 0) { $io = new InvalidOperation(); $io->whatOp = $op; $io->why = "Cannot divide by 0"; throw $io; } $val = $num1 / $num2; break; default: $io = new InvalidOperation(); $io->whatOp = $op; $io->why = "Invalid Operation"; throw $io; } return $val; } /** * @param $string */ public function echoString($string) { return $string; } } 

Service/EchoService.php:

<?php
/**
 *  实现Echo服务
 */

namespace Service;

use Rpc\Test\EchoIf; class EchoService implements EchoIf { /** * @param $string */ public function echo($string) { return $string; } } 

thrift-server服务端控制器:

<?php
/**
 * 服务端控制器
 */

namespace App\Http\Controllers; use Rpc\Test\CalculatorProcessor; use Rpc\Test\EchoProcessor; use Service\CalculatorService; use Service\EchoService; use Illuminate\Http\Request; use Thrift\Protocol\TBinaryProtocol; use Thrift\TMultiplexedProcessor; use Thrift\Transport\TBufferedTransport; use Thrift\Transport\TPhpStream; use Thrift\Exception\TException; class ServerController extends Controller { /** * 多个服务 * @param Request $request */ function handleManyRequest(Request $request) { try{ header('Content-Type', 'application/x-thrift'); // 初始化多个服务提供者handle $calculatorhandler = new CalculatorService(); $echohandler = new EchoService(); $multiplexedProcessor = new TMultiplexedProcessor(); // 创建多个服务Processor $calculatorProcessor = new CalculatorProcessor($calculatorhandler); $echoProcessor = new EchoProcessor($echohandler); // 将服务注册到TMultiplexedProcessor中 $multiplexedProcessor->registerProcessor("calculator", $calculatorProcessor); $multiplexedProcessor->registerProcessor("echo", $echoProcessor); // 初始化数据传输方式transport $transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W)); // 利用该传输方式初始化数据传输格式protocol $protocol = new TBinaryProtocol($transport, true, true); // 开始服务 $transport->open(); $multiplexedProcessor->process($protocol, $protocol); $transport->close(); } catch (TException $tx) { print 'TException: '.$tx->getMessage()."\n"; } } } 

配置post方式路由

Route::post('/rpc/server', 'ServerController@handleManyRequest');

配置虚拟主机 8081 端口监听thrift-server服务,80端口监听thrift-client服务

thrift-client客户端控制器：

<?php
/**
 * 客户端控制器
 */

namespace App\Http\Controllers; use Rpc\Test\Operation; use Rpc\Test\CalculatorClient; use Rpc\Test\EchoClient; use Illuminate\Http\Request; use Thrift\Protocol\TBinaryProtocol; use Thrift\Protocol\TMultiplexedProtocol; use Thrift\Transport\THttpClient; use Thrift\Transport\TBufferedTransport; use Thrift\Exception\TException; class ClientController extends Controller { /** * 多服务 * @param Request $request */ function handleManyRequest(Request $request) { try{ // 定义连接 $socket = new THttpClient('127.0.0.1', 8081, '/rpc/server'); // 创建transport $transport = new TBufferedTransport($socket, 1024, 1024); // 基于Transport创建Protocol $protocol = new TBinaryProtocol($transport); // 创建Client调用服务接口的方法 $calculatorClient = new CalculatorClient(new TMultiplexedProtocol($protocol, "calculator")); $echoClient = new EchoClient(new TMultiplexedProtocol($protocol, "echo")); // 开启 $transport->open(); // 调用接口方法 $sum = $calculatorClient->calculate(1, 2, Operation::ADD); print "calculator service -> calculate function -> 1+2=$sum </br>"; $test = $calculatorClient->echoString('this it test'); print "calculator service -> echoString function -> echoString:$test </br>"; $echoString = $echoClient->echo('echo method'); print "echo service -> echo function -> echo:$echoString\n\r"; $transport->close(); } catch (TException $tx) { print 'TException: '.$tx->getMessage()."\n"; } } } 

由此可客户端可调用服务端的方法,实现通讯：

 

postman测试thrift

注意:
1、根目录新建目录需配置composer.json中的psr-4
2、取消http/kernel.php中web中间件内容