返回介绍

1.16.27 如何广播数据

发布于 2020-05-17 11:52:43 字数 4328 浏览 894 评论 0 收藏 0

范例(定时广播)

use WorkermanWorker;
use WorkermanLibTimer;
require_once __DIR__ . '/Workerman/Autoloader.php';

$worker = new Worker('websocket://0.0.0.0:2020');
// 这个例子中进程数必须为1
$worker->count = 1;
// 进程启动时设置一个定时器,定时向所有客户端连接发送数据
$worker->onWorkerStart = function($worker)
{
    // 定时,每10秒一次
    Timer::add(10, function()use($worker)
    {
        // 遍历当前进程所有的客户端连接,发送当前服务器的时间
        foreach($worker->connections as $connection)
        {
            $connection->send(time());
        }
    });
};
// 运行worker
Worker::runAll();

范例(群聊)

use WorkermanWorker;
use WorkermanLibTimer;
require_once './Workerman/Autoloader.php';

$worker = new Worker('websocket://0.0.0.0:2020');
// 这个例子中进程数必须为1
$worker->count = 1;
// 客户端发来消息时,广播给其它用户
$worker->onMessage = function($connection, $message)use($worker)
{
    foreach($worker->connections as $connection)
    {
        $connection->send($message);
    }
};
// 运行worker
Worker::runAll();

说明:

单进程:
以上例子只能单进程$worker->count=1),因为多进程时多个客户端可能连接到不同的进程中,进程间的客户端是隔离的,无法直接通讯,也就是A进程中无法直接操作B进程的客户端connection对象发送数据。(要做到这点,需要进程间通讯,比如可以使用Channel组件,例如例子-集群发送、 例子-分组发送)。

建议用GatewayWorker
在workerman基础上开发的GatewayWoker框架提供了更方便推送机制,包括组播、广播等,可以设置多进程甚至可以多服务器部署,如果需要给客户端推送数据,建议使用GatewayWorker框架。

GatewayWorker手册地址 http://www.workerman.net/gatewaydoc/
GatewayWorker下载地址(linux版本) http://www.workerman.net/download/GatewayWorker.zip
GatewayWorker下载地址(windows版本) http://www.workerman.net/download/GatewayWorker-for-win.zip

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文