首先建立用户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 关联起来。
当客户端成功建立 WebSocket 连接并完成身份验证后,服务端需要将该连接的 fd 与用户的唯一标识绑定。这个映射关系可以存储在内存数组、Swoole Table 或 Redis 等持久化/共享存储中。
当需要向某个用户发送消息时,先通过 user_id 查询其对应的 fd,再调用 $server->push() 方法发送数据。
映射表,获取目标用户的 fd必须在连接关闭时清理映射关系,避免出现向无效连接推送的情况。