NestJS控制器中如何获取socket.io的客户端id？

你混淆了NestJS中不同装饰器的适用范围，同时对HTTP请求和WebSocket连接的通信链路逻辑理解有偏差：

• @ConnectedSocket() 是仅适用于WebSocket网关内消息处理方法的专属装饰器，完全无法在普通HTTP控制器的路由方法（你当前用的@Post()就是HTTP接口）中生效。
• 第三方服务触发的webhook请求是独立的HTTP请求，和前端与服务端建立的WebSocket长连接属于完全隔离的两条通信链路，本身不存在直接绑定关系，你不可能直接从HTTP请求中拿到对应前端的Socket实例。

你需要自行维护「业务用户唯一标识」和「Socket客户端ID」的映射关系，按以下逻辑实现即可：

1. 首先创建全局的映射存储服务，用来维护用户和Socket的绑定关系（分布式场景可以替换为Redis存储）

// socket-mapping.service.ts
import { Injectable } from '@nestjs/common';

@Injectable()
export class SocketMappingService {
  // 键为业务侧用户唯一ID，值为Socket客户端ID数组（兼容同一个用户多端登录的场景）
  private userSocketMap = new Map<string, string[]>();

  addUserSocket(userId: string, socketId: string) {
    const existSockets = this.userSocketMap.get(userId) || [];
    this.userSocketMap.set(userId, [...existSockets, socketId]);
  }

  removeUserSocket(userId: string, socketId: string) {
    const existSockets = this.userSocketMap.get(userId) || [];
    this.userSocketMap.set(userId, existSockets.filter(id => id !== socketId));
  }

  getUserSocketIds(userId: string): string[] {
    return this.userSocketMap.get(userId) || [];
  }
}

2. 实现WebSocket网关，监听连接/断开事件，更新映射关系，同时封装主动推送消息的方法

// chat.gateway.ts
import { WebSocketGateway, WebSocketServer, OnGatewayConnection, OnGatewayDisconnect } from '@nestjs/websockets';
import { Server, Socket } from 'socket.io';
import { SocketMappingService } from './socket-mapping.service';

@WebSocketGateway()
export class ChatGateway implements OnGatewayConnection, OnGatewayDisconnect {
  @WebSocketServer()
  server: Server;

  constructor(private readonly socketMappingService: SocketMappingService) {}

  async handleConnection(client: Socket) {
    // 前端连接WebSocket时需要携带鉴权token，解析出对应用户的唯一ID
    const userId = this.parseUserIdFromToken(client.handshake.auth.token);
    if (userId) {
      this.socketMappingService.addUserSocket(userId, client.id);
    } else {
      // 无有效身份直接断开连接
      client.disconnect();
    }
  }

  async handleDisconnect(client: Socket) {
    const userId = this.parseUserIdFromToken(client.handshake.auth.token);
    if (userId) {
      this.socketMappingService.removeUserSocket(userId, client.id);
    }
  }

  // 封装给指定用户推送消息的方法，供HTTP控制器调用
  pushMsgToUser(userId: string, message: any) {
    const targetSocketIds = this.socketMappingService.getUserSocketIds(userId);
    targetSocketIds.forEach(socketId => {
      this.server.to(socketId).emit('chat-message', message);
    });
  }

  private parseUserIdFromToken(token: string): string | null {
    // 自行实现JWT解析逻辑，拿到业务用户ID即可
    return 'your-parsed-user-id';
  }
}

3. 修改你的原有HTTP控制器，注入网关服务，接收webhook消息后推送给对应用户

@Controller('chat')
export class ChatController {
    // 注入WebSocket网关实例
    constructor(private readonly chatGateway: ChatGateway) {}

    @UseInterceptors(CamelCaseConverterInterceptor)
    @Post()
    getExternalMessage(
        @Body() payload: WebhookChatMessageDto,
    ): void {
       // 从webhook的payload中拿到要推送的目标用户ID
       const targetUserId = payload.userId;
       // 调用网关方法推送消息
       this.chatGateway.pushMsgToUser(targetUserId, payload.message);
    }
}

• 分布式部署场景下不要用本地内存存映射关系，换成Redis等公共存储，同时Socket.IO需要配置Redis适配器支持跨实例广播
• webhook的回调payload中必须包含要推送的目标用户唯一标识，才能匹配到对应的Socket连接

内容的提问来源于stack exchange，提问作者Denys Rybkin