1、什么是task进程？

Task进程是独立与worker进程的一组进程.他主要处理耗时较长的业务逻辑.并且不影响worker进程处理客户端的请求,这大大提高了swoole的并发能力当有耗时较长的任务时,worker进程通过task()函数把数据投递到Task进程去处理
回顾一下：

图片1.png

在worker进程当中我们可以执行客户端提交过来的数据执行相应的业务逻辑，也就是在触发的事件当中，比如接收客户端提交的数据，处理同步的业务，这是在worker进程当中执行，那什么时候需要task进程呢？

2、task进程适用场景

情景一：管理员需要给100W用户发送邮件，当点击发送，浏览器会一直转圈，直到邮件全部发送完毕。
情景二：千万微博大V发送一条微博，其关注的粉丝相应的会接收到这个消息，是不是大V需要一直等待消息发送完成，才能执行其它操作
从我们理解的角度思考，这其实都是php进程一直被阻塞，客户端才一直在等待服务端的响应，我们的代码就是同步执行的。
对于用户而言，这就是漫长的等待。如何优雅的提高用户体验就是一个非常棘手的问题。
那么task的目的就是这个，下面我们来介绍下task的使用。

图片2.png

1、worker进程到中，我们调用对应的task()方法发送数据通知到task worker进程
2、task worker进程会在onTask()回调中接收到这些数据，并进行处理。
3、处理完成之后通过调用finsh()函数或者直接return返回消息给worker进程
4、worker进程在onFinsh()进程收到这些消息并进行处理

三、代码测试

注意事项：

一、开启task功能

task功能默认是关闭的，开启task功能需要满足两个条件
1.配置task进程的数量
2.注册task的回调函数onTask和onFinish
配置task进程的数量，即配置task_worker_num这个配置项。比如我们开启8个task进程，同样task进程数量的配置也不是随意的配置

图片3.png

计算方法
单个task的处理耗时，如100ms，那一个进程1秒就可以处理1/0.1=10个task
task投递的速度，如每秒产生2000个task
2000/10=200，需要设置task_worker_num => 200，启用200个task进程
对于单个服务器的承受数量我们要提前做预知，处理能力必须是大于投放能力的

二、task怎么使用？

Task进程其实是要在worker进程内发起的，即我们把需要投递的任务，通过worker进程投递到task进程中去处理。
怎么操作呢？我们可以利用swoole_server->task函数把任务数据投递到task进程池中。
swoole_server->task函数是非阻塞函数，任务投递到task进程中后会立即返回，即不管任务需要在task进程内处理多久，worker进程也不需要任何的等待，不会影响到worker进程的其他操作。但是task进程却是阻塞的，如果当前task进程都处于繁忙状态即都在处理任务，你又投递过来更多任务，这个时候新投递的任务就只能乖乖的排队等task进程空闲才能继续处理。
如果投递的任务量总是大于task进程的处理能力，建议适当的调大task_worker_num的数量，增加task进程数，不然一旦task塞满缓冲区，就会导致worker进程阻塞，所以需要使用好task前期必须有所规划

三、Task常见问题：

1、Task传递数据的大小
数据小于8k直接通过管道传递,数据大于8k写入临时文件传递
onTask会读取这个文件,把他读出来
运行Task,必须要在swoole服务中配置参数task_worker_num,此外，必须给swoole_server绑定两个回调函数：onTask和onFinish。
onTask要return 数据
2、Task传递对象
默认task只能传递数据，可以通过序列化传递一个对象的拷贝,Task中对象的改变并不会反映到worker进程中数据库连接,网络连接对象不可传递,会引起php报错
3、Task的onFinish回调
Task的onFinish回调会回调调用task方法的worker进程

四、客户端测试

客户端请求：

图片4.png

服务端运行结果：

图片5.png

ask任务切分

除了直接将数据投递到task，由task分配处理之外，如果是投递过来的是数据类型的任务，也可以自己去指定分配进程去处理。

场景：假设有一台服务器专门处理前台投递的数据存入
1.将一个大的任务拆分成相应份数(是由$task_worker_num数量来确定)
2.通过foreach循环将数据投递到指定的task进程,范围是(0-(task_worker_num-1))区间之内
3.执行失败的任务，需要保留，重新投递执行（进程间通讯管道方式）

进程间通讯

