$channel_server = new Channelserver($this->channelHost, $this->channelPort);
}
// 实例化$this->worker->count = $this->processes;
$this->worker->name = $this->name;
// 初始化public function onWorkerStart($worker)
{
// 心跳间隔60秒
define('HEARTBEAT_TIME', 60);
// 链接保持提醒time_now;
continue;
}
//$connection->send(time());
// 链接保持提醒时间time_now - $connection->lastMessageTime == HEARTBEAT_TIME - ALARM_TIME) {
//发送命令消息,提示应该重新发送消息,保持链接