on('connect', function ($serv, $fd, $reactor_id){ // echo "[#".posix_getpid()."]\tClient@[$fd:$reactor_id]: Connect.\n"; //}); $serv->set(array( 'worker_num' => 1, )); $serv->on('receive', function (swoole_server $serv, $fd, $reactor_id, $data) { echo "[#".$serv->worker_id."]\tClient[$fd] receive data: $data\n"; if ($serv->send($fd, "hello {$data}\n") == false) { echo "error\n"; } }); //$serv->on('close', function ($serv, $fd, $reactor_id) { // echo "[#".posix_getpid()."]\tClient@[$fd:$reactor_id]: Close.\n"; //}); $serv->start();