library prime-rpc

xd/prime-rpc

Prime-rpc is a basal and asynchronous RPC library, _(*1)

Install

composer require xd/prime-rpc, _(*2)

Examples

1. Base on TCP, _(*3)

   Server, _(*4)

   <?php
   include 'vendor/autoload.php';
   $server = new \Xd\PrimeRpc\Server\TcpServer('yur server name', '0.0.0.0', '9501', 20);
   
   //bind receive event 
   \Xd\PrimeRpc\Server\IocEventServer::inject('receive', function($fd, $data){
      //do something...
   
      //output content at last
      $output = ['code' => 0, 'msg' => 'ok', 'result' => ['title' => "test={$data['test']}"]];
      return $output;
   });
   $server->start();
   

   Client, _(*5)

   <?php
   //connect host
   $client = new Xd\PrimeRpc\Client\TcpClient('127.0.0.1', 9501);
   
   //send data
   $request1 = $client->request(['test' => '1']);
   //send data
   $request2 = $client->request(['test' => '2']);
   
   //get the second response data
   $res2 = $request2->receive();
   print_r($res2);
   
   //get the first response data
   $res1 = $request1->receive();
   print_r($res1);
   
   

2. Base on HTTP Server, _(*6)

   <?php
   include 'vendor/autoload.php';
   $server = new \Xd\PrimeRpc\Server\HttpServer('yur server name', '0.0.0.0', '9501', 20);
   
   //bind request event 
   \Xd\PrimeRpc\Server\IocEventServer::inject('request', function($request, $response){
      //do something...
   
      //output content at last
      $output = ['code' => 0, 'msg' => 'ok', 'result' => ['title' => "test={$request->get['test']}"]];
      return $output;
   });
     $server->start();
   

   Client: recommend use the github.com/ganxiangdong/async-http-client, _(*7)

3. Manage server
   shutdown: sh vender/src/server/bins/shutdown.sh
   reload: sh vender/src/server/bins/reload.sh, _(*8)

4. More information please visit github.com/swoole/swoole-src, _(*9)