title: Rpc server meta:

  • name: description content: RPC server implementation in EasySwoole
  • name: keywords content: swoole|swoole extension|swoole framework|Easyswoole|Rpc server | swoole RPC

Server

Independent code

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: xcg
  5.  * Date: 2019/5/30
  6.  * Time: 9:17
  7.  */
  8. require_once 'vendor/autoload.php';
  10. use EasySwoole\Rpc\Config;
  11. use EasySwoole\Rpc\Rpc;
  12. use EasySwoole\Rpc\NodeManager\RedisManager;
  13. use EasySwoole\Rpc\Test\UserService;
  14. use EasySwoole\Rpc\Test\OrderService;
  15. use EasySwoole\Rpc\Test\NodeService;
  17. $config = new Config();
  18. $config->setServerIp('127.0.0.1');//Register to provide ip service ip
  20. $config->setNodeManager(new RedisManager('127.0.0.1'));//Register Node Manager
  21. $config->getBroadcastConfig()->setSecretKey('lucky');    //Set key
  23. $config->getBroadcastConfig()->setEnableBroadcast(false);     //Whether to enable broadcast (ps: use redis node to close)
  24. $config->getBroadcastConfig()->setEnableListen(false);        //Whether to enable listening broadcast (ps: use redis node to close)
  26. $rpc = new Rpc($config);
  27. $rpc->add(new UserService());  //Registration service
  28. $rpc->add(new OrderService());
  29. $rpc->add(new NodeService());
  31. $list = $rpc->generateProcess();   
  32. foreach ($list['worker'] as $p) {//Start the rpc process
  33.     $p->getProcess()->start();
  34. }
  36. foreach ($list['tickWorker'] as $p) { //Start the timing process (ps: timed broadcast, monitor broadcast)
  37.     $p->getProcess()->start();
  38. }
  40. while ($ret = \Swoole\Process::wait()) {//Recycling child process
  41.     echo "PID={$ret['pid']}\n";
  42. }

Used under the easyswoole framework

  1. <?php
  2. use EasySwoole\Rpc\Config;
  3. use EasySwoole\Rpc\Rpc;
  4. use EasySwoole\Rpc\NodeManager\RedisManager;
  5. use EasySwoole\Rpc\Test\UserService;
  6. use EasySwoole\Rpc\Test\OrderService;
  7. use EasySwoole\Rpc\Test\NodeService;
  8. use EasySwoole\EasySwoole\ServerManager;
  10. #Register in the global mainServerCreate event of EasySwooleEvent.php
  12. $config = new Config();
  13. $config->setServerIp('127.0.0.1');//Register to provide ip service ip
  14. $config->setNodeManager(new RedisManager('127.0.0.1'));//Register Node Manager
  15. $config->getBroadcastConfig()->setSecretKey('lucky');        //Set key        
  17. $rpc = Rpc::getInstance($config);;
  18. $rpc->add(new UserService());  //Registration service
  19. $rpc->add(new OrderService());
  20. $rpc->add(new NodeService());
  22. $rpc->attachToServer(ServerManager::getInstance()->getSwooleServer());