代码拉取完成,页面将自动刷新
同步操作将从 winting/swoole 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
<?php
$serv = new swoole_server("127.0.0.1", 9501);
$serv->set(array(
'worker_num' => 2,
'task_worker_num' => 2,
// 'daemonize' => 1,
));
function my_onStart($serv)
{
echo "MasterPid={$serv->master_pid}|Manager_pid={$serv->manager_pid}\n";
echo "Server: start.Swoole version is [".SWOOLE_VERSION."]\n";
//$serv->addtimer(1000);
}
function my_onShutdown($serv)
{
echo "Server: onShutdown\n";
}
function my_onTimer($serv, $interval)
{
echo "Server:Timer Call.Interval=$interval\n";
}
function my_onClose($serv, $fd, $from_id)
{
//echo "Client: fd=$fd is closed.\n";
}
function my_onConnect($serv, $fd, $from_id)
{
//echo "Client:Connect.\n";
}
function my_onWorkerStart($serv, $worker_id)
{
//sleep(10);
echo "WorkerStart[$worker_id]|pid=".posix_getpid().".\n";
//$serv->addtimer(500);
//$serv->addtimer(6000);
}
function my_onWorkerStop($serv, $worker_id)
{
echo "WorkerStop[$worker_id]|pid=".posix_getpid().".\n";
}
function my_onReceive($serv, $fd, $from_id, $data)
{
//echo "Client:Data. fd=$fd|from_id=$from_id|data=$data";
//echo "WorkerPid=".posix_getpid()."\n";
//swoole_server_send($serv, $fd, 'Swoole: '.$data, $from_id);
//$serv->deltimer(800);
if(trim($data) == "reload")
{
$serv->reload($serv);
}
elseif(trim($data) == "task")
{
$task_id = $serv->task("hello world");
echo "Dispath AsyncTask: id=$task_id\n";
}
else
{
$serv->send($fd, 'Swoole: '.$data, $from_id);
//$serv->close($fd);
}
//swoole_server_send($serv, $other_fd, "Server: $data", $other_from_id);
//swoole_server_close($serv, $fd, $from_id);
//swoole_server_close($serv, $ohter_fd, $other_from_id);
/*
* require swoole-1.5.8+
var_dump(swoole_connection_info($serv, $fd));
$start_fd = 0;
while(true)
{
$conn_list = swoole_connection_list($serv, $start_fd, 10);
if($conn_list===false)
{
echo "finish\n";
break;
}
$start_fd = $conn_list[count($conn_list)-1];
var_dump($conn_list);
}
*/
}
function my_onMasterConnect($serv, $fd, $from_id)
{
//echo "my_onMasterConnect:Close.PID=".posix_getpid().PHP_EOL;
}
function my_onMasterClose($serv,$fd,$from_id)
{
echo "Client:Close.PID=".posix_getpid().PHP_EOL;
}
function my_onTask($serv, $task_id, $from_id, $data)
{
echo "AsyncTask[PID=".posix_getpid()."]: task_id=$task_id.".PHP_EOL;
$serv->finish("OK");
}
function my_onFinish($serv, $data)
{
echo "AsyncTask Finish:Connect.PID=".posix_getpid().PHP_EOL;
}
$serv->on('Start', 'my_onStart');
$serv->on('Connect', 'my_onConnect');
$serv->on('Receive', 'my_onReceive');
$serv->on('Close', 'my_onClose');
$serv->on('Shutdown', 'my_onShutdown');
$serv->on('Timer', 'my_onTimer');
$serv->on('WorkerStart', 'my_onWorkerStart');
$serv->on('WorkerStop', 'my_onWorkerStop');
$serv->on('Task', 'my_onTask');
$serv->on('Finish', 'my_onFinish');
//$serv->on('MasterConnect', 'my_onMasterConnect');
//$serv->on('MasterClose', 'my_onMasterClose');
$serv->start();
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。