From 2bcf9f355f0168c0b5ecf01cf57e6294b2e7ed2d Mon Sep 17 00:00:00 2001
From: farwish <farwish@foxmail.com>
Date: Mon, 12 Aug 2019 07:56:23 +0800
Subject: [PATCH] task, protocol, co

---
 .../README.md"                                | 70 +++++++++++++++++++
 .../task.php"                                 | 40 +++++++++++
 "5Swoole\345\215\217\347\250\213/README.md"   | 28 ++++++++
 "5Swoole\345\215\217\347\250\213/co.php"      | 20 ++++++
 4 files changed, 158 insertions(+)
 create mode 100644 "4Swoole\346\234\215\345\212\241\345\231\250/task.php"
 create mode 100644 "5Swoole\345\215\217\347\250\213/README.md"
 create mode 100644 "5Swoole\345\215\217\347\250\213/co.php"

diff --git "a/4Swoole\346\234\215\345\212\241\345\231\250/README.md" "b/4Swoole\346\234\215\345\212\241\345\231\250/README.md"
index 830b7c7..f25b4d4 100644
--- "a/4Swoole\346\234\215\345\212\241\345\231\250/README.md"
+++ "b/4Swoole\346\234\215\345\212\241\345\231\250/README.md"
@@ -385,4 +385,74 @@ stats       返回统计信息（需要 swoole-4.4 及以上）
 
 @doc https://wiki.swoole.com/wiki/page/p-timer.html
 
+## 执行异步任务
+
+Swoole 异步任务
+
+```
+Server 程序中如果需要执行耗时的操作，worker 进程使用 $server->task() 向 task worker 投递任务，
+使当前进程不阻塞，不影响当前请求的处理速度。
+（必须设置了 task_worker_num 才能使用 task 回调函数）
+```
+
+注意事项
+
+```
+设置的 onTask 回调函数在 task 进程池内异步执行，执行完后使用 return 非null的变量
+或者调用 $server->finish() 来返回结果。
+
+return 和 $server->finish() 操作都是可选的，onTask 可以不返回任何结果。
+
+onTask 返回结果才会触发 onFinish 回调，执行 onFinish 逻辑的 worker 进程和下发 task 任务的 worker 是同一进程。
+```
+
+回调原型
+
+```
+onTask(Swoole\Server $server, int $taskId, int $srcWorkerId, mix $data)
+
+onTask(Swoole\Server $server, Swoole\Server\Task $task)
+swoole-4.2.12起，开启了 task_enable_coroutine 之后的函数原型，信息存储在 $task 对象的属性上。
+
+onFinish(Swoole\Server $server, int $taskId, string $data)
+```
+
+## 网络通信协议设计
+
+通信协议解决的问题
+
+```
+TCP 协议是流式传输协议，应用需要处理分包和合包才能有效获取数据，比如 HTTP、FTP、SMTP、Redis、MySQL 等都是基于 TCP 的协议，
+它们都实现了自己的数据解析方式，方便应用层进行使用。
+
+Swoole 底层支持 2 种类型的自定义网络通信协议：EOF 结束符协议、固定包头加包体协议
+```
+
+EOF 结束符协议
+
+```
+原理是每个数据包结尾加一串自定义的特殊字符表示数据包的结束。
+使用 EOF 协议，要确保数据包中间不会出现 EOF 字符，否则会分包错误。
+
+$server->set([
+    'open_eof_split' => true,
+    'package_eof'    => '\r\n',
+]);
+```
+
+固定包头加包体协议
+
+```
+原理是一个数据包总是由包头和包体两部分组成。
+包头由一个字段 指定了包体或者整个包的长度，长度一般是使用 2 字节或 4 字节整数表示，
+服务器收到包头后，根据长度值来控制需要再接收多少数据才是完整的数据包。
+
+$server->set([
+    'open_length_check' => true,
+    'package_max_length' => 81920,
+    'package_length_type' => 'n', // 和 pack 函数用法一致
+    'package_length_offset' => 0,
+    'package_body_offset' => 2,
+]);
+```
 
diff --git "a/4Swoole\346\234\215\345\212\241\345\231\250/task.php" "b/4Swoole\346\234\215\345\212\241\345\231\250/task.php"
new file mode 100644
index 0000000..7ac5515
--- /dev/null
+++ "b/4Swoole\346\234\215\345\212\241\345\231\250/task.php"
@@ -0,0 +1,40 @@
+<?php
+/**
+ * task.php
+ *
+ * github.com/farwish/swoole-wholly
+ *
+ * @author ercom
+ */
+
+$server = new Swoole\Server("0.0.0.0", 7749, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);
+
+$server->set([
+    'worker_num' => 2,
+    'task_worker_num' => 2,
+]);
+
+$server->on('WorkerStart', function ($server, $workerId) {
+    if ($workerId == 0) {
+        $data = [1, 2, 3, 4, 5];
+        foreach ($data as $value) {
+            echo "Send task data {$value}\n";
+            $server->task($value);
+        }
+    }
+});
+
+$server->on("Receive", function ($server, $fd, $reactorId, $data) {
+});
+
+$server->on('Task', function ($server, $taskId, $srcWorkerId, $data) {
+    sleep(1);
+    echo "Task#{$taskId} execute task, data is {$data}\n";
+    return "aaa{$data}";
+});
+
+$server->on('Finish', function ($server, $taskId, $data) {
+    echo "Task{$taskId} execute finish, data is {$data}\n";
+});
+
+$server->start();
diff --git "a/5Swoole\345\215\217\347\250\213/README.md" "b/5Swoole\345\215\217\347\250\213/README.md"
new file mode 100644
index 0000000..59c2b9a
--- /dev/null
+++ "b/5Swoole\345\215\217\347\250\213/README.md"
@@ -0,0 +1,28 @@
+# Swoole 协程
+
+## CSP 编程方式
+
+CSP 编程
+
+```
+不同于传统的通过共享内存来通信，CSP 讲究以通信的方式来共享内存。
+
+Swoole 使用到了 CSP 里面的部分概念，参考了 Golang 的实现，使用 go 协程作为执行体，
+用 Chan 作为实体间通信的通道，Defer 在协程退出时执行。
+```
+
+Swoole 协程特点
+
+```
+应用层使用同步的编程方式，底层自动实现异步 IO 的效果和性能。
+
+不需要在应用层使用 yield 关键字标识协程切换，易于使用。
+
+默认开启了 enable_coroutine 选项，底层会在一些回调函数中自动创建一个协程，此时回调中使用协程 API。
+
+使用 Coroutine::create 或者 go 方法来手动创建一个协程。
+
+协程的切换是隐式发生的，所以协程切换前后不保证全局变量和静态变量的一致性（不安全）。
+```
+
+
diff --git "a/5Swoole\345\215\217\347\250\213/co.php" "b/5Swoole\345\215\217\347\250\213/co.php"
new file mode 100644
index 0000000..74d5a6e
--- /dev/null
+++ "b/5Swoole\345\215\217\347\250\213/co.php"
@@ -0,0 +1,20 @@
+<?php
+/**
+ * co.php
+ *
+ * github.com/farwish/swoole-wholly
+ *
+ * @author ercom
+ */
+
+Swoole\Coroutine::set([
+    'max_coroutine' => 2000,
+]);
+
+for ($i = 0; $i < 1000; $i++) {
+    go(function () {
+        echo 'A';
+        co::sleep(5);
+        echo 'B';
+    });
+}