<?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();
如上是一种思路!
谢谢
@5753:https://wenda.workerman.net/question/4025帮忙看下这条 你上面说的“所有连接上的websocket的conn" A发消息 我接收通过接口发送出去 回来的消息我用上面方法可以发送给A么?获取的 所有连接上的websocket的会初始化掉A么 ?
如上是一种思路!
谢谢
@5753:https://wenda.workerman.net/question/4025帮忙看下这条 你上面说的“所有连接上的websocket的conn" A发消息 我接收通过接口发送出去 回来的消息我用上面方法可以发送给A么?获取的 所有连接上的websocket的会初始化掉A么
?