在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
在swoole中,一个swoole_server的拥有若干回调函数,这些回调函数决定了swoole_server的相关功能。可以通过 $serv->on( string $event, mixed $callback ); 函数来配置. 示例: class Server
{
private $serv;
public function __construct() {
$this->serv = new swoole_server("0.0.0.0", 9501);
$this->serv->set(array(
'worker_num' => 8,
'daemonize' => false,
'max_request' => 10000,
'dispatch_mode' => 2,
'debug_mode'=> 1
));
$this->serv->on('Start', array($this, 'onStart'));
$this->serv->on('Connect', array($this, 'onConnect'));
$this->serv->on('Receive', array($this, 'onReceive'));
$this->serv->on('Close', array($this, 'onClose'));
$this->serv->start();
}
} 全部回调函数以及相关介绍如下: [TOC] 1.onReceive描述:接收数据的回调 function onReceive( swoole_server $serv, $fd, $from_id, $data );
说明:每当server接收到客户端发来的数据后,就会通过onReceive回调将数据投递给Worker。如果开启了协议检测,则会在收到完整数据包之后才会响应回调。注意,必须设置该回调函数,否则无法启动服务器。 2.onStart描述:服务器启动的回调 function onStart( swoole_server $serv);
说明:
接下来要执行
onStart回调中,仅允许echo、打印Log、修改进程名称。不得执行其他操作。onWorkerStart和onStart回调是在不同进程中并行执行的,不存在先后顺序。 可以在onStart回调中,将$serv->master_pid和$serv->manager_pid的值保存到一个文件中。这样可以编写脚本,向这两个PID发送信号来实现关闭和重启的操作。 3.onWorkerStart描述:Worker进程启动的回调 function onWorkerStart( swoole_server $serv,int $worker_id);
说明:此事件在worker进程/task_worker启动时发生。
通过$worker_id参数的值来,判断worker是普通worker还是task_worker。$worker_id>= $serv->setting['worker_num'] 时表示这个进程是task_worker。 4.onConnect描述:新连接接入时的回调 function onConnect( swoole_server $serv,int $fd, int $from_id);
说明:有新的连接进入时,在worker进程中回调。onConnect/onClose这2个回调发生在worker进程内,而不是主进程。如果需要在主进程处理连接/关闭事件,请注册onMasterConnect/onMasterClose回调。onMasterConnect/onMasterClose回调总是先于onConnect/onClose被执行 5.onClose描述:连接关闭时的回调 function onClose( swoole_server $serv,int $fd, int $from_id);
说明:TCP客户端连接关闭后,在worker进程中回调此函数。无论close由客户端发起还是服务器端主动调用swoole_server_close关闭连接,都会触发此事件。 因此只要连接关闭,就一定会回调此函数。 6.onTask描述:task_worker进程处理任务的回调 function onTask(swoole_server $serv, int $task_id, int $from_id, string $data);
说明:在task_worker进程内被调用。worker进程可以使用swoole_server_task函数向task_worker进程投递新的任务。可以直接将任务结果字符串通过return方式返回给worker进程。worker进程将在onFinish回调中收到结果。注:如果serv->set(array('task_worker_num' => 8)) task_id 并不是从1-8 而是递增的。 7.onFinish描述:task_worker进程处理任务结束的回调 function onFinish(swoole_server $serv, int $task_id, string $data);
说明:在此函数中会收到任务处理的结果,通过task_id和worker_id来区分不同的任务。 8.onTimer描述:定时器触发的回调 function onTimer(swoole_server $serv, int $interval);
说明:定时器被触发时,该函数被调用。通过interval来区分不同时间间隔的定时器。 |
请发表评论