php swoole-task任务

ゝ一纸荒年。 2023-06-17 09:54 30阅读 0赞

## task任务是投递一个异步任务到task\_worker池中，此函数是非阻塞的，执行完毕会立即返回。Worker进程可以继续处理新的请求。使用Task功能，必须先设置 task\_worker\_num，并且必须设置Server的onTask和onFinish事件回调函！！ ##

task任务常见于一键发送邮件，通知。如我需要发送一万封邮件给一万个用户，如果是传统的实现方式，则会存在堵塞、延迟，从第一份到发送完毕，中间的耗时是不确定的，存在一定的误差，此时task任务就能够很好的解决该任务

1.首先，回顾上文，我们在ws.php里面新增几行代码  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70]  
2. 我们编写投递任务的代码  
       在task\_worker进程内被调用。worker进程可以使用swoole\_server\_task函数向task\_worker进程投递新的任务。当前的Task进程在调用onTask回调函数时会将进程状态切换为忙碌，这时将不再接收新的Task，当onTask函数返回时会将进程状态切换为空闲然后继续接收新的Task。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 1]

3.在下面实现具体的实现代码  
       我们模拟发邮件延迟的场景，当投递task任务时睡眠10秒来模拟场景，睡眠完成后return字符串：on task finish  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 2]  
        在此我们再去完成onfinish回调函数，此回调函数必须与ontask任务同时实现，两者返回的数据并不是一致的，详细的说：当worker进程投递的任务在task\_worker中完成时，task进程会通过swoole\_server->finish()方法将任务处理的结果发送给worker进程。  
![在这里插入图片描述][20191128143920458.png]

1.  访问之前设置好的域名去访问websocket\_client.html，Linux返回了以下的数据格式，对以下的数据格式做了一些解析  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191128142409529.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191128142535904.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191128143201732.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70
[20191128143920458.png]: https://img-blog.csdnimg.cn/20191128143920458.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20191205103728440.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyMDkwMA==,size_16,color_FFFFFF,t_70