swoole 비동기 작업

1576 단어
on("connect",function($cli){
    $cli->send("how are you
"); }); $client->on("receive",function($cli,$data){ echo " :$data
"; }); // $client->on("error",function($cli){ echo "
"; }); $client->on("close",function($cli){ echo "
"; }); // $client->connect('127.0.0.1', 9501, -1); exit; // $client = new swoole_client(SWOOLE_SOCK_TCP); if (!$client->connect('127.0.0.1', 9501, -1)) { exit("connect failed. Error: {$client->errCode}
"); } $client->send("hello world
"); echo $client->recv(); $client->send("hello world1
"); echo $client->recv(); $client->send("hello world2
"); echo $client->recv(); $client->close();

서비스 포트는 다음과 같습니다.
$serv=new swoole_server('127.0.0.1',9501);
$serv->set(array('task_worker_num'=>4));
 
$serv->on("receive",function($serv,$fd,$from_id,$data){
    $serv->send($fd,"Server:".$data);
    $task_id=$serv->task($data);
    echo " id{$task_id}
"; }); $serv->on("task",function($serv,$task_id,$from_id,$data){ echo " id $task_id
"; $serv->finish("{$data}->ok"); }); $serv->on("finish",function($serv,$task_id,$data){ echo " $task_id
"; }); $serv->start();exit;

좋은 웹페이지 즐겨찾기