进程间通信（IPC，Inter-Process Communication），指至少两个进程或线程间传送数据或信号的一些技术或方法。每个进程都有自己的一部分独立的系统资源，彼此是隔离的。为了能使不同的进程互相访问资源并进行协调工作，才有了进程间通信。

进程通信有如下的目的：
数据传输，一个进程需要将它的数据发送给另一个进程，发送的数据量在一个字节到几M之间；
共享数据，多个进程想要操作共享数据，一个进程对数据的修改，其他进程应该立刻看到；
进程控制，有些进程希望完全控制另一个进程的执行（如Debug进程），此时控制进程希望能够拦截另一个进程的所有异常，并能够及时知道它的状态改变。

系统进行进程间通信（IPC）的时候，可用的方式包括管道、命名管道、消息队列、信号、信号量、共享内存、套接字(socket)等形式。

1消息队列

消息队列实际上就是一个链表，而消息就是链表中具有特定格式和优先级的记录，对消息队列有写权限的进程可以根据一定规则在消息链表中添加消息，对消息队列有读权限的进程则可以从消息队列中获得所需的信息。

在某个进程往一个消息队列写入消息之前，并不需要另外某个进程在该队列上等待消息的到达。对于消息队列来说，除非显式删除，否则其一直存在

php实现消息队列操作

在php中通过这两句话就可以创建一个消息队列。 ftok 函数，是可以将一个路径转换成 消息队列 可用的key值。 msg_get_queue函数的第一个参数 是消息队列的key，第二个参数是消息队列的读写权限，这个权限跟文件类似

注意：需要开启sysvmsg

msg_send函数，向指定消息队列写入信息。

msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize = true [, bool $blocking = true [, int &$errorcode ]]] )

第1个参数 ： resource $queue 表示要写入的消息队列资源。

第2个参数 ： int $msgtype 表示写入消息队列的 消息类型，这个参数是 配合 msg_receive读取消息队列函数 使用的，下面会说。

第3个参数 ： mixed $message 你要发送的信息，最大为 65536 个字节。

第4个参数 ： bool $serialize = true 为可选项，是否序列化你发送的消息。

第5个参数 ： bool $blocking = true 是否阻塞，当你发送的消息很大，而此时的消息队列无法存入的时候，此时消息队列就会阻塞，除非等到有别的进程从消息队列中读取了别的消息，然后消息队列有足够的空间存储你要发送的信息，才能继续执行。你可以设置这个参数为false，这样你发送信息就会失败，此时错误信息会在

第6个参数 $errorcode中体现，错误码为 MSG_EAGAIN ，你可以根据这个错误码，重新发送你的消息。

第6个参数 ： int &$errorcode 记录写入中出现的一系列错误。

读取函数 msg_receive

msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize = true [, int $flags = 0 [, int &$errorcode ]]] )

第1个参数：resource $queue 表示要读取的消息队列资源。

第2个参数 ：int $desiredmsgtype 读取的消息类型。这个参数为 0 的时候，你可以读取 msg_send 以任意 消息类型 发送的消息。 如果此参数和你发送的某个消息类型相同，比如你有 2个消息，一个是通过 1类型发送的，一个是通过2 类型发送的。你用 0 可以接收这两种消息 ，而你用 1 只能接收到 以1类型发送的消息。

第3个参数 ： int &$msgtype 你读取到的信息，它发送时的消息类型会存储在该参数中。

第4个参数 ： int $maxsize 你以多大的字节去读取消息，如果这个值小于你要读取的内容的长度，你会读取失败。

第5个参数 ：mixed &$message 读取的内容。

第6个参数 ： bool $unserialize = true 内容是否序列化

第7个参数 ：int $flags = 0 读取标识。除了默认的0 之外，还有3个参数可选 MSG_IPC_NOWAIT 这个参数表示如果没有从消息队列中读取到信息，会立马返回，并返回错误码 MSG_ENOMSG.

MSG_EXCEPT 这个参数 是配合 第2个参数使用的，如果使用这个参数，你读取到的第一个参数，不是你第一个发送的参数。(队列先进先出)
MSG_NOERROR 如果读取的内容过大，而你指定的第4个参数又不够的时候，它会截断这个消息，并且不报错。

销毁消息队列的方法 ： msg_remove_queue($msg_queue);
我们可以利用消息队列在自己的网络服务器实现swoole的task方法