您当前的位置： 首页 > 学无止境 > 心得笔记 网站首页心得笔记

swoole学习笔记-异步tcp服务器

发布时间：2018-04-30 11:00:07编辑：雪饮阅读（）

创建异步tcp服务器脚本

<?php
//创建tcp服务器
$serv=new swoole_server("0.0.0.0",9501);
//设置异步 进程工作数
$serv->set(array("task_worker_num"=>4));
//投寄异步任务
$serv->on("receive",function ($serv,$fd,$from_id,$data){
    $task_id=$serv->task($data);
    echo "接收到异步任务，生成异步ID为:$task_id\n";
});
//处理异步任务
$serv->on("task",function ($serv,$task_id,$from_id,$data){
    echo "对异步任务 $task_id 的预处理工作，处理后再将本任务提交到最后的finish阶段\n";
    $serv->finish("$data -> ok \n");
});
//完成异步任务
$serv->on('finish',function ($serv,$task_id,$data){
    echo "异步任务$task_id 最终的完成的数据为：$data\n";
});
$serv->start();

调试

异步任务在服务端运行后会按照我们脚本中所设置的进程工作数创建对应个数的异步进程



当用网络调试助手连接上并且不断向服务器端发送信息后,会发现服务器端异步任务也会按照我们脚本的意思进行逐次的异步处理.