我想通过接口接收数据然后同过自己ws服务发送给客户端 这个能做吗?怎么处理?谢谢

websocket0622
2320 1 0
1个回答

taozywu
<?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去读取接口过来的数据
   // 可以是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();

如上是一种思路!

年代过于久远,无法发表回答
×
🔝