转载自: http://www.ooso.net/archives/537
这些天用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)=309858235082523Total 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)=309858235082523Total time:8 ms
这个测试中,没有耗时很长的请求,处理逻辑完全一样,php socket server耗时仅为apache + php的五分之一。
相关推荐
- "thrift-server 最简单的测试案例"表明,项目可能包含一个简单的服务器实现和对应的测试用例,用来验证Thrift服务的正确性。 - 测试通常使用JUnit或类似框架,模拟客户端调用,检查服务器的响应是否符合预期。 ...
Thrift IDL 文件被编译成多种编程语言的代码,如 C++, Java, Python 等,这些代码实现了 RPC(远程过程调用)协议层和传输层。 Thrift 的特性包括: 1. 接口描述语言:Thrift 提供了一种类似于 Java 或 C++ 的语言...
- 创建Spring配置文件,如`thrift-server.xml`,配置Thrift服务器实例(通常是`TNonBlockingServer`或`TSimpleServer`)和Thrift服务处理器。 - 使用Spring的`<bean>`标签定义Thrift服务接口的实现,并通过`@...
而在`cpp-thrift-uploadImage-server`目录下,你会看到服务端的代码,包括服务器的启动、连接处理以及`ImageService`的实现。 总结来说,这个例子展示了如何结合Qt的网络功能和Thrift的跨语言RPC机制来构建C++...
spark-hive-thriftserver_2.11-2.1.spark-hive-thrift
在“thrift实现http协议案例”中,由于Thrift默认只支持基于TCP的socket通信,而我们需要实现HTTP协议,所以需要自定义处理。这里提到的是通过继承Java的Servlet来实现。Servlet是Java Web应用程序的一部分,用于...
一组用thrift写的Java RPC框架,是两个maven项目,直接可以用,可以传字符串。 方便初学者了解thrift RPC各部分的原理,如果想自己加功能,就要新建XX.thrift文件,定义好接口,用用thrift生成
from thrift.server import TServer from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryProtocol class MyServiceImpl(MyService.Iface): def ...
spark-hive_2.11-2.3.0...spark-hive-thriftserver_2.11-2.3.0.jar log4j-2.15.0.jar slf4j-api-1.7.7.jar slf4j-log4j12-1.7.25.jar curator-client-2.4.0.jar curator-framework-2.4.0.jar curator-recipes-2.4.0.jar
这里提到了“thrift和thrift2两套代码”,这可能意味着项目包含了两种版本的Thrift实现,可能是因为不同的需求或者兼容性考虑。 在实际操作中,首先需要在服务器端安装并运行HBase,然后配置Thrift服务器。接着,在...
thrift框架通过vs2013编译好的静态库,然后通过vs2013实现双向通信代码,通信协议利用openssl加密证书的方式来实现,本资源给出了完整的实现代码,证书可以在网上百度一下,看看如何生成客户端和服务端的,然后编译...
本文将详细讲解如何使用C++实现Thrift双向通信,并以提供的"ThriftServer"和"ThriftClient"为例进行分析。 首先,理解Thrift的基本工作原理至关重要。Thrift通过定义一个中间描述文件(.thrift),来描述服务接口和...
spark和hive结合依赖,如何使用请看我博客https://blog.csdn.net/z1987865446/article/details/109372818
php 使用thrift客户端访问服务器测试 下载后 放到站点根目录,设置 thrift_test.php里的 $socket = new TSocket('10.200.28.43', 10001); 修改为默认服务器和端口 后 直接访问 http://localhost/thrift_test.php
在本Java实现Thrift的Demo中,我们将深入理解Thrift的工作原理以及如何使用Java来实现它。 首先,让我们了解Thrift的基本工作流程: 1. **接口定义**:使用Thrift IDL编写服务接口和数据类型。例如,你可以创建一...
4. **安全性**:ThriftServer可以通过Kerberos、SSL等机制实现身份验证和加密,确保数据传输的安全性。 5. **配置优化**:为了适应不同的工作负载,ThriftServer有多种配置选项,如并发查询设置、执行超时、内存...
然后运行 restart_thrift.sh 脚本就可以直接启动 ps 一下进程是否正常,如果错误请查看日志 然后就可以使用线下的php直接调用, 代码是从网上找到的,比较容易入门 当然也可以直接导入java目录下的java工程,直接运行...
在这个场景下,PHP作为客户端,通过Thrift接口与Hadoop服务器端进行通信,实现了数据的读取和写入。 首先,理解Thrift的工作原理是关键。Thrift提供了编译器,可以将服务接口定义(通常是一个.thrift文件)转换为...
本设计源码提供了一个基于Scala的Spark Thrift Server。项目包含12731个文件,主要使用Scala、Java、Python、Shell、JavaScript、CSS、HTML、Ruby和C编程语言。文件类型包括3539个Scala源代码文件、1559个Q文件、...
本篇将详细讲解如何将Spring与Thrift整合,构建一个Server和Client,以实现高效的数据通信。 首先,我们需要了解Thrift的基本原理。Thrift通过定义一种中间描述文件(.thrift),来生成不同语言的客户端和服务端...