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

namespace php Img

service ImgInfo{    
   string getimgInfo(1: string url),
}  

 

2. 生成文件thrift文件中間接口文件

   thrift -r --gen php:server imginfo.thrift

　　官網上面沒有添加server參數。我添加sever並測試通過，官網的方法本人沒有測試。

　　會在 imginfo.thrift 的目錄生成一個 gen-php 目錄，采用不同的語言會生成不同的目錄

3. 編寫客戶端（client）程序

　　在imginfo.thrift 目錄層 創建php目錄  用於存放 客戶端腳本。

　　文件名：c.php

      

<?php

namespace Img\php;
# 紅色是需要根據自己的實際情況修改目錄的點
error_reporting(E_ALL);

require_once '/root/tools/thrift-0.9.3/lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';

use Thrift\ClassLoader\ThriftClassLoader;

$GEN_DIR = realpath(dirname(__FILE__) . '/../') . '/gen-php';
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', '/root/tools/thrift-0.9.3/lib/php/lib');
$loader->registerDefinition('Img', $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/s.php'); // 實際的server文件地址
    } else {
        $socket = new TSocket('localhost', 8080);
    }
    $transport = new TBufferedTransport($socket, 1024, 1024);
    $protocol = new TBinaryProtocol($transport);
    $client = new \Img\ImgInfoClient($protocol);
    $transport->open();

#[ start 根據自己的文件調用就行  ]#################################################
    $ret = $client->getimgInfo('BBBBBBBBBBBBBBBBBBBB');
     echo $ret;
     echo "<br /> \r\n";
    
#[ end ]#################################################

    $transport->close();
} catch (TException $tx) {
    print 'TException: ' . $tx->getMessage() . "\n";
}
?>

 

4. 編寫服務端（server）端

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

　　需要注意的點  我用紅色標識

#!  /bin/env  php 
<?php
namespace Img\php;

error_reporting(E_ALL);

require_once '/root/tools/thrift-0.9.3/lib/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';

use Thrift\ClassLoader\ThriftClassLoader;

$GEN_DIR = realpath(dirname(__FILE__).'/../').'/gen-php';

$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', '/root/tools/thrift-0.9.3/lib/php/lib');
$loader->registerDefinition('Img', $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 ImgInfoHandler implements \Img\ImgInfoIf {
  protected $log = array();
  # 編寫自己個功能吧
  public function getimgInfo($name) {
      return $name .  ' ==>   client Request server is ok!';
  }

};

header('Content-Type', 'application/x-thrift');
if (php_sapi_name() == 'cli') {
  echo "\r\n";
}

$handler = new \Img\php\ImgInfoHandler();
$processor = new \Img\ImgInfoProcessor($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();

4. 編寫端口監控代碼。

　　使用python，用於監控指定端口的http請求並交給s.php 處理

     需要注意的使用紅色標識

#!/usr/bin/env python



import os
import BaseHTTPServer
import CGIHTTPServer

# chdir(2) into the tutorial directory.
os.chdir(os.path.dirname(os.path.dirname(os.path.realpath(__file__))))
# 指定目錄 ，如果目錄錯誤 請求會失敗
class Handler(CGIHTTPServer.CGIHTTPRequestHandler):
  cgi_directories  = ['/php']


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