wokerman thrift调试历程

前期准备:
yum -y update
wget http://mirrors.cnnic.cn/apache/thrift/0.9.0/thrift-0.9.0.tar.gz
yum -y groupinstall "Development Tools"

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
make && make install

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
make && make install

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
./bootstrap.sh
./configure --prefix=/usr
make && make install

yum -y install libevent-devel zlib-devel openssl-devel
thrift安装包:1wget https://mirrors.cnnic.cn/apache/thrift/0.9.3/thrift-0.9.3.tar.gz
2
3./configure && sudo make && sudo make install
1启动
2/usr/server/php7/bin/php start.php start
3关闭
4/usr/server/php7/bin/php start.php stop
下面我们实际创建个例子1.第一步模仿下官方例子,自己建一个thift协议1namespace php Services.UserInfo
2service UserInfo
3{
4    string sayHello(1:string name);
5    i32 getMyScore(1:string age)
6}
7
命名空间第一个语言名,后面为生成的命名空间名称。
此处实现了两个方法:一个返回字符串类型 第二个返回int32类型
他们均接受一个字符串参数2.生成代码文件1thrift -gen php:server UserInfo.thrift
3.在当前目录下的 gen-php/Services应该生成了个UserInfo的文件夹。UserInfo此为命名空间目录,下面的文件夹共有两个文件。Types.php 2. UserInfo.php将生成的文件目录UserInfo 复制到 workerman 下面的Applications/ThriftRpc/Services/下cp ./UserInfo /data/www/xxx/workerman-thrift/Applications/ThriftRpc -r

在复制过来的UserInfo里面新建 UserInfoHandler.php 文件, 实现UserInfoIf的接口,这些接口是我们在UserInfo.thrift中定义的。
<br />&lt;?php</li>
</ol>
namespace Services\UserInfo;class UserInfoHandler implements UserInfoIf
{
   public function sayHello($name)
   {
       //mysql查询
       return ["123","456"];
   }¨K62K}
如果你的返回值类型并不是thrift文件定义的那样,将会被强制转义并在后台报一条错误。 必须以Handler结尾的文件类名6.绑定端口提供服务1$worker = new ThriftWorker('tcp://0.0.0.0:9093');
2$worker->name = 'UserInfo'; //设置进程名称
3$worker->count = 2;  //开启两个进程提供
4$worker->class = 'UserInfo'; //要提供的服务名称
1/usr/server/php7/bin/php start.php start 启动
2/usr/server/php7/bin/php start.php  stop 停止
3/usr/server/php7/bin/php start.php restart 重启
4/usr/server/php7/bin/php start.php reload 平滑重启
注意启动后查看 进程名称是否存在,listen中tcp列表 是否有我们新增的端口
相应的process数量对应我们刚才设置的count属性。服务简单的运行起来了,下面我们看下客户端1.首先我们引入ThriftClient.php1require "/data/www/xxx/workerman-thrift/Applications/ThriftRpc/Clients/ThriftClient.php";
2
3use ThriftClient\ThriftClient; 
它会自动帮我们引入我们需要的类 1thriftClient::config(
 2    array(
 3        'HelloWorld' => array(
 4            'addresses' => array(
 5                '127.0.0.1:9090',
 6                //'127.0.0.2:9191',
 7            ),
 8            'thrift_protocol' => 'TBinaryProtocol',//不配置默认是TBinaryProtocol，对应服务端HelloWorld.conf配置中的thrift_protocol
 9            'thrift_transport' => 'TBufferedTransport',//不配置默认是TBufferedTransport，对应服务端HelloWorld.conf配置中的thrift_transport
10        ),
11        'UserInfo' => array(
12            'addresses' => array(
13                '127.0.0.1:9093'
14            ),
15        ),
16    )
17);
UserInfo服务是我们新增的服务，address是我们的端口号，是个数组的配置。地址是可以支持多个，进行随机请求处理。3.获取UserInfo的实例－调用方法1$client = ThriftClient::instance('UserInfo');
2$data = $client->getMyScore(12); //同步调用
3var_dump($data);
4
5$client->asend_sayHello(12); //异步调用
6echo $client->arecv_sayHello(12); //接收
注意 异步调用和接收值的传参数必须一致,否则无法定位到该接收哪个值。更多的thrift语法使用: 11基本类型
 2bool: 布尔值 (true or false), one byte
 3
 4byte: 有符号字节
 5
 6i16: 16位有符号整型
 7
 8i32: 32位有符号整型
 9
