$worker->onWorkerStart = function () use ($worker) {

            // 開(kāi)啟一個(gè)內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符
            $inner_text_worker = new Worker('http://0.0.0.0:5898');
            $inner_text_worker->onMessage = function ($connection) use ($worker) {

                $data = input('post.');
                $data = json_encode($data);

                foreach ($worker->uidConnections as $connection) {
                    $connection->send($data);
                }

                // 返回推送結(jié)果

            };
            $inner_text_worker->listen();

            Timer::add(3, function () use ($worker) {
                $time_now = time();
                foreach ($worker->uidConnections as $connection) {
                    // 有可能該connection還沒(méi)收到過(guò)消息，則lastMessageTime設(shè)置為當(dāng)前時(shí)間
                    if (empty($connection->lastMessageTime)) {
                        $connection->lastMessageTime = $time_now;
                        continue;
                    }
                    // 上次通訊時(shí)間間隔大于心跳間隔，則認(rèn)為客戶(hù)端已經(jīng)下線(xiàn)，關(guān)閉連接
                    if ($time_now - $connection->lastMessageTime > 25) {
                        $connection->close();
                    }

                }
            });
        };