一、安装篇
博主注：截至2017-10-10，官网上thrift最新版0.10.0一直无法成功编译。所以，请选择0.9.3版本，避免走各种弯路：
wget http://apache.fayea.com/thrift/0.9.3/thrift-0.9.3.tar.gz
1、安装开发平台工具
yum -y groupinstall "Development Tools"
2、安装autoconf
wget http://ftp.gnu.org/gnu/autoconf/autoconf-2.69.tar.gz
tar xvf autoconf-2.69.tar.gz
cd autoconf-2.69
./configure --prefix=/usr/local
make
make install
3、安装automake
wget http://ftp.gnu.org/gnu/automake/automake-1.14.tar.gz
tar xvf automake-1.14.tar.gz
cd automake-1.14
./configure --prefix=/usr/local
make
make install
4、安装bison
wget http://ftp.gnu.org/gnu/bison/bison-2.5.1.tar.gz
tar xvf bison-2.5.1.tar.gz
cd bison-2.5.1
./configure --prefix=/usr/local
make
make install
5、安装C++库依赖包
yum -y install libevent-devel zlib-devel openssl-devel
6、安装boost
wget http://sourceforge.net/projects/boost/files/boost/1.53.0/boost_1_53_0.tar.gz
tar xvf boost_1_53_0.tar.gz
cd boost_1_53_0
./bootstrap.sh
./b2
7、安装其它依赖包
yum install gcc gcc-c++ bzip2 bzip2-devel bzip2-libs python-devel -y
8、安装thrift（基本的编译套路）
cd thrift
./bootstrap.sh
./configure --with-lua=no --prefix=/alidata/server/thrift
make
make install
二、Hello World篇
使用套路总结：
1、用IDL语法，定义自己的数据结构与服务接口：
https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=tutorial/tutorial.thrift
https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=tutorial/shared.thrift
将这两个文件下载到本地，分别保存为tutorial.thrift和shared.thrift，并将这两个文件传到与thrift同目录下。
附：
IDL详细教程：
http://thrift.apache.org/docs/idl
IDL示例（够用了）：
https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=tutorial/tutorial.thrift
https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=tutorial/shared.thrift
2、用thrift将上面的thrift的IDL文件，转成对应语言的类：
thrift -gen php:server tutorial.thrift
上面这一句是对应服务端的转换，客户端的转换不用:server；但是服务端方式生成的类文件可以供客户端使用。
3、转换完成后，在本目录下会得到一个gen-php目录，里面有三个文件tutorial.php、shared.php和Types.php。
tutorial.php里面有一个CalculatorIf接口，这个类是我们要实现的服务端业务接口。
shared.php被引用在tutorial.php文件中。
Types.php里面是自定义数据类型。
4、实现server端，即需要创建一个Handler类实再业务接口CalculatorIf
注意：这里的lib文件在thrift源码包lib里，我们移到自己的php需要的路径中。代码中require_once部分、$GEN_DIR部分、Thrift命名空间注册部分的路径需要根据实际情况进行更改
<?php
namespace tutorial\php;
error_reporting(E_ALL);
require_once __DIR__.'/../../lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';
use Thrift\ClassLoader\ThriftClassLoader;
$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', __DIR__ . '/../../lib/php/lib');
$loader->registerDefinition('shared', $GEN_DIR);
$loader->registerDefinition('tutorial', $GEN_DIR);
$loader->register();
if (php_sapi_name() == 'cli') {
ini_set("display_errors", "stderr");
}
use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TPhpStream;
use Thrift\Transport\TBufferedTransport;
class CalculatorHandler implements \tutorial\CalculatorIf {
protected $log = array();
public function ping() {
error_log("ping()");
}
public function add($num1, $num2) {
error_log("add({$num1}, {$num2})");
return $num1 + $num2;
}
public function calculate($logid, \tutorial\Work $w) {
error_log("calculate({$logid}, {{$w->op}, {$w->num1}, {$w->num2}})");
switch ($w->op) {
case \tutorial\Operation::ADD:
$val = $w->num1 + $w->num2;
break;
case \tutorial\Operation::SUBTRACT:
$val = $w->num1 - $w->num2;
break;
case \tutorial\Operation::MULTIPLY:
$val = $w->num1 * $w->num2;
break;
case \tutorial\Operation::DIVIDE:
if ($w->num2 == 0) {
$io = new \tutorial\InvalidOperation();
$io->whatOp = $w->op;
$io->why = "Cannot divide by 0";
throw $io;
}
$val = $w->num1 / $w->num2;
break;
default:
$io = new \tutorial\InvalidOperation();
$io->whatOp = $w->op;
$io->why = "Invalid Operation";
throw $io;
}
$log = new \shared\SharedStruct();
$log->key = $logid;
$log->value = (string)$val;
$this->log[$logid] = $log;
return $val;
}
public function getStruct($key) {
error_log("getStruct({$key})");
// This actually doesn't work because the PHP interpreter is
// restarted for every request.
//return $this->log[$key];
return new \shared\SharedStruct(array("key" => $key, "value" => "PHP is stateless!"));
}
public function zip() {
error_log("zip()");
}
};
header('Content-Type', 'application/x-thrift');
if (php_sapi_name() == 'cli') {
echo "\r\n";
}
$handler = new CalculatorHandler();
$processor = new \tutorial\CalculatorProcessor($handler);
$transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W));
$protocol = new TBinaryProtocol($transport, true, true);
$transport->open();
$processor->process($protocol, $protocol);
$transport->close();
5、实现client端：
同样需要注意：这里的lib文件在thrift源码包lib里，我们移到自己的php需要的路径中。代码中require_once部分、$GEN_DIR部分、Thrift命名空间注册部分的路径需要根据实际情况进行更改
<?php
namespace tutorial\php;
error_reporting(E_ALL);
require_once __DIR__.'/../../lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';
use Thrift\ClassLoader\ThriftClassLoader;
$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', __DIR__ . '/../../lib/php/lib');
$loader->registerDefinition('shared', $GEN_DIR);
$loader->registerDefinition('tutorial', $GEN_DIR);
$loader->register();
use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\THttpClient;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
try {
if (array_search('--http', $argv)) {
$socket = new THttpClient('localhost', 8080, '/php/PhpServer.php');
} else {
$socket = new TSocket('localhost', 9090);
}
$transport = new TBufferedTransport($socket, 1024, 1024);
$protocol = new TBinaryProtocol($transport);
$client = new \tutorial\CalculatorClient($protocol);
$transport->open();
$client->ping();
print "ping()\n";
$sum = $client->add(1,1);
print "1+1=$sum\n";
$work = new \tutorial\Work();
$work->op = \tutorial\Operation::DIVIDE;
$work->num1 = 1;
$work->num2 = 0;
try {
$client->calculate(1, $work);
print "Whoa! We can divide by zero?\n";
} catch (\tutorial\InvalidOperation $io) {
print "InvalidOperation: $io->why\n";
}
$work->op = \tutorial\Operation::SUBTRACT;
$work->num1 = 15;
$work->num2 = 10;
$diff = $client->calculate(1, $work);
print "15-10=$diff\n";
$log = $client->getStruct(1);
print "Log: $log->value\n";
$transport->close();
} catch (TException $tx) {
print 'TException: '.$tx->getMessage()."\n";
}
?>
6、因为php的server端代码没有进行端口侦听的网络服务功能，所以要依靠python来提供这个功能。我们把下面的脚本命名为s.py，需要与server.php放在同一个目录下（/alidata/www/thrift）
#!/bin/py
#coding=utf-8
import os
import BaseHTTPServer
import CGIHTTPServer
# chdir(2) into the tutorial directory.
os.chdir('/alidata/www/thrift')
# 指定目录 ，如果目录错误 请求会失败
class Handler(CGIHTTPServer.CGIHTTPRequestHandler):
cgi_directories = ['/']
BaseHTTPServer.HTTPServer(('', 8080), Handler).serve_forever()
7、到现在为止，hello world级别的工程已经完成。
运行服务端s.py
运行客户端php client.php --http
便可以看到响应的实际效果
三、生产使用篇
hello world级别的工程，只有一个进程进行侦听和服务，在多核CPU的时代，只有一个进程不但无法充分利用CPU的性能，也无法为用户提供最高效的服务。
方案一：用php自己实现网络服务方案（这是一个牛人写的多进程服务demo，完全可以参照） http://blog.csdn.net/flynetcn/article/details/47837975
<?php
/**
* 多进程形式的server.
* @package thrift.server
* @author flynetcn
*/
namespace Thrift\Server;
use Thrift\Server\TServer;
use Thrift\Transport\TTransport;
use Thrift\Exception\TException;
use Thrift\Exception\TTransportException;
class TMultiProcessServer extends TServer
{
/**
* 捕获的信号编号
*/
static $catchQuitSignal = 0;
/**
* worker进程数量
*/
private $workProcessNum = 4;
/**
* 每个worker进程处理的最大请求数
*/
private $maxWorkRequestNum = 2000;
/**
* 当前worker进程已处理的请求数
*/
private $currentWorkRequestNum = 0;
/**
* 当前连接调用次数
*/
private $currentConnectCallNum = 0;
/**
* 发送超时
*/
private $sendTimeoutSec = 1;
/**
* 接收超时
*/
private $recvTimeoutSec = 1;
/**
* 当前进程pid
*/
private $pid = 0;
/**
* Flag for the main serving loop
*/
private $stop_ = false;
/**
* List of children.
*/
protected $childrens = array();
/**
* 服务器日志文件
*/
protected static $logFiles;
protected static $pidFile;
/**
* run
*/
public function serve($daemon=false, array $config=array())
{
if (isset($config['workProcessNum'])) {
$this->workProcessNum = intval($config['workProcessNum']);
}
if ($this->workProcessNum < 1) {
self::log(1, "child workProcessNum can not be less than 1");
throw new TException('child workProcessNum can not be less than 1');
}
if (isset($config['maxWorkRequestNum'])) {
$this->maxWorkRequestNum = intval($config['maxWorkRequestNum']);
}
if ($this->maxWorkRequestNum < 1) {
self::log(1, "child maxWorkRequestNum can not be less than 1");
throw new TException('child maxWorkRequestNum can not be less than 1');
}
if (isset($config['sendTimeoutSec'])) {
$this->sendTimeoutSec = intval($config['sendTimeoutSec']);
}
if (isset($config['recvTimeoutSec'])) {
$this->recvTimeoutSec = intval($config['recvTimeoutSec']);
}
if ($daemon) {
$this->daemon();
$this->registerSignalHandler();
self::$logFiles = isset($config['logFiles']) && is_array($config['logFiles']) ? $config['logFiles'] : array();
self::$pidFile = isset($config['pidFile']) ? $config['pidFile'] : '';
declare(ticks=3);
}
$this->pid = posix_getpid();
self::createPidFile($this->pid);
self::log(0, "manage process({$this->pid}) has started");
$this->transport_->listen();
while (!$this->stop_) {
while ($this->workProcessNum > 0) {
try {
$pid = pcntl_fork();
if ($pid > 0) {
$this->handleParent($pid, $this->workProcessNum);
} else if ($pid === 0) {
$this->pid = posix_getpid();
$this->handleChild($this->workProcessNum);
} else {
self::log(1, "Failed to fork");
throw new TException('Failed to fork');
}
$this->workProcessNum--;
} catch (Exception $e) {
}
}
$this->collectChildren();
sleep(2);
if (\Thrift\Server\TMultiProcessServer::$catchQuitSignal) {
$this->stop();
}
}
}
public function getCurrentWorkRequestNum()
{
return $this->currentWorkRequestNum;
}
public function getCurrentConnectCallNum()
{
return $this->currentConnectCallNum;
}
/**
* Code run by the parent
*
* @param int $pid
* @param int $num 进程编号
* @return void
*/
private function handleParent($pid, $num)
{
$this->childrens[$pid] = $num;
}
/**
* Code run by the child.
*
* @param int $num 进程编号
* @return void
*/
private function handleChild($num)
{
self::log(0, "child process($this->pid) has started");
$this->childrens = array();
while (!$this->stop_) {
try {
$transport = $this->transport_->accept();
if ($transport != null) {
$transport->setSendTimeout($this->sendTimeoutSec * 1000);
$transport->setRecvTimeout($this->recvTimeoutSec * 1000);
$this->currentWorkRequestNum++;
$this->currentConnectCallNum = 0;
$inputTransport = $this->inputTransportFactory_->getTransport($transport);
$outputTransport = $this->outputTransportFactory_->getTransport($transport);
$inputProtocol = $this->inputProtocolFactory_->getProtocol($inputTransport);
$outputProtocol = $this->outputProtocolFactory_->getProtocol($outputTransport);
while ($this->processor_->process($inputProtocol, $outputProtocol)) {
$this->currentConnectCallNum++;
}
@$transport->close();
}
} catch (TTransportException $e) {
} catch (Exception $e) {
self::log(1, $e->getMessage().'('.$e->getCode().')');
}
if (\Thrift\Server\TMultiProcessServer::$catchQuitSignal) {
$this->stop();
}
if ($this->currentWorkRequestNum >= $this->maxWorkRequestNum) {
self::log(0, "child process($this->pid) has processe {$this->currentWorkRequestNum} requests will be exit");
$this->stop();
break;
}
}
exit(0);
}
/**
* Collects any children we may have
*
* @return void
*/
private function collectChildren()
{
foreach ($this->childrens as $pid => $num) {
if (pcntl_waitpid($pid, $status, WNOHANG) > 0) {
unset($this->childrens[$pid]);
$this->workProcessNum++;
}
}
}
/**
* @return void
*/
public function stop()
{
$this->transport_->close();
$this->stop_ = true;
foreach ($this->childrens as $pid => $num) {
if (!posix_kill($pid, SIGTERM)) {
}
}
}
/**
* 附加信号处理
*/
public static function sig_handler($signo)
{
switch ($signo) {
case SIGTERM:
case SIGHUP:
case SIGQUIT:
case SIGTSTP:
$pid = posix_getpid();
self::log(0, "process($pid) catch signo: $signo");
\Thrift\Server\TMultiProcessServer::$catchQuitSignal = $signo;
break;
default:
}
}
/**
* 附加信号处理
*/
private function registerSignalHandler()
{
pcntl_signal(SIGTERM, '\Thrift\Server\TMultiProcessServer::sig_handler');
pcntl_signal(SIGHUP, '\Thrift\Server\TMultiProcessServer::sig_handler');
pcntl_signal(SIGQUIT, '\Thrift\Server\TMultiProcessServer::sig_handler');
pcntl_signal(SIGTSTP, '\Thrift\Server\TMultiProcessServer::sig_handler');
declare(ticks=3);
}
/**
* 附加守护进程方式
*/
private function daemon()
{
if (!function_exists('posix_setsid')) {
return;
}
if (($pid1 = pcntl_fork()) != 0) {
exit;
}
posix_setsid();
if (($pid2 = pcntl_fork()) != 0) {
exit;
}
}
public static function log($type, $msg)
{
static $fds;
$msg = date('Y-m-d H:i:s')." $type {$msg}\n";
if (isset(self::$logFiles[$type]) && self::$logFiles[$type]) {
if (file_exists(self::$logFiles[$type])) {
if (empty($fds[$type])) {
$fds[$type] = fopen(self::$logFiles[$type], 'a');
}
if (!$fds[$type]) {
$fds[$type] = fopen('php://stdout', 'w');
fwrite($fds[$type], date('Y-m-d H:i:s')." WARNING fopen(".self::$logFiles[$type].") failed\n");
}
} else {
if (!is_dir(dirname(self::$logFiles[$type])) && !mkdir(dirname(self::$logFiles[$type]), 0755, true)) {
$fds[$type] = fopen('php://stdout', 'w');
fwrite($fds[$type], date('Y-m-d H:i:s')." WARNING mkdir(".self::$logFiles[$type].") failed\n");
} elseif (!($fds[$type] = fopen(self::$logFiles[$type], 'a'))) {
$fds[$type] = fopen('php://stdout', 'w');
fwrite($fds[$type], date('Y-m-d H:i:s')." WARNING fopen(".self::$logFiles[$type].") failed\n");
}
}
} else {
$fds[$type] = fopen('php://stdout', 'w');
}
$ret = fwrite($fds[$type], $msg);
if (!$ret && self::$logFiles[$type]) {
fclose($fds[$type]);
$fds[$type] = fopen(self::$logFiles[$type], 'a');
$ret = fwrite($fds[$type], $msg);
}
return true;
}
public static function createPidFile($pid=0)
{
if (!$pid) {
$pid = posix_getpid();
}
if (file_exists(self::$pidFile)) {
$fd = fopen(self::$pidFile, 'w');
if (!$fd) {
self::log(1, "fopen(".self::$pidFile.") failed");
return false;
}
} else {
if (!is_dir(dirname(self::$pidFile)) && !mkdir(dirname(self::$pidFile), 0755, true)) {
self::log(1, "mkdir(".self::$pidFile.") failed");
return false;
} elseif (!($fd = fopen(self::$pidFile, 'w'))) {
self::log(1, "fopen(".self::$pidFile.") failed");
return false;
}
}
if (!fwrite($fd, "$pid")) {
self::log(1, "fwrite(".self::$pidFile.",$pid) failed");
return false;
}
fclose($fd);
return true;
}
}
方案二：方案一固然不错，但是因为没有实践的检验，所以用起来还是有一点担心的。所以，个人建议采用workman的thrift方案，请参考：http://www.workerman.net/workerman-thrift
1、因为要使用多进程，所以需要先安装pcntl扩展。（安装过程很简单，不是重点，不详细描述过程）
2、workman-thrift下载解压后，目录中Applications/ThriftRpc/Services存放的自己的服务端服务，即业务接口If、自定义数据类型Type和业务接口的实现。
3、根目录下的start.php加载并运行了Applications下的各个服务的start.php文件
4、解压后的目录中Applications/ThriftRpc是一个HelloWorld服务的demo。
5、现在，看Applications/ThriftRpc/start.php中的关键代码：
$worker = new ThriftWorker('tcp://0.0.0.0:9090');
$worker->count = 16;
$worker->class = 'HelloWorld';
这里，设置了侦听的IP与端口、设置了服务进程数量与服务的类
6、查看Applications/ThriftPrc/ThriftWorker.php中的关键代码：
// 载入该服务下的所有文件
foreach(glob(THRIFT_ROOT . '/Services/'.$this->class.'/*.php') as $php_file)
{
require_once $php_file;
}
// 检查类是否存在
$processor_class_name = "\\Services\\".$this->class."\\".$this->class.'Processor';
if(!class_exists($processor_class_name))
{
ThriftWorker::log("Class $processor_class_name not found" );
return;
}
// 检查类是否存在
$handler_class_name ="\\Services\\".$this->class."\\".$this->class.'Handler';
if(!class_exists($handler_class_name))
{
ThriftWorker::log("Class $handler_class_name not found" );
return;
}
根据第5步指定的class，在ThriftWorker中会载入对应路径下的所有php文件进行检查，并检查对应的Processor和Handler类是否存在。最终创建Handler和Processor
7、运行根目录下的php start.php start，可以看到
恭喜，服务端运行成功。
8、关于客户端
复制 http://www.workerman.net/workerman-thrift 上的客户端代码，即可正常运行。
<?php // 引入客户端文件
require_once __DIR__.'/Applications/ThriftRpc/Clients/ThriftClient.php';
use ThriftClient\ThriftClient;
// 传入配置，一般在某统一入口文件中调用一次该配置接口即可
thriftClient::config(
array(
'HelloWorld' => array(
'addresses' => array(
'127.0.0.1:9090',
'127.0.0.2:9191',
),
'thrift_protocol' => 'TBinaryProtocol',//不配置默认是TBinaryProtocol，对应服务端HelloWorld.conf配置中的thrift_protocol
'thrift_transport' => 'TBufferedTransport',//不配置默认是TBufferedTransport，对应服务端HelloWorld.conf配置中的thrift_transport
),
'DInfoCenter' => array(
'addresses' => array(
'127.0.0.1:9090',
),
'thrift_protocol' => 'TBinaryProtocol',//不配置默认是TBinaryProtocol，对应服务端HelloWorld.conf配置中的thrift_protocol
'thrift_transport' => 'TBufferedTransport',//不配置默认是TBufferedTransport，对应服务端HelloWorld.conf配置中的thrift_transport
),
)
);
// ========= 以上在WEB入口文件中调用一次即可 ===========
// ========= 以下是开发过程中的调用示例 ==========
// 初始化一个HelloWorld的实例
$client = ThriftClient::instance('HelloWorld');
// --------同步调用实例----------
var_export($client->sayHello('JIM');
//var_export($client->recv_request("req",strval(time())));
// --------异步调用示例-----------
/*
// 异步调用 之 发送请求给服务端（注意：异步发送请求格式统一为 asend_XXX($arg),既在原有方法名前面增加'asend_'前缀）
$client->asend_sayHello("JERRY");
$client->asend_sayHello("KID");
// 这里是其它业务逻辑
sleep(1);
// 异步调用 之 接收服务端的回应（注意：异步接收请求格式统一为 arecv_XXX($arg),既在原有方法名前面增加'arecv_'前缀）
var_export($client->arecv_sayHello("KID"));
var_export($client->arecv_sayHello("JERRY"));
*/
9、截止这里，已经可以成功运行workman-thrift的hello world工程
10、关于定义自己的服务：
到这里根据了解，我们可以很容易自己的的服务。比如，我们想定义自己的服务，DInfoCenter，这个过程中有三个一定需要注意的地方：
第一点：目录名称需要改成DInfoCenter
第二点：三个文件的namespace声明（第一行），一定要改为：namespace Services\DInfoCenter;
第三点：默认生成的DInfoCenter.php中，下面很多类以及函数的调用，都带有命名空间（\DInfoCenter），需要把这一段删掉
到这里，就大致完成了，最后将start.php中的class赋值成DInfoCenter，就全部完成了。
网友评论