在使用 Nest.js 搭建 WebSocket 群聊功能时很多开发者都会遇到“如何实现私聊”的难题。下面给出完整的实现思路，并结合代码示例，方便你落地。

主要模块结构

import { Module } from "@nestjs/common";不过，import { EventsGateway } from "./events.gateway";@Module({
imports:,controllers:,providers:。exports:
})
export class WebsocketModule {}

为什么要拆成 Gateway？

Gateway 负责处理所有 WebSocket 的生命周期。将其单独拆出来既能保持代码整洁，也方便后期维护。

主要原因

import {
WebSocketGateway,SubscribeMessage。MessageBody,ConnectedSocket,WebSocketServer,OnGatewayInit,OnGatewayConnection,OnGatewayDisconnect
} from "@nestjs/websockets";import { Server,Socket } from 'socket.io';@WebSocketGateway
export class EventsGateway implements OnGatewayInit,OnGatewayConnection。OnGatewayDisconnect {
// 给所有 websocket 客户端发送信息
@WebSocketServer
server这方面，Server;/**
* userId -> socketId
*/
private userSocketMap = new Map;/**
* socketId -> userId
*/
private socketUserMap = new Map;/* ==================== 群聊 ==================== */
/**
* 群聊事件
* @param data - 包含 message 字段
* @param client - 当前连接的 Socket 对象
*/
@SubscribeMessage
handleEvent data: string,@ConnectedSocket client: Socket) {
console.log;// 广播给除了当前客户端之外的所有客户端
client.broadcast.emit('events'。{
说到type，'client',message: data
});}
/* ==================== 私聊 ==================== */
/**
* 私聊事件
* @param data - 包含 toUserId 与 message 字段
* @param client - 当前连接的 Socket 对象
*/
@SubscribeMessage
handlePrivateMessage data: any,@ConnectedSocket client: Socket) {
console.log;说起来，// 当前发送者 ID
const fromUserId = this.socketUserMap.get;// 接收者 ID
const toUserId = Number;// 根据接收者 ID 查找对应的 socket.id
const toSocketId = this.userSocketMap.get;
if {
client.emit('privateMessage'。{
message: '不在线',time: Date.now,});return，}
// 将消息发送给指定使用者的 socket.id
this.server.to.emit('privateMessage'。{
fromUserId,message: data.message,time: Date.now,});}
/* ==================== 生命周期 ==================== */
afterInit {
console.log;}
handleConnection {
// 建立映射关系：userID ↔︎ socket.id
this.userSocketMap.set,client.id);this.socketUserMap.set;// 广播使用者加入信息给全体成员
this.server.emit('server',{
type的观点是，'server'。message: `使用者 ${client.handshake.auth.userId} 加入聊天室`
});}
handleDisconnect {
this.server.emit('server'。{
type这方面，'server',message:`使用者 ${client.id} 离开聊天室`
});console.log，不过，}
}

前端示例

账号 / 邮箱

登 录

常见痛点 & 对策

1️⃣ 使用者映射失效 / 离线检查不到位

• 痛点：当使用者离线后映射表仍保留旧数据导致错误广播。其实，
• 对策：在 handleDisconnect 中及时删除对应映射；使用心跳机制检测空闲连接。

2️⃣ 私聊安全性不高

• 痛点：若未对接收方进行身份校验，恶意使用者可伪造 target ID。
• 对策：后端根据握手中携带的 token 或 session 校验请求来源；仅允许已验证过的 ID 才能接收消息。

3️⃣ 大规模并发导致性能瓶颈

• 痛点：Nest.js + socket.io 在高并发下可能出现 GC 垃圾回收卡顿。
• 对策：SSE 或 Redis pub/sub 做分布式集群；使用更轻量级框架如 ws 或 uWebSockets.js 替代。

4️⃣ 缺少离线消息存储与推送

• 痛点：User 在离线时收到私聊会被丢失。按理说，
• 对策：I/O 写入数据库或缓存保存离线消息。使用者上线后主动拉取或通过 FCM/Web Push 推送。话说回来，

`