php实现的thrift socket server

这些天用php写了个thrift的socket server,因为原来thrift的源码里php部分只有基于apache的服务器端代码,再加上前些日子看到php也能直接使用libevent构建web服务器,所以才会想到写这个玩玩。

php-thrift-server源码

代码直接从apache的thrift项目clone过来,托管在github上:

http://github.com/volca/thrift

新增或改动的代码如下:

    lib/php/
    `-- src
        |-- server
        |   |-- TNonblockingServer.php
        |   `-- TServer.php
        `-- transport
            |-- TNonblockingServerSocket.php
            |-- TNonblockingSocket.php
            |-- TServerSocket.php
            |-- TServerTransport.php
    test/php
    |-- TestClient.php
    |-- TestNonblockingServer.php
    

使用示例

获取thrift的源码,并编译出thrift工具,编译过程请搜索


git clone git://github.com/volca/thrift.git

安装php,以及apc, libevent扩展:


pecl install apc
#需要先libevent-devel之类的包包
pecl install libevent

运行php的socket服务器,我直接从thrift的test代码中修改了一个独立运行的php server,见thrift/test/php/TestNonblockingServer.php,这里也包含一个测试业务代码的实现。


cd thrift/test/php
#用thrift命令行工具生成php的测试类库
make 
#启动thrift服务,会监听本机的9090端口
php TestNonblockingServer.php

客户端的代码也一并提供,对各种数据类型比如int, float, string, list等等进行测试。


php TestClient.php

性能测试

apache + php的测试结果

testVoid() = void
testString("Test") = "Test"
testByte(1) = 1
testI32(-1) = -1
testI64(-34359738368) = -34359738368
testDouble(-852.234234234) = -852.234234234
testStruct({"Zero", 1, -3, -5}) = {"Zero", 1, -3, -5}
testNest({1, {"Zero", 1, -3, -5}), 5} = {1, {"Zero", 1, -3, -5}, 5}
testMap({0 => -10, 1 => -9, 2 => -8, 3 => -7, 4 => -6}) = {0 => -10, 1 => -9, 2 => -8, 3 => -7, 4 => -6}
testSet({-2, -1, 0, 1, 2}) = {1, 1, 1, 1, 1}
testList({-2, -1, 0, 1, 2}) = {-2, -1, 0, 1, 2}
testEnum(ONE) = 1
testEnum(TWO) = 2
testEnum(THREE) = 3
testEnum(FIVE) = 5
testEnum(EIGHT) = 8
testTypedef(309858235082523) = 309858235082523
Total time: 41 ms

php + libevent的socket server测试结果

testVoid() = void
testString("Test") = "Test"
testByte(1) = 1
testI32(-1) = -1
testI64(-34359738368) = -34359738368
testDouble(-852.234234234) = -852.234234234
testStruct({"Zero", 1, -3, -5}) = {"Zero", 1, -3, -5}
testNest({1, {"Zero", 1, -3, -5}), 5} = {1, {"Zero", 1, -3, -5}, 5}
testMap({0 => -10, 1 => -9, 2 => -8, 3 => -7, 4 => -6}) = {0 => -10, 1 => -9, 2 => -8, 3 => -7, 4 => -6}
testSet({-2, -1, 0, 1, 2}) = {1, 1, 1, 1, 1}
testList({-2, -1, 0, 1, 2}) = {-2, -1, 0, 1, 2}
testEnum(ONE) = 1
testEnum(TWO) = 2
testEnum(THREE) = 3
testEnum(FIVE) = 5
testEnum(EIGHT) = 8
testTypedef(309858235082523) = 309858235082523
Total time: 8 ms

这个测试中,没有耗时很长的请求,处理逻辑完全一样,php socket server耗时仅为apache + php的五分之一。

thrift是什么?

thrift流传的似乎不是太广泛,而且有被别的技术替代的趋势,所以下面还是引用一下别的文章的介绍:

Thrift由一个软件库和一系列的代码生成工具组成,由 Facebook开发。目的是为了加快软件开发和实现高效和可扩展的后台服务。主要目标是不同程序开语言之间实现高效和可靠的通信,这需要将不同语言之间抽象出一个通用层,然后由不同语言来实现这个通用层。在这里要特别指出的是,Thrift允许开发人员定义数据类型和服务接口(定义在一个中性语言文件里),并通过这个文件生成构建RPC客户端和服务端所需的代码。

简单分析其机理,Thrift就是实现C/S模式,通过代码生成工具将接口定义文件生成服务器端和客户端代码(可以为不同语言),从而实现服务端和客户端跨语言的支持。

Thrift可以分为传输层和协议层:

传输层定义了数据的传输方式,可以为TCP/IP传输,内存共享或者文件共享等形式;
协议层定义了数据的传输格式,可以为二进制流或者XML等形式。
当服务器端使用socket协议时,可以用simple|thread-pool|threaded|nonblocking等方式运行,从而获得更好的性能。

作者: 发表于June 25, 2010 at 4:03 pm

版权信息: 可以任意转载, 转载时请务必以超链接形式标明文章原始出处作者信息及此声明

Tags: ,,,

9 条评论

  1. codeblocker 于 2010-08-13 @ 09:30:48 留言

    用thrift写一个服务,最大的问题是如何克服系统单点故障,你有什么解决方案没

  2. Volcano 于 2010-08-13 @ 13:50:58 留言

    thrift源码的php部分,有利用apc扩展来保存多个服务的状态,一定程度解决了单点故障,见
    http://github.com/volca/thrift/blob/trunk/lib/php/src/transport/TSocketPool.php

    如果从服务端着手,我可能会考虑用haproxy之类的进行分发

  3. codeblocker 于 2010-08-13 @ 18:12:14 留言

    @Volcano
    基于thrift有没有一种failover的解决方案呢?

  4. lxy 于 2011-03-23 @ 17:31:43 留言

    博主认为什么技术会取代thrift?请教
    方便的话email联络

  5. Volcano 于 2011-03-23 @ 19:29:51 留言

    取代谈不上,目前类似的有protobuf, avro

  6. 王某某 于 2012-03-01 @ 16:31:43 留言

    请问 ThriftTestProcessor 这个类是哪来的 在 TestNonblockingServer.php 中 175 行 本人是个菜鸟 还请博主指点

  7. Volcano 于 2012-03-02 @ 12:02:43 留言

    ThriftTestProcessor这个是用thrift的命令行生成的

  8. 小红帽 于 2014-04-13 @ 02:48:10 留言

    我参照博主的代码写了一个thrift socket server,也是用的libevent,并且客户端有自动容灾的功能。容灾原理是当客户端发现当前服务器无法连接时便将故障ip放到共享内存中,客户单服务器的其它进程调用服务时时会首先将共享内存中的故障ip读出来,然后过滤掉故障ip后剩下可用的ip中选一个去连接,这样避免了后续请求访问到故障节点。另外还有自动恢复探测功能,原理是客户端请求服务时有一定几率(万分之一)去访问故障节点,用来探测故障节点是否已经恢复。哦,我写的东东叫workerman-thrift,在git上

  9. walkor 于 2014-05-06 @ 22:41:28 留言

    workerman-thrift-rpc 可用于生产环境的 php thrift socket server,很不错

RSS 为此帖反馈评论