PHP 实现长轮询消息实时推送功能

消息写入接口 write.php

这个脚本负责接收前端发送的消息，并将其持久化到本地文件中。同时记录当前消息的发送者和读取状态。

<?php
/**
 * 消息写入处理
 */
$filename = dirname(__FILE__) . '/data.txt';
$isread_file = dirname(__FILE__) . '/isread.txt';
$userfile = dirname(__FILE__) . '/user.txt';

// 写入消息内容
file_put_contents($filename, $_GET['msg']);
// 标记为未读
file_put_contents($isread_file, '0');
// 记录发送者
file_put_contents($userfile, $_GET['user']);

echo json_encode(['sf' => true]);
?>

长轮询接收接口 ajaxPush.php

这是长轮询的核心部分。脚本会进入一个循环，不断检查是否有新消息。只有当检测到对方发送的新消息时，才会返回数据并结束阻塞，随后前端再次发起新的请求。

<?php
/**
 * 长轮询消息接收
 */
$filename = dirname(__FILE__) . '/data.txt';
$isread_file = dirname(__FILE__) . '/isread.txt';
$userfile = dirname(__FILE__) . '/user.txt';

// 获取当前登录用户，假设对方是另一个 ID
$get_user = $_GET['user'] == '1' ? '2' : '1';
$msg = '';

while (true) {
    $msg = file_get_contents($filename);
    $isread = file_get_contents($isread_file);
    $user = file_get_contents($userfile);

    // 如果消息存在且是对方发送的，标记为已读并退出循环
    if ($isread == '0' && $get_user == $user) {
        file_put_contents($isread_file, '1');
        break;
    }
    sleep(1); // 轮询间隔，避免 CPU 占用过高
}

echo json_encode(['msg' => $msg]);
?>

注意事项

1. 文件锁：上述代码在并发场景下可能存在读写冲突，生产环境建议使用 flock 进行文件锁保护。
2. 性能瓶颈：长轮询依赖 HTTP 连接维持，高并发下对服务器资源消耗较大，适合低流量或学习原理的场景。
3. 安全性：实际项目中需增加身份验证与输入过滤，防止 XSS 攻击。