thrift php 使用参考笔记

转载请指明出处：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 Img2 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 Imgphp; 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 ThriftClassLoaderThriftClassLoader;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 ThriftProtocolTBinaryProtocol;19 use ThriftTransportTSocket;20 use ThriftTransportTHttpClient;21 use ThriftTransportTBufferedTransport;22 use ThriftExceptionTException;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 ImgImgInfoClient($protocol);33     $transport->open();34 35 #[ start 根据自己的文件调用就行  ]#################################################36     $ret = $client->getimgInfo('BBBBBBBBBBBBBBBBBBBB');37      echo $ret;38      echo "<br /> rn";39     40 #[ end ]#################################################41 42     $transport->close();43 } catch (TException $tx) {44     print 'TException: ' . $tx->getMessage() . "n";45 }46 ?>

4. 编写服务端（server）端

　　文件名：s.php ；也放在了php目录下。

　　需要注意的点我用红色标识

 1 #!  /bin/env  php  2 <?php 3 namespace Imgphp; 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 ThriftClassLoaderThriftClassLoader;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 ThriftProtocolTBinaryProtocol;22 use ThriftTransportTPhpStream;23 use ThriftTransportTBufferedTransport;24 25 class ImgInfoHandler implements ImgImgInfoIf {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 "rn";37 }38 39 $handler = new ImgphpImgInfoHandler();40 $processor = new ImgImgInfoProcessor($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 --httpBBBBBBBBBBBBBBBBBBBB ==>   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

爱程序网

Tags：thrift php 使用参考笔记