feat: PHP + Promise

Author: zhangxl10015103

.gitignore

@@ -1,3 +1,5 @@
 composer.lock
+package-lock.json
 vendor
-logs
+node_modules
+logs

README.md

@@ -8,23 +8,29 @@
 
 - **使用场景:**
 
-常见于Webhook的实现中
+    消息推送，但不考虑结果状态
 
 - **代码片段**
 
-> framework/src/Request.class.php
+    > framework/src/Request.class.php
 
 ### 2.2 **Promise**
 
+- **相关简介:**
+
+    
+
 - **使用场景:**
 
-常见于Webhook的实现中
+    并发获取资源
 
 - **代码片段**
 
-> framework/src/Request.class.php
+    > framework/src/Request.class.php
 
 ### 2.3 **Redis pipeline**
+
+
 ### 2.4 **AMQP**
 ### 2.5 **MySQL BatchInsert**
 ### 2.6 **Deamon Process**

app/index.php

@@ -12,14 +12,30 @@
 
 use Monolog\Logger;
 use Monolog\Handler\StreamHandler;
+use GuzzleHttp\Client;
+use GuzzleHttp\Promise;
+use Psr\Http\Message\ResponseInterface;
 
 $loglevel = defined('RUN_MODE') && RUN_MODE === 'production' ? Logger::NOTICE : Logger::DEBUG;
 $logger   = new Logger('cobolphp');
 $logger->pushHandler(new StreamHandler(LOG_PATH . '/access.log', $loglevel));
 
 // 非阻塞请求
 $request  = new \cobolphp\Request($logger);
-$request->asyncRequest('http://shujuguan.cn');
+$request->asyncRequest('http://localhost:8008');
 
 // Promise
-
+$client = new Client();
+$promises = [];
+for ($i = 0; $i < 10; ++$i) {
+    $promise = $client->requestAsync(
+        'GET',
+        'http://localhost:8008'
+    );
+    $promise
+        ->then(function (ResponseInterface $response) {
+            echo $response->getBody() . PHP_EOL;
+        });
+    $promises[] = $promise;
+}
+Promise\all($promises)->wait();

build/devserver.js

@@ -0,0 +1,17 @@
+const http = require('http');
+const sleep = require('sleep-async')();
+
+const server = http.createServer();
+const sleepMiliSecond = 1000;
+
+server.on('request', function(req, res) {
+  console.log('Received.');
+
+  sleep.sleep(sleepMiliSecond, function() {
+    res.writeHead(200, {'Content-Type': 'text/json'});
+    res.write('{"status": "ok"}');
+    res.end();
+  });
+});
+
+server.listen(8008, 'localhost');

composer.json

@@ -1,6 +1,7 @@
 {
     "require": {
-        "monolog/monolog": "^1.23"
+        "monolog/monolog": "^1.23",
+        "guzzlehttp/guzzle": "^6.3"
     },
     "require-dev": {
         "psecio/iniscan": "^3.6"

package.json

@@ -0,0 +1,7 @@
+{
+    "name": "cobolphp/framework",
+    "description": "Strive to break through",
+    "dependencies": {
+        "sleep-async": "^1.0.5"
+    }
+}