10i64: 64位有符号整型
11
12double: 64位浮点型
13
14string: Encoding agnostic text or binary string
1map<string,string> getMyScore(1:i32 age) 
返回值为key和value均强制转换为为string.1list<map<string,string>> getMyScore(1:i32 age)
注意list结构其实对应php的0,1,2,3有序下标。1return [
2        'data'=>["name" => "小明", "age" => 18, "is_open" => true],
3        'common' => [
4            'uid' => 12,
5        ],
6    ];
返回结果： 1array (
 2  0 => 
 3  array (
 4    'name' => '小明',
 5    'age' => '18',
 6    'is_open' => '1',
 7  ),
 8  1 => 
 9  array (
10    'uid' => '12',
11  ),
12)
结构体1map<string,map<string,string>> getMyScore(1:i32 age)
返回值 1array (
 2  'data' => 
 3  array (
 4    'name' => '小明',
 5    'age' => '18',
 6    'is_open' => 'true',
 7  ),
 8  'uid' => 
 9  array (
10    0 => '1',
11    1 => '2',
12    2 => '3',
13    3 => '4',
14    4 => '5',
15  ),
16)
结构体1map<string,map<string,string>> getMyScore(1:i32 age)
返回值： 1array (
 2  'data' => 
 3  array (
 4    'name' => '小明',
 5    'age' => '18',
 6    'is_open' => 'true',
 7  ),
 8  'uid' => 
 9  array (
10    0 => '1',
11    1 => '2',
12    2 => '3',
13    3 => '4',
14    4 => '5',
15  ),
16)
如何为自己的应用程序拓展model层等1$loader = new ThriftClassLoader();
2$loader->registerNamespace('Thrift', THRIFT_ROOT.'/Lib');
3$loader->registerNamespace('Service', THRIFT_ROOT);
4$loader->registerNamespace('Model', THRIFT_ROOT.'/Model');
5$loader->register();
workerman-thrift/Applications/ThriftRpc/ThriftWorker.php:22
注册Model到命名空间中log文件地址1/data/www/xxx/workerman-thrift/vendor/workerman/workerman.log
thrift实际部署工作流thrift区分客户端和服务端 1#!/bin/sh
 2
 3cd `dirname $0`
 4
 5for name in `ls ./thrift`
 6do
 7   thrift -gen php:server ./thrift/$name
 8   cp ./gen-php/Services/* ../Applications/ThriftRpc/Services/ -r
 9  /usr/server/php7/bin/php  ../start.php restart -d
10
11done
在服务器端的脚本,扫描文件生成,复制到业务目录里,然后重启workerman
但是客户端需要用到生成的文件XXService/XXService.php，整个工作流目前怎么管理还不知道,希望有耐心看到这里的读者给我些思路。 目前用的手动创建目录复制。客户端调用实例: 1require "./Clients/ThriftClient.php";
 2
 3use ThriftClient\ThriftClient;
 4
 5thriftClient::config(
 6    array(
 7        'PayService' => array(
 8            'addresses' => array(
 9                '127.0.0.1:9090',
10                //'127.0.0.2:9191',
11            ),
12            'thrift_protocol' => 'TBinaryProtocol',//不配置默认是TBinaryProtocol，对应服务端HelloWorld.conf配置中的thrift_protocol
13            'thrift_transport' => 'TBufferedTransport',//不配置默认是TBufferedTransport，对应服务端HelloWorld.conf配置中的thrift_transport
14        ),
15    )
16);
17
18$client = ThriftClient::instance('PayService');
19//获取详情
20//var_export($client->xxxxx('1144778255615962','26')); 
21var_export($client->xxxxxx(12312));  
使用composer安装客户端composer.json 1{
 2  "name":"thrift client",
 3  "require":{
 4    "cto/thrift_client":"dev-master"
 5  },
 6  "repositories":{
 7    "cto/thrift_client":{
 8      "type":"git",
 9      "url":"https://github.com/chinawangyu/thriftClient.git"
10    }
11  },
12  "autoload":{
13    "psr-4": {
14      "ThriftClient\\": "vendor/cto/thrift_client"
15    }
16  }
17}
require加载进来的名字 repositories仓库地址workerman运行:1/usr/server/php7/bin/php start.php status
2查看运行状态
监控workerman运行http://127.0.0.1:55757/
需要额外配置  Applications/Statistics/Lib/Cache.php1 public static $ServerIpList = array('127.0.0.1');
定义返回一个二维数组类型php中获取数据库中查询的一维数组返回回来：注册我们提供的服务地址启动服务