场景

例如在一个商场系统中，我们将商品库和系统公告两个服务切分开到不同的服务器当中。当用户打开商场首页的时候， 我们希望App向某个网关发起请求，该网关可以自动的帮我们请求商品列表和系统公共等数据，合并返回。

服务定义

每一个Rpc服务其实就一个EasySwoole\Rpc\AbstractService类。 如下：

定义商品服务

  1. namespace App\RpcService;
  4. use EasySwoole\Rpc\AbstractService;
  6. class Goods extends AbstractService
  7. {
  9.     public function serviceName(): string
  10.     {
  11.         return 'goods';
  12.     }
  14.     public function list()
  15.     {
  16.         $this->response()->setResult([
  17.             [
  18.                 'goodsId'=>'100001',
  19.                 'goodsName'=>'商品1',
  20.                 'prices'=>1124
  21.             ],
  22.             [
  23.                 'goodsId'=>'100002',
  24.                 'goodsName'=>'商品2',
  25.                 'prices'=>599
  26.             ]
  27.         ]);
  28.         $this->response()->setMsg('get goods list success');
  29.     }
  30. }

定义公共服务

  1. namespace App\RpcService;
  4. use EasySwoole\Rpc\AbstractService;
  6. class Common extends AbstractService
  7. {
  8.     public function serviceName(): string
  9.     {
  10.         return 'common';
  11.     }
  13.     public function mailBox()
  14.     {
  15.         $this->response()->setResult([
  16.             [
  17.                 'mailId'=>'100001',
  18.                 'mailTitle'=>'系统消息1',
  19.             ],
  20.             [
  21.                 'mailId'=>'100001',
  22.                 'mailTitle'=>'系统消息1',
  23.             ],
  24.         ]);
  25.         $this->response()->setMsg('get mail list success');
  26.     }
  28.     public function serverTime()
  29.     {
  30.         $this->response()->setResult(time());
  31.         $this->response()->setMsg('get server time success');
  32.     }
  33. }

服务注册

在Easyswoole全局的Event文件中，进行服务注册。至于节点管理、服务类定义等具体用法请看对应章节。

  1. namespace EasySwoole\EasySwoole;
  3. use App\RpcService\Common;
  4. use App\RpcService\Goods;
  5. use EasySwoole\EasySwoole\Swoole\EventRegister;
  6. use EasySwoole\EasySwoole\AbstractInterface\Event;
  7. use EasySwoole\Http\Request;
  8. use EasySwoole\Http\Response;
  9. use EasySwoole\Redis\Config\RedisConfig;
  10. use EasySwoole\RedisPool\RedisPool;
  11. use EasySwoole\Rpc\NodeManager\RedisManager;
  12. use EasySwoole\Rpc\Config as RpcConfig;
  13. use EasySwoole\Rpc\Rpc;
  15. class EasySwooleEvent implements Event
  16. {
  18.     public static function initialize()
  19.     {
  20.         // TODO: Implement initialize() method.
  21.         date_default_timezone_set('Asia/Shanghai');
  22.     }
  24.     public static function mainServerCreate(EventRegister $register)
  25.     {
  26.         /*
  27.          * 定义节点Redis管理器
  28.          */
  29.         $redisPool = new RedisPool(new RedisConfig([
  30.             'host'=>'127.0.0.1'
  31.         ]));
  32.         $manager = new RedisManager($redisPool);
  33.         //配置Rpc实例
  34.         $config = new RpcConfig();
  35.         //这边用于指定当前服务节点ip，如果不指定，则默认用UDP广播得到的地址
  36.         $config->setServerIp('127.0.0.1');
  37.         $config->setNodeManager($manager);
  38.         /*
  39.          * 配置初始化
  40.          */
  41.         Rpc::getInstance($config);
  42.         //添加服务
  43.         Rpc::getInstance()->add(new Goods());
  44.         Rpc::getInstance()->add(new Common());
  45.         Rpc::getInstance()->attachToServer(ServerManager::getInstance()->getSwooleServer());
  46.     }
  48.     public static function onRequest(Request $request, Response $response): bool
  49.     {
  50.         // TODO: Implement onRequest() method.
  51.         return true;
  52.     }
  54.     public static function afterRequest(Request $request, Response $response): void
  55.     {
  56.         // TODO: Implement afterAction() method.
  57.     }
  58. }

为了方便测试，我把两个服务放在同一台机器中注册。实际生产场景应该是N台机注册商品服务，N台机器注册公告服务，把服务分开。