<?php

require_once __DIR__ . '/Workerman/Autoloader.php';
use Workerman\Worker;
use Workerman\Lib\Timer;

// 初始化Worker容器
$worker = new Worker(ws://0.0.0.0:1234);

$worker->onWorkerStart = function ($worker) {
   // 每隔2s去讀取接口過來的數(shù)據(jù)
   // 可以是DB 可以是Redis
   Timer::add(2, function(){
        // json
        $json = json_encode(array());

        // 獲取所有連接上的websocket的conn
        foreach ($worker->connections as $conn) {
            $conn->send($json);
        }
   })
};

$worker->onMessage = function($connection, $msg) {

};

// 啟動Worker容器
Worker::runAll();