标签:names ide tis nginx red new cli artisan art
luman/laravel:5.5
php:7.2
thrift -version :Thrift version 0.11.0
thrift文件模板:testServer.thrift
namespace php Rpc.Test service Echop { string Echop(1: string str) , }
生成RPC文件:
thrift -r --out ./app --gen php:server ./ThriftSource/testServer.thrift
安装第三方扩展包:
composer require sunlong/thrift
或者
https://github.com/sunlongv5/thrift.git
composer文件修改:
"autoload": { "classmap": [ "app/Rpc" ], "psr-4": { "Rpc\\": "app/Rpc", "Services\\": "app/services", "Thrift\\": "vendor/sunlong/thrift/lib/php/lib/Thrift/" } },
新建Sevice文件夹创建文件EchopServie.php 实现thrift的Echop方法
<?php namespace Services; use Rpc\Test\EchopIf; class EchopServie implements EchopIf{ public function Echop($str){ \Log::info($str); // for($i=0;$i<=100000;$i++){ // \Log::info($i); // } // sleep(10); return "RPC:".$str; } }
创建文件app\Console\Commands\RpcServer.php
此代码为thrift的server实现
<?php namespace App\Console\Commands; use Illuminate\Console\Command; use Thrift\Exception\TException; use Thrift\Factory\TBinaryProtocolFactory; use Thrift\Factory\TTransportFactory; use Thrift\Server\TServerSocket; use Thrift\Server\TSimpleServer; use Thrift\Server\TForkingServer; use Thrift\TMultiplexedProcessor; use Rpc\Test\EchopClient; use Rpc\Test\EchopProcessor; use Thrift\Protocol\TBinaryProtocol; use Thrift\Transport\TBufferedTransport; class RpcServer extends Command{ protected $signature = ‘server:rpc‘; /** * 控制台命令说明。 * * @var string */ protected $description = ‘rpc 服务‘; protected static $socketController; public function handle() { try { $handler = new \Services\EchopServie(); $processor = new EchopProcessor($handler); // 将服务注册到TMultiplexedProcessor中 $tFactory = new TTransportFactory(); $pFactory = new TBinaryProtocolFactory(true, true); $multiplexedProcessor = new TMultiplexedProcessor(); $multiplexedProcessor->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()); } } }
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(‘http://192.168.1.188‘, 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秒返回的结果,没有阻塞
thrift之php使用TServerSocket并发 处理请求
标签:names ide tis nginx red new cli artisan art
原文地址:https://www.cnblogs.com/sunlong88/p/10702842.html