Workerman主动推送信息怎么实现最简单方法

夜磊大大_5491

夜磊大大_5491

2026-08-08

174人浏览

原创

最简路径是用原生 workerman 启动单进程 websocket 服务并内存维护连接列表:新建 pushserver.php,写入约30行代码,设 count=1,通过 $_server['connections'] 全局共享连接池,业务中遍历发送即可实时推送。

workerman主动推送信息怎么实现最简单方法

要在服务端不依赖客户端轮询、直接向已连接的前端推送消息,最简路径是用原生 Workerman 启动一个单进程 WebSocket 服务,并在内存中维护连接列表,通过遍历发送。

启动一个单进程 WebSocket 服务

第一步:新建文件 PushServer.php,放在项目根目录或任意可执行位置。

第二步:写入以下最小可行代码(仅 30 行左右,无框架依赖):

```php
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;

$ws_worker = new Worker('websocket://0.0.0.0:2888');
$ws_worker->count = 1;
$ws_worker->connections = [];

$ws_worker->onConnect = function ($connection) {
  $connection->uid = uniqid('u_');
  $connection->send('已连接,分配 uid:' . $connection->uid);
  $_SERVER['connections'][$connection->uid] = $connection;
};

$ws_worker->onMessage = function ($connection, $data) {
  echo "收到消息:{$data}\n";
};

$ws_worker->onClose = function ($connection) {
  if (isset($connection->uid)) {
    unset($_SERVER['connections'][$connection->uid]);
  }
};

Worker::runAll();
```

注意:【必须设为单进程】,即 $ws_worker->count = 1。多进程下连接分散在不同子进程,无法跨进程访问 $connection 对象,主动推送必然失败。

从 PHP 其他地方触发推送

方法一:命令行临时推送(调试最快)

新开终端,执行:php -r "file_get_contents('http://127.0.0.1:2888/push?msg=hello');" —— 这种方式需额外加 HTTP 路由层,不推荐。

方法二:直接调用全局连接池(推荐,零额外依赖)

Kits AI
Kits AI

Kits AI是一款面向音乐制作人的 AI 人声生成、声音克隆和音频处理工具。

下载

在你业务逻辑中(比如控制器、定时任务、回调函数里),插入这段推送代码:

```php
if (isset($_SERVER['connections']) && !empty($_SERVER['connections'])) {
  foreach ($_SERVER['connections'] as $conn) {
    if ($conn instanceof \Workerman\Connection\TcpConnection && $conn->isConnected()) {
      $conn->send(json_encode(['type'=>'notice','content'=>'系统消息:时间'.date('H:i:s')]));
    }
  }
}
```

这一步不需要重启服务,只要 PushServer.php 正在运行且连接未断开,就能立刻送达。连接池存在 $_SERVER 超全局变量中,是单进程下最轻量的共享方式。

前端建立连接并监听

新建一个 HTML 文件,放入以下代码并用浏览器打开:

```html
<script><br>const ws = new WebSocket('ws://127.0.0.1:2888');<br>ws.onopen = () => console.log('已连接');<br>ws.onmessage = e => console.log('收到推送:', e.data);<br></script>
```

确保浏览器地址栏是 http:// 或 https:// 开头(不能是 file://),否则 WebSocket 会因跨域策略被拦截。

此时后端任意位置执行上一步的 foreach 推送,前端控制台就会实时打印消息。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
Workerman安装配置教程
Workerman安装配置教程

Workerman安装配置教程专题提供Workerman安装配置、WebSocket开发、TCP通信、异步编程、高并发服务搭建与PHP实时通信开发教程。

2026.05.20

166

15

Workerman实时通信与长连接开发教程
Workerman实时通信与长连接开发教程

WWorkerman实时通信与长连接开发教程聚合实时通信、聊天室、长连接、消息推送、AI流式输出等Workerman高并发开发内容。

2026.05.20

202

12

Workerman异步通信与TCP服务器开发
Workerman异步通信与TCP服务器开发

Workerman异步通信与TCP服务器开发专题整理Workerman异步通信、TCP服务、HTTP服务、WebSocket开发与高并发PHP服务器教程。

2026.05.20

187

13

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

2026.09.30

80

10

LLVM RISC-V参数配置教程
LLVM RISC-V参数配置教程

本专题介绍LLVM对RISC-V基础ISA和扩展的支持方式,涵盖RV32、RV64、标准扩展、实验性扩展、厂商扩展、-menable-experimental-extensions和版本差异。

2026.09.30

80

14

LLVM IR中间表示入门指南
LLVM IR中间表示入门指南

本专题整理LLVM IR的核心概念,包括中间表示作用、模块结构、函数、基本块、SSA形式、类型系统和常见语法,帮助新手理解LLVM编译流程中的关键层。

2026.09.30

40

12

PDF转图片方法
PDF转图片方法

需要把 PDF 页面用于上传、预览、分享或图片归档时,PDF 转图片方法专题整理 JPG/PNG 格式选择、逐页导出、清晰度设置、批量下载和结果检查等流程,帮助用户稳定完成 PDF 图片化处理。

2026.09.30

40

26

PixTV AI视频生成与无限画布创作
PixTV AI视频生成与无限画布创作

PixTV专题整理AI视频与视觉内容创作相关功能使用教程,涵盖AI生图、视频生成、无限画布、多模型创作、素材管理、声音音乐及视频剪辑等功能,帮助用户快速掌握PixTV从创意到成片的完整制作方法。

2026.09.29

60

15

Buffalo框架数据库开发全教程
Buffalo框架数据库开发全教程

本专题围绕Buffalo框架数据库开发,讲解database.yml多环境配置、soda与fizz迁移生成回滚、模型结构体标签、增删改查与条件查询、一对多与多对多关联、数据校验、回调钩子、事务处理及原生SQL执行能力。

2026.09.23

280

15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman中文手册
Webman中文手册

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

ThinkPHP5.1完全开发手册
ThinkPHP5.1完全开发手册

共0课时 | 0人学习