定期向所有客户端发送数据
Send data to all clients periodically
我正在使用 Workerman along with PHPSocketIO 并试图弄清楚如何定期将数据发送到指定的服务器。出于某种原因,我可以在 Javascript 中完美地完成它,但我需要从 PHP 向所有连接的客户端发出通知。我曾尝试使用独立功能连接到服务器并通过标准 'message' 通知它,但由于某种原因它什么也没做。
<?php
require_once __DIR__ . '/vendors/autoload.php';
use Workerman\Worker;
use PHPSocketIO\SocketIO;
static $_TERMINATE_TIME = 61;
static $_CHECK_DATA = 3;
$io = new SocketIO(1234);
$io->on('connection', function($socket){
$socket->addedUser = false;
echo 'New user connected' . PHP_EOL;
$socket->broadcast->emit('message', array(
'data'=> array('test' => 1, 'blah' => 2)
));
$socket->on('message', function ($data)use($socket){
$socket->broadcast->emit('message', array(
'data' => array('test' => 1, 'blah' => 2)
));
});
});
function HasData()
{
echo 'Need to send server-side data to all clients ...' . PHP_EOL;
}
// Need to send notifications from the server every N seconds
\Workerman\Lib\Timer::add($_CHECK_DATA, 'HasData', null, true);
// Self-destruct server after K seconds
\Workerman\Lib\Timer::add($_TERMINATE_TIME, function() {Worker::stopAll();}, null, false);
Worker::runAll();
由于 PHP 中没有现成的解决方案可以让我连接并请求 websockets 服务器通知所有客户端,我们决定使用 clsssic JavaScript ping-pong 和数据检索解决.
我正在使用 Workerman along with PHPSocketIO 并试图弄清楚如何定期将数据发送到指定的服务器。出于某种原因,我可以在 Javascript 中完美地完成它,但我需要从 PHP 向所有连接的客户端发出通知。我曾尝试使用独立功能连接到服务器并通过标准 'message' 通知它,但由于某种原因它什么也没做。
<?php
require_once __DIR__ . '/vendors/autoload.php';
use Workerman\Worker;
use PHPSocketIO\SocketIO;
static $_TERMINATE_TIME = 61;
static $_CHECK_DATA = 3;
$io = new SocketIO(1234);
$io->on('connection', function($socket){
$socket->addedUser = false;
echo 'New user connected' . PHP_EOL;
$socket->broadcast->emit('message', array(
'data'=> array('test' => 1, 'blah' => 2)
));
$socket->on('message', function ($data)use($socket){
$socket->broadcast->emit('message', array(
'data' => array('test' => 1, 'blah' => 2)
));
});
});
function HasData()
{
echo 'Need to send server-side data to all clients ...' . PHP_EOL;
}
// Need to send notifications from the server every N seconds
\Workerman\Lib\Timer::add($_CHECK_DATA, 'HasData', null, true);
// Self-destruct server after K seconds
\Workerman\Lib\Timer::add($_TERMINATE_TIME, function() {Worker::stopAll();}, null, false);
Worker::runAll();
由于 PHP 中没有现成的解决方案可以让我连接并请求 websockets 服务器通知所有客户端,我们决定使用 clsssic JavaScript ping-pong 和数据检索解决.