PHP WebSocket服务器无法向所有连接客户端广播消息求助

问题根源 #

多进程fork后，每个子进程拥有独立的内存空间，clientResources数组是进程私有资源；共享内存中仅存储客户端ID，但socket连接句柄是进程专属的，跨进程无法直接使用，导致当前进程无法获取其他进程持有的客户端连接，广播时只能发送给自己管理的客户端，其他客户端因无法找到有效资源报错「Invalid client resource」。

可行解决方案 #

1. 基于IPC消息队列的广播转发（推荐）

• 父进程创建全局消息队列，所有子进程共享该队列
• 子进程收到广播请求时，不直接尝试跨进程发送，而是将广播内容推送到消息队列
• 父进程监听队列，收到广播消息后，通过信号/管道通知所有子进程
• 每个子进程收到通知后，从共享内存读取广播内容，发送给自己维护的本地客户端

简化代码示例：

// 父进程初始化消息队列
$msgQueueKey = ftok(__FILE__, 'W');
$globalMsgQueue = msg_get_queue($msgQueueKey);

// 子进程处理广播请求
function broadcast($message) {
    global $globalMsgQueue;
    msg_send($globalMsgQueue, 1, json_encode([
        'action' => 'broadcast',
        'content' => $message
    ]));
}

// 父进程后台监听队列
while (true) {
    msg_receive($globalMsgQueue, 0, $msgType, 4096, $payload);
    $data = json_decode($payload, true);
    if ($data['action'] === 'broadcast') {
        // 将广播内容写入共享内存临时区
        $shmId = shmop_open(0x1234, 'w', 0644, strlen($data['content']));
        shmop_write($shmId, $data['content'], 0);
        // 发送信号通知所有子进程
        foreach ($childPIDs as $pid) {
            posix_kill($pid, SIGUSR1);
        }
        shmop_close($shmId);
    }
}

// 子进程注册信号处理
pcntl_signal(SIGUSR1, function() {
    // 从共享内存读取广播内容
    $shmId = shmop_open(0x1234, 'r', 0644, 0);
    $message = shmop_read($shmId, 0, shmop_size($shmId));
    shmop_close($shmId);
    // 发送给本地客户端
    foreach ($GLOBALS['clientResources'] as $client) {
        socket_write($client, $message);
    }
});

2. 切换为单进程模型（低并发场景）

如果业务并发量不高，直接移除进程fork逻辑，用单进程处理所有客户端连接，这样clientResources是全局唯一的数组，广播时直接遍历数组发送即可，无需处理进程间通信。

3. 跨进程套接字传递（高并发场景）

利用PHPsockets扩展的socket_send_fd和socket_recv_fd方法，让子进程将新客户端的socket句柄传递给父进程，由父进程统一维护全局连接池，广播时由父进程直接向所有连接发送消息。这种方式实现复杂，但性能最优，适合高并发场景。

内容的提问来源于stack exchange，提问作者Dark Phoenix