Apache Thrift是一个跨语言的服务部署框架，通过一个中间语言(IDL, 接口定义语言)来定义RPC的接口和数据类型，然后通过一个编译器生成不同语言的代码（支持C++，Java，Python，PHP, GO，Javascript，Ruby，Erlang，Perl， Haskell， C#等）,并由生成的代码负责RPC协议层和传输层的实现。
Thrift的PHP类库位于thrift/lib/php/lib/Thrift目录下面（这里就是下面代码中定义的THRIFT_ROOT路径），Thrift对于数据传输格式、数据传输方式，服务器模型均做了定义，方便自行扩展。
数据传输格式（protocol）是定义的了传输内容，对Thrift Type的打包解包，包括
- TBinaryProtocol，二进制格式，TBinaryProtocolAccelerated则是依赖于thrift_protocol扩展的快速打包解包。
- TCompactProtocol，压缩格式
- TJSONProtocol，JSON格式
- TMultiplexedProtocol，利用前三种数据格式与支持多路复用协议的服务端（同时提供多个服务，TMultiplexedProcessor）交互
数据传输方式（transport），定义了如何发送（write）和接收（read）数据，包括
- TBufferedTransport，缓存传输，写入数据并不立即开始传输，直到刷新缓存。
- TSocket，使用socket传输
- TFramedTransport，采用分块方式进行传输，具体传输实现依赖其他传输方式，比如TSocket
- TCurlClient，使用curl与服务端交互
- THttpClient，采用stream方式与HTTP服务端交互
- TMemoryBuffer，使用内存方式交换数据
- TPhpStream，使用PHP标准输入输出流进行传输
- TNullTransport，关闭数据传输
- TSocketPool在TSocket基础支持多个服务端管理（需要APC支持），自动剔除无效的服务器
- TNonblockingSocket，非官方实现非阻塞socket
服务模型，定义了当PHP作为服务端如何监听端口处理请求
- TForkingServer，采用子进程处理请求
- TSimpleServer，在TServerSocket基础上处理请求
- TNonblockingServer，基于libevent的非官方实现非阻塞服务端，与TNonblockingServerSocket，TNonblockingSocket配合使用
另外还定义了一些工厂，以便在Server模式下对数据传输格式和传输方式进行绑定
- TProtocolFactory，数据传输格式工厂类，对protocol的工厂化生产，包括TBinaryProtocolFactory，TCompactProtocolFactory，TJSONProtocolFactory
- TTransportFactory，数据传输方式工厂类，对transport的工厂化生产，作为server时，需要自行实现
- TStringFuncFactory，字符串处理工厂类
其他文件便是异常，字符串处理，自动加载器的定义等等。
现在开始编写一个简单接IDL文件HelloWorld.thrift
namespace php Services.HelloWorld
service HelloWorld
{
string sayHello(1:string name);
}
然后通过生成器生成PHP文件
thrift --gen php:server HelloWorld.thrift（不指明:server不生成processor）
生成文件在gen-php目录下面的Services/HelloWord/HelloWorld.php（目录与namesapce定义一致），这是个公共文件，服务端和客户端都需要包括它。
而服务端的服务实现代码则需要继承HelloWorldIf 实现代码HelloWorldHandler.php
<?php
namespace Services\HelloWorld;
class HelloWorldHandler implements HelloWorldIf {
public function sayHello($name)
{
return "Hello $name";
}
}
编写服务端代码Server.php
<?php
namespace Services\HelloWorld;
error_reporting(E_ALL);
define("THRIFT_ROOT", "/root/thrift/lib/php/lib/");
define("ROOT", "/root/zshanjun/thrift_scripts/");
require_once THRIFT_ROOT . "Thrift/ClassLoader/ThriftClassLoader.php";
use Thrift\ClassLoader\ThriftClassLoader;
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', THRIFT_ROOT);
$loader->registerDefinition('Service', ROOT . 'hello/gen-php');
$loader->register();
use Thrift\Exception\TException;
use Thrift\Factory\TTransportFactory;
use Thrift\Factory\TBinaryProtocolFactory;
use Thrift\Server\TServerSocket;
use Thrift\Server\TSimpleServer;
try {
require_once 'HelloWorldHandler.php';
$handler = new \Services\HelloWorld\HelloWorldHandler();
$processor = new \Services\HelloWorld\HelloWorldProcessor($handler);
$transportFactory = new TTransportFactory();
$protocolFactory = new TBinaryProtocolFactory(true, true);
//作为cli方式运行，监听端口，官方实现
$transport = new TServerSocket('localhost', 9090);
$server = new TSimpleServer($processor, $transport, $transportFactory, $transportFactory, $protocolFactory, $protocolFactory);
$server->serve();
} catch (TException $tx) {
print 'TException: '.$tx->getMessage()."\n";
}
服务端创建的步骤：
- 首先初始化服务提供者handler
- 然后利用该handler初始化自动生成的processor
- 初始化数据传输方式transport
- 利用该传输方式初始化数据传输格式protocol
- 开始服务
编写客户端代码Client.php
<?php
namespace Services\HelloWorld;
error_reporting(E_ALL);
define('THRIFT_ROOT', '/root/thrift/lib/php/lib/');
define('ROOT', '/root/zshanjun/thrift_scripts/');
require_once THRIFT_ROOT . 'Thrift/ClassLoader/ThriftClassLoader.php';
use Thrift\ClassLoader\ThriftClassLoader;
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', THRIFT_ROOT);
$loader->registerDefinition('Service', ROOT . 'hello/gen-php');
$loader->register();
use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
try {
//仅在与服务端处于同一输出输出流有用
//使用方式：php Client.php | php Server.php
//$transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W));
//socket方式连接服务端
//数据传输格式和数据传输方式与服务端一一对应
//如果服务端以http方式提供服务，可以使用THttpClient/TCurlClient数据传输方式
$transport = new TBufferedTransport(new TSocket('localhost', 9090));
$protocol = new TBinaryProtocol($transport);
$client = new \Services\HelloWorld\HelloWorldClient($protocol);
$transport->open();
//同步方式进行交互
$recv = $client->sayHello('Courages');
echo "\n sayHello11dd:".$recv." \n";
//异步方式进行交互
$client->send_sayHello('Us');
echo "\n send_sayHello \n";
$recv = $client->recv_sayHello();
echo "\n recv_sayHello:".$recv." \n";
$transport->close();
} catch (TException $tx) {
print 'TException: '.$tx->getMessage()."\n";
}
客户端调用的步骤：
- 初始化数据传输方式transport，与服务端对应
- 利用该传输方式初始化数据传输格式protocol，与服务端对应
- 实例化自动生成的Client对象
- 开始调用
在终端上运行
php Server.php
#在另外一个终端运行
php Client.ph
----
输出：
sayHello11dd:Hello Courages
send_sayHello
recv_sayHello:Hello Us
参考网站：
