标签：
转载请指明出处：http://www.cnblogs.com/lpit/p/4902292.html
thrift 是什么东西，就不多说了 ，网上都有。
现在展示我做的API。
1. 安装thrift 后开始写代码。
环境：
Linux version 2.6.18；
Thrift version 0.9.3；
PHP 5.5.9 ；
Python 2.4.3；
部署：
server 端使用 php，
client 端使用 php，
端口监控使用 python，
目录结构：
2. 展示代码：
创建 thrift 文件。
说明：准备使用thrift实现一个获取图片信息的API，这里展示调通的结果。
下面是 thrift 文件 ，文件名： imginfo.thrift
1 namespace php Img 2 3 service ImgInfo{ 4 string getimgInfo(1: string url), 5 }
2. 生成文件thrift文件中间接口文件
1 thrift -r --gen php:server imginfo.thrift
官网上面没有添加server参数。我添加sever并测试通过，官网的方法本人没有测试。
会在 imginfo.thrift 的目录生成一个 gen-php 目录，采用不同的语言会生成不同的目录
3. 编写客户端（client）程序
在imginfo.thrift 目录层 创建php目录 用于存放 客户端脚本。
文件名：c.php
1 <?php 2 3 namespace Img\php; 4 # 红色是需要根据自己的实际情况修改目录的点 5 error_reporting(E_ALL); 6 7 require_once ‘/root/tools/thrift-0.9.3/lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php‘; 8 9 use Thrift\ClassLoader\ThriftClassLoader; 10 11 $GEN_DIR = realpath(dirname(__FILE__) . ‘/../‘) . ‘/gen-php‘; 12 $loader = new ThriftClassLoader(); 13 $loader->registerNamespace(‘Thrift‘, ‘/root/tools/thrift-0.9.3/lib/php/lib‘); 14 $loader->registerDefinition(‘Img‘, $GEN_DIR); 15 $loader->register(); 16 17 18 use Thrift\Protocol\TBinaryProtocol; 19 use Thrift\Transport\TSocket; 20 use Thrift\Transport\THttpClient; 21 use Thrift\Transport\TBufferedTransport; 22 use Thrift\Exception\TException; 23 24 try { 25 if (array_search(‘--http‘, $argv)) { 26 $socket = new THttpClient(‘localhost‘, 8080, ‘/php/s.php‘); // 实际的server文件地址 27 } else { 28 $socket = new TSocket(‘localhost‘, 8080); 29 } 30 $transport = new TBufferedTransport($socket, 1024, 1024); 31 $protocol = new TBinaryProtocol($transport); 32 $client = new \Img\ImgInfoClient($protocol); 33 $transport->open(); 34 35 #[ start 根据自己的文件调用就行 ]################################################# 36 $ret = $client->getimgInfo(‘BBBBBBBBBBBBBBBBBBBB‘); 37 echo $ret; 38 echo "<br /> \r\n"; 39 40 #[ end ]################################################# 41 42 $transport->close(); 43 } catch (TException $tx) { 44 print ‘TException: ‘ . $tx->getMessage() . "\n"; 45 } 46 ?>
4. 编写服务端（server）端
文件名：c.php ；也放在了php目录下。
需要注意的点 我用红色标识
1 #! /bin/env php 2 <?php 3 namespace Img\php; 4 5 error_reporting(E_ALL); 6 7 require_once ‘/root/tools/thrift-0.9.3/lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php‘; 8 9 use Thrift\ClassLoader\ThriftClassLoader; 10 11 $GEN_DIR = realpath(dirname(__FILE__).‘/../‘).‘/gen-php‘; 12 13 $loader = new ThriftClassLoader(); 14 $loader->registerNamespace(‘Thrift‘, ‘/root/tools/thrift-0.9.3/lib/php/lib‘); 15 $loader->registerDefinition(‘Img‘, $GEN_DIR); 16 $loader->register(); 17 if (php_sapi_name() == ‘cli‘) { 18 ini_set("display_errors", "stderr"); 19 } 20 21 use Thrift\Protocol\TBinaryProtocol; 22 use Thrift\Transport\TPhpStream; 23 use Thrift\Transport\TBufferedTransport; 24 25 class ImgInfoHandler implements \Img\ImgInfoIf { 26 protected $log = array(); 27 # 编写自己个功能吧 28 public function getimgInfo($name) { 29 return $name . ‘ ==> client Request server is ok!‘; 30 } 31 32 }; 33 34 header(‘Content-Type‘, ‘application/x-thrift‘); 35 if (php_sapi_name() == ‘cli‘) { 36 echo "\r\n"; 37 } 38 39 $handler = new \Img\php\ImgInfoHandler(); 40 $processor = new \Img\ImgInfoProcessor($handler); 41 42 $transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W)); 43 $protocol = new TBinaryProtocol($transport, true, true); 44 45 $transport->open(); 46 $processor->process($protocol, $protocol); 47 $transport->close();
4. 编写端口监控代码。
使用python，用于监控指定端口的http请求并交给s.php 处理
需要注意的使用红色标识
1 #!/usr/bin/env python 2 3 4 5 import os 6 import BaseHTTPServer 7 import CGIHTTPServer 8 9 # chdir(2) into the tutorial directory. 10 os.chdir(os.path.dirname(os.path.dirname(os.path.realpath(__file__)))) 11 # 指定目录 ，如果目录错误 请求会失败 12 class Handler(CGIHTTPServer.CGIHTTPRequestHandler): 13 cgi_directories = [‘/php‘] 14 15 16 BaseHTTPServer.HTTPServer((‘‘, 8080), Handler).serve_forever()
注意： client端请求server的脚本地址 需要和这里的保持一致。
5. 测试：
1） 开启监控
python r.py
2）c 端请求 s 端
[root@localhost php]# php c.php --http
BBBBBBBBBBBBBBBBBBBB ==> client Request server is ok!<br />
3）python 监控结果展示
[root@localhost php]# python r.py localhost.localdomain - - [22/Oct/2015 02:36:34] "POST /php/s.php HTTP/1.0" 200 -
完成，希望对大家有帮助。
转载请指明出处：http://www.cnblogs.com/lpit/p/4902292.html
标签：
原文地址：http://www.cnblogs.com/lpit/p/4902292.html
