第一次提交

Author: Yurunsoft

.gitignore

@@ -0,0 +1,2 @@
+/vendor
+/composer.lock

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 imiphp
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,57 @@
+# imi-rpc
+
+[![Latest Version](https://img.shields.io/packagist/v/imiphp/imi-rpc.svg)](https://packagist.org/packages/imiphp/imi-rpc)
+[![Php Version](https://img.shields.io/badge/php-%3E=7.1-brightgreen.svg)](https://secure.php.net/)
+[![Swoole Version](https://img.shields.io/badge/swoole-%3E=4.1.0-brightgreen.svg)](https://github.com/swoole/swoole-src)
+[![IMI License](https://img.shields.io/github/license/imiphp/imi-rpc.svg)](https://github.com/imiphp/imi-rpc/blob/master/LICENSE)
+
+## 介绍
+
+在 imi 框架中开发 RPC 服务的基础组件。本组件不提供实际的 RPC 实现，仅提供开发 RPC 服务的一些插槽。
+
+## Composer
+
+本项目可以使用composer安装，遵循psr-4自动加载规则，在你的 `composer.json` 中加入下面的内容:
+
+```json
+{
+    "require": {
+        "imiphp/imi-rpc": "~1.0"
+    }
+}
+```
+
+然后执行 `composer update` 安装。
+
+## 使用
+
+在项目 `config/config.php` 中配置：
+
+```php
+[
+    'components'    =>  [
+        // 引入本组件
+        'rpc'    =>  'Imi\Rpc',
+    ],
+]
+```
+
+## 免费技术支持
+
+QQ群：17916227 [![点击加群](https://pub.idqqimg.com/wpa/images/group.png "点击加群")](https://jq.qq.com/?_wv=1027&k=5wXf4Zq)，如有问题会有人解答和修复。
+
+## 运行环境
+
+- [PHP](https://php.net/) >= 7.1
+- [Composer](https://getcomposer.org/)
+- [Swoole](https://www.swoole.com/) >= 4.1.0
+
+## 版权信息
+
+`imi-rpc` 遵循 MIT 开源协议发布，并提供免费使用。
+
+## 捐赠
+
+<img src="https://raw.githubusercontent.com/imiphp/imi-rpc/dev/res/pay.png"/>
+
+开源不求盈利，多少都是心意，生活不易，随缘随缘……

composer.json

@@ -0,0 +1,17 @@
+{
+    "name": "imiphp/imi-rpc",
+    "type": "library",
+    "license": "MIT",
+    "description": "在 imi 框架中开发 RPC 服务的基础组件",
+    "require": {
+        
+    },
+    "require-dev": {
+        "yurunsoft/imi": "dev-dev"
+    },
+    "autoload": {
+        "psr-4" : {
+            "Imi\\Rpc\\" : "src/"
+        }
+    }
+}

res/pay.png

@@ -0,0 +1,12 @@
+<?php
+namespace Imi\Rpc;
+
+use Imi\Server\Base;
+
+/**
+ * RPC 服务器基类
+ */
+abstract class BaseRpcServer extends Base
+{
+
+}

src/BaseRpcServer.php

@@ -0,0 +1,7 @@
+<?php
+namespace Imi\Rpc\Controller;
+
+class RpcController
+{
+
+}

src/Controller/RpcController.php

@@ -0,0 +1,76 @@
+<?php
+namespace Imi\Rpc\Listener;
+
+use Imi\ServerManage;
+use Imi\RequestContext;
+use Imi\Event\EventParam;
+use Imi\Event\IEventListener;
+use Imi\Bean\Annotation\Listener;
+use Imi\Server\Route\RouteCallable;
+use Imi\Bean\Annotation\AnnotationManager;
+use Imi\Rpc\Route\Annotation\RpcRoute;
+use Imi\Rpc\Route\Annotation\RpcAction;
+use Imi\Rpc\Route\Annotation\Parser\RpcControllerParser;
+use Imi\Rpc\BaseRpcServer;
+
+/**
+ * RPC 服务器路由初始化
+ * @Listener("IMI.MAIN_SERVER.WORKER.START")
+ */
+class RouteInit implements IEventListener
+{
+    /**
+     * 事件处理方法
+     * @param EventParam $e
+     * @return void
+     */
+    public function handle(EventParam $e)
+    {
+        $this->parseAnnotations($e);
+    }
+
+    /**
+     * 处理注解路由
+     * @return void
+     */
+    private function parseAnnotations(EventParam $e)
+    {
+        $controllerParser = RpcControllerParser::getInstance();
+        foreach(ServerManage::getServers() as $name => $server)
+        {
+            if(!$server instanceof BaseRpcServer)
+            {
+                continue;
+            }
+            RequestContext::create();
+            RequestContext::set('server', $server);
+            $route = $server->getBean('RpcRoute');
+            foreach($controllerParser->getByServer($name) as $className => $classItem)
+            {
+                $classAnnotation = $classItem['annotation'];
+                foreach(AnnotationManager::getMethodsAnnotations($className, RpcAction::class) as $methodName => $actionAnnotations)
+                {
+                    $routes = AnnotationManager::getMethodAnnotations($className, $methodName, RpcRoute::class);
+                    if(!isset($routes[0]))
+                    {
+                        $routes = [
+                            new RpcRoute([
+                                'name' => $methodName,
+                            ])
+                        ];
+                    }
+                    
+                    foreach($routes as $routeItem)
+                    {
+                        $route->addRuleAnnotation($routeItem, new RouteCallable($className, $methodName), [
+                            'serverName'    =>  $name,
+                            'controller'    =>  $classAnnotation,
+                        ]);
+                    }
+                }
+            }
+            RequestContext::destroy();
+        }
+    }
+
+}

src/Listener/RouteInit.php

@@ -0,0 +1,12 @@
+<?php
+namespace Imi\Rpc;
+
+use Imi\Main\BaseMain;
+
+class Main extends BaseMain
+{
+    public function __init()
+    {
+        
+    }
+}

src/Main.php

@@ -0,0 +1,33 @@
+<?php
+namespace Imi\Rpc\Route\Annotation\Parser;
+
+use Imi\Bean\Annotation\Base;
+use Imi\Bean\Parser\BaseParser;
+use Imi\Util\Traits\TServerAnnotationParser;
+use Imi\Rpc\Route\Annotation\RpcController;
+use Imi\Event\Event;
+
+/**
+ * 控制器注解处理器
+ */
+class RpcControllerParser extends BaseParser
+{
+    use TServerAnnotationParser;
+
+    protected $controllerAnnotationClass = RpcController::class;
+
+    /**
+     * 处理方法
+     * @param \Imi\Bean\Annotation\Base $annotation 注解类
+     * @param string $className 类名
+     * @param string $target 注解目标类型（类/属性/方法）
+     * @param string $targetName 注解目标名称
+     * @return void
+     */
+    public function parse(\Imi\Bean\Annotation\Base $annotation, string $className, string $target, string $targetName)
+    {
+        $eventName = 'IMI.RPC.ANNOTATION.PARSER:' . get_class($annotation);
+        Event::trigger($eventName, func_get_args(), $this);
+    }
+
+}