增加异步命令执行，更新文档

Author: dzvon

README.md

@@ -4,8 +4,6 @@
 
 Encapsulate communication of services.
 
-**!!! At this time the package is still in developmental stage and should not be used in production.**
-
 ## Installation
 
 Require this package with composer:
@@ -43,21 +41,36 @@ use Per3evere\Preq\AbstractCommand;
 class Example extends AbstractCommand
 {
     /**
-     * 执行命令
+     * 同步执行命令.
      *
      * @return void
      */
     public function run()
     {
         return 'run!';
     }
+
+    /**
+     * 异步执行命令.
+     *
+     * @return \Guzzlehttp\Promise\Promise;
+     */
+    public function runAsync()
+    {
+        // 返回注意返回类型.
+    }
 }
 ```
 
 execute it
 
 ```php
 $command = app('preq')->getCommand(\App\Services\Example::class);
+
+// 同步执行命令
 echo $command->execute();
+
+// 异步执行命令
+$command->queue();
 ```
 

composer.json

@@ -13,7 +13,8 @@
     ],
     "require": {
         "php": ">=5.6.4",
-        "illuminate/support": "~5.1"
+        "illuminate/support": "~5.1",
+        "guzzlehttp/promises": "^1.0"
     },
     "require-dev": {
         "phpunit/phpunit": "~4.0|~5.0"

src/AbstractCommand.php

@@ -8,6 +8,7 @@
 use Per3evere\Preq\Contract\Command as CommandContract;
 use Illuminate\Support\Arr;
 use Throwable;
+use GuzzleHttp\Promise\PromiseInterface;
 
 abstract class AbstractCommand implements CommandContract
 {
@@ -131,16 +132,6 @@ public function setRequestLog(RequestLog $requestLog)
         $this->requestLog = $requestLog;
     }
 
-    /**
-     * 获取请求日志.
-     *
-     * @return void
-     */
-    public function getRequestLog()
-    {
-        return $this->requestLog;
-    }
-
     /**
      * 初始化配置.
      */
@@ -189,7 +180,7 @@ private function isRequestCacheEnabled()
 
 
     /**
-     * 执行命令
+     * 执行命令，同步
      * 加入处理逻辑.
      *
      * @return mixed
@@ -245,6 +236,68 @@ public function execute()
         return $result;
     }
 
+    /**
+     * 异步执行命令.
+     *
+     * @return mixed
+     */
+    public function queue()
+    {
+        $this->prepare();
+        $metrics = $this->getMetrics();
+        $cacheEnabled = $this->isRequestCacheEnabled();
+
+        $this->recordExecutedCommand();
+
+        if ($cacheEnabled) {
+            $cacheHit = $this->requestCache->exists($this->getCommandKey(), $this->getCacheKey());
+
+            if ($cacheHit) {
+                $metrics->markResponseFromCache();
+                $this->recordExecutionEvent(self::EVENT_RESPONSE_FROM_CACHE);
+                return $this->requestCache->get($this->getCommandKey(), $this->getCommandKey());
+            }
+        }
+
+        $circuitBreaker = $this->getCircuitBreaker();
+
+        if (! $circuitBreaker->allowRequest()) {
+            $metrics->markShortCircuited();
+            $this->recordExecutionEvent(self::EVENT_SHORT_CIRCUITED);
+            return $this->getFallbackOrThrowException();
+        }
+
+        $this->invocationStartTime = $this->getTimeInMilliseconds();
+
+        $promise = $this->runAsync();
+
+        if ($promise instanceof PromiseInterface) {
+            $promise->then(
+                function ($value) use ($metrics, $circuitBreaker) {
+                    $this->recordExecutionTime();
+                    $metrics->markSuccess();
+                    $circuitBreaker->markSuccess();
+                    $this->recordExecutionEvent(self::EVENT_SUCCESS);
+                },
+                function ($reason) use ($metrics) {
+                    $this->recordExecutionTime();
+
+                    if ($reason instanceof BadRequestException) {
+                        throw $reason;
+                    }
+
+                    $metrics->markFailure();
+                    $this->executionException = $reason;
+                    $this->recordExecutionEvent(self::EVENT_FAILURE);
+                    return Promise\promise_for($this->getFallbackOrThrowException($reason));
+                }
+            );
+
+            return $promise;
+        }
+    }
+
+
     /**
      * 执行命令前置操作.
      */

src/CommandFactory.php

@@ -87,4 +87,14 @@ public function getCommand($class)
 
         return $command;
     }
+
+    /**
+     * 获取请求日志.
+     *
+     * @return void
+     */
+    public function getRequestLog()
+    {
+        return $this->requestLog;
+    }
 }