RPC & SOA

EasySwoole 同样可以做串行、并行化的SOA服务调用，底层基于SWOOLE_TCP实现，支持自定义消息加解密，为方便多种客户端（不同语言）调用，服务交互采用json格式传递，开发者可以快速以其他语言实现。

场景描述

例如，某个应用中，A为前端承载机器，B与C分别部署着不同的服务。一个用户请求进来，A同时向BC发起请求获取，并汇集两个结果返回给用户。

在EasySwoole中，RPC服务以服务名=>多个行为名的形式存在。

创建服务命令注册类

  1. namespace App\RPC;
  4. use Core\Component\RPC\AbstractInterface\AbstractActionRegister;
  5. use Core\Component\RPC\Common\ActionList;
  6. use Core\Component\RPC\Common\Package;
  8. class Goods extends AbstractActionRegister
  9. {
  11.     function register(ActionList $actionList)
  12.     {
  13.         // TODO: Implement register() method.
  14.         $actionList->setDefaultAction(function (Package $req,Package $res){
  15.             $res->setMessage('this is goods default');
  16.         });
  17.     }
  18. }
  1. namespace App\RPC;
  4. use Core\Component\RPC\AbstractInterface\AbstractActionRegister;
  5. use Core\Component\RPC\Common\ActionList;
  6. use Core\Component\RPC\Common\Package;
  7. use Core\Component\Socket\Client\TcpClient;
  9. class User extends AbstractActionRegister
  10. {
  12.     function register(ActionList $actionList)
  13.     {
  14.         // TODO: Implement register() method.
  15.         $actionList->registerAction('who', function (Package $req, Package $res, TcpClient $client) {
  16.             var_dump('your req package is' . $req->__toString());
  17.             $res->setMessage('this is User.who');
  18.         });
  21.         $actionList->registerAction('login', function (Package $req, Package $res, TcpClient $client) {
  22.             var_dump('your req package is' . $req->__toString());
  23.             $res->setMessage('this is User.login');
  24.         });
  26.         $actionList->setDefaultAction(function (Package $req, Package $res, TcpClient $client) {
  27.             $res->setMessage('this is user.default');
  28.         });
  30.     }
  31. }
  1. namespace App\RPC;
  4. use Core\Component\RPC\AbstractInterface\AbstractActionRegister;
  5. use Core\Component\RPC\Common\ActionList;
  6. use Core\Component\RPC\Common\Package;
  7. use Core\Component\Socket\Client\TcpClient;
  9. class User2 extends AbstractActionRegister
  10. {
  12.     function register(ActionList $actionList)
  13.     {
  14.         // TODO: Implement register() method.
  15.         $actionList->registerAction('who', function (Package $req, Package $res, TcpClient $client) {
  16.             var_dump('your req package is' . $req->__toString());
  17.             $res->setMessage('this is User.who');
  18.         });
  21.         $actionList->registerAction('login', function (Package $req, Package $res, TcpClient $client) {
  22.             var_dump('your req package is' . $req->__toString());
  23.             $res->setMessage('this is User.login');
  24.         });
  26.         $actionList->setDefaultAction(function (Package $req, Package $res, TcpClient $client) {
  27.             $res->setMessage('this is user.default');
  28.         });
  30.     }
  31. }

以上代码，实现了三个不同服务的命令注册。

监听服务

在服务启动前事件中，进行服务注册。

  1. function beforeWorkerStart(\swoole_server $server)
  2. {
  3.         // TODO: Implement beforeWorkerStart() method.
  4.         $conf = new \Core\Component\RPC\Common\Config();
  5.         $server = new Server($conf);
  6.         $server->registerServer('user')->setActionRegisterClass(User::class);
  7.         $server->registerServer('goods')->setActionRegisterClass(Goods::class);
  8.         $server->attach(9502);
  10.         $server2 = new Server($conf);
  11.         $server2->registerServer('user')->setActionRegisterClass(User2::class);
  12.         $server2->attach(9503);
  13. }

调用客户端

  1. use Core\Component\RPC\Common\Package;
  2. $conf = new \Core\Component\RPC\Common\Config();
  3. $conf->setPort(9502);
  4. $conf->setHost('127.0.0.1');
  6. $client = new \Core\Component\RPC\Client\Client();
  7. $server1 = $client->selectServer($conf);
  8. $server1->addCall('user','who',null,function (Package $req,Package $res){
  9.     echo "call success at".$res->__toString()."\n";
  10. },function (Package $req,Package $res){
  11.     echo "call fail at".$res->__toString()."\n";
  12. });
  14. $server1->addCall("user",'login',[1,2,3,4],function (Package $req,Package $res){
  15.     echo "call success at".$res->__toString()."\n";
  16. });
  18. $server1->addCall("user",'404',[1,2,3,4],function (Package $req,Package $res){
  19.     echo "call success at".$res->__toString()."\n";
  20. });
  22. $server1->addCall('goods','404',null,function (){
  23.     echo "success"."\n";
  24. });
  26. $conf2 = new \Core\Component\RPC\Common\Config();
  27. $conf2->setHost('127.0.0.1');
  28. $conf2->setPort(9503);
  30. $server2 = $client->selectServer($conf2);
  31. $server2->addCall('user','404',null,function (){
  32.     echo "success at server 2";
  33. });
  35. $client->call();