thrift之php，python使用TServerSocket并发 处理请求

thrift之php，python使用TServerSocket并发 处理请求

要求：

不适用nginx+fastcgi情况下，分布式系统之间如果通讯，如果不阻塞，能并发处理请求

环境：

luman/laravel：5.5php：7.2 thrift -version ：Thrift version 0.11.0

thrift文件模板：testServer.thrift

namespace php Rpc.Testservice Echop { string Echop(1: string str) ,}

生成RPC文件：

thrift -r --out ./app --gen php:server ./ThriftSource/testServer.thrift

服务端的实现：

安装第三方扩展包：

composer require sunlong/thrift

或者

{ "classmap": [ "app/Rpc" ], "psr-4": { "Rpc\\": "app/Rpc", "Services\\": "app/services", "Thrift\\": "vendor/sunlong/thrift/lib/php/lib/Thrift/" } },

新建Sevice文件夹创建文件EchopServie.php  实现thrift的Echop方法

创建文件app\Console\Commands\RpcServer.php

此代码为thrift的server实现

registerProcessor("Echop", $processor); // 监听开始 $transport = new TServerSocket('0.0.0.0', '9998'); $server = new TForkingServer($processor, $transport, $tFactory, $tFactory, $pFactory, $pFactory); $server->serve(); } catch (TException $te) { throw new \Exception($te->getMessage()); } }}

RpcServer

app\Console\Kernel.php文件中添加

protected $commands = [ RpcServer::class, ];

客户端实现：

添加路由：

$router->get('/rpc/test', ['uses' => 'Controller@test']);

Controller文件新增test方法

public function test(){ try { ini_set('memory_limit', '1024M');// $socket = new THttpClient('5201, '/rpc/test2'); $socket = new TSocket('192.168.1.188', '9998'); $socket->setRecvTimeout(50000); $socket->setDebug(true); $transport = new TBufferedTransport($socket, 1024, 1024); $protocol = new TBinaryProtocol($transport); $client = new \Rpc\Test\EchopClient($protocol); $transport->open(); $result = $client->Echop('hello world !'); print_r($result); $transport->close(); } catch (TException $tx) { print_r($tx->getMessage()); } }

启动服务端：

/application/php7/bin/php artisan server:rpc

模拟请求：

7878端口为nginx启动的客户端地址

同时刷新三个页面，发现每个页面都是5秒返回的结果，没有阻塞

采用python客户端测试：

/application/python3.6.4/bin/pip3  install thrift

生成pthon客户端thrift文件

thrift -out .. --gen py ./ThriftSource/testPyServer.thrift

编写python的客户端：

#! /usr/bin/env python# -*- coding: utf-8 -*-from thrift.transport import TSocketfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocolfrom Rpc.Python.Echop import Clientimport threading__HOST = '192.168.1.188'__PORT = 9998def send(data): tsocket = TSocket.TSocket(__HOST, __PORT) transport = TTransport.TBufferedTransport(tsocket) protocol = TBinaryProtocol.TBinaryProtocol(transport) client = Client(protocol) transport.open() print(client.Echop(data))if __name__ == '__main__': threadl = [] t1 = threading.Thread(target=send,args=('python001',)) t2 = threading.Thread(target=send,args=('python002',)) t3 = threading.Thread(target=send,args=('python003',)) threadl.append(t1) threadl.append(t2) threadl.append(t3) for x in threadl: x.start()

执行客户端

python3 ./client.py

结果同一时刻返回三条记录

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。