首先建立用户ID与fd的映射关系，在用户认证后将user_id与客户端fd绑定并存储于Swoole Table或Redis中；随后通过查询该映射获取目标fd，使用$server->push($fd, $message)向指定用户推送消息，并在on(‘close’)时清除失效连接，确保映射准确。

在 Swoole 的 WebSocket 服务中向指定用户推送消息，关键在于建立并维护用户标识（如 user_id）与客户端连接文件描述符（fd）之间的映射关系。WebSocket 连接建立后，Swoole 会为每个连接分配一个唯一的 fd，但这个 fd 并不直接对应业务系统中的用户。因此，需要在用户登录或认证后，将 user_id 和当前的 fd 关联起来。

建立用户ID与FD的映射

当客户端成功建立 WebSocket 连接并完成身份验证后，服务端需要将该连接的 fd 与用户的唯一标识绑定。这个映射关系可以存储在内存数组、Swoole Table 或 Redis 等持久化/共享存储中。

• 使用 Swoole Table 可以在多进程间共享数据，适合单机部署场景
• 使用 Redis 更适合分布式或集群环境，能保证多个服务实例间的数据一致性
• 在 on(‘open’) 回调中接收客户端传来的用户 token 或 id，验证后完成绑定

推送消息的具体实现

当需要向某个用户发送消息时，先通过 user_id 查询其对应的 fd，再调用 $server->push() 方法发送数据。

稿定AI绘图

稿定推出的AI绘画工具

36

查看详情

• 查询存储中的映射表，获取目标用户的 fd
• 使用 $server->push($fd, $message) 向指定连接推送消息
• 推送前最好检查连接是否仍然有效，可通过 $server->exist($fd) 判断
• 若用户有多个设备在线或多个标签页打开，可能需要维护一个 fd 列表，逐一推送

处理连接断开和重复登录

必须在连接关闭时清理映射关系，避免出现向无效连接推送的情况。

• 在 on(‘close’) 事件中，根据 fd 查找并删除对应的 user_id 映射
• 对于重复登录，可以选择踢掉旧连接，或允许多端同时在线
• 若踢掉旧连接，需在新连接建立时查找是否存在旧 fd，并主动 close 旧连接

基本上就这些步骤，核心是管理好 user_id 和 fd 的生命周期，确保映射准确、及时更新。