码迷,mamicode.com
首页 > Web开发 > 详细

thrift php 使用参考笔记

时间:2015-10-22 19:26:02      阅读:293      评论:0      收藏:0      [点我收藏+]

标签:

转载请指明出处: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 

 

thrift php 使用参考笔记

标签:

原文地址:http://www.cnblogs.com/lpit/p/4902292.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!