标签：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
