Tcp Websocket Specialist

房間管理

• client.join(roomId)：加入房間
• client.leave(roomId)：離開房間
• this.server.to(roomId).emit()：向特定房間廣播

認證整合

• 使用 @UseGuards() 搭配 WsGuard
• Token 驗證應在 handleConnection 階段進行

2. TCP 自定義協定（錢包通訊）

TcpClientService 設計模式

import { Injectable, OnModuleInit, OnModuleDestroy } from '@nestjs/common';
import * as net from 'net';

@Injectable()
export class TcpClientService implements OnModuleInit, OnModuleDestroy {
  private client: net.Socket;
  private isConnected = false;
  private messageBuffer = Buffer.alloc(0);

  async onModuleInit() {
    await this.connect();
  }

  async onModuleDestroy() {
    this.disconnect();
  }

  private async connect(): Promise<void> {
    return new Promise((resolve, reject) => {
      this.client = new net.Socket();
      this.client.connect({
        host: process.env.WALLET_HOST,
        port: parseInt(process.env.WALLET_PORT, 10),
      });

      this.client.on('connect', () => {
        this.isConnected = true;
        resolve();
      });

      this.client.on('data', (data) => this.handleData(data));
      this.client.on('error', (err) => this.handleError(err));
      this.client.on('close', () => this.handleClose());
    });
  }

  private handleData(data: Buffer): void {
    // 處理封包黏包問題
    this.messageBuffer = Buffer.concat([this.messageBuffer, data]);
    this.processBuffer();
  }

  private processBuffer(): void {
    // 依據封包格式解析完整訊息
    // 格式範例：[4 bytes 長度][N bytes 內容]
    while (this.messageBuffer.length >= 4) {
      const length = this.messageBuffer.readUInt32BE(0);
      if (this.messageBuffer.length < 4 + length) break;
      
      const message = this.messageBuffer.slice(4, 4 + length);
      this.messageBuffer = this.messageBuffer.slice(4 + length);
      
      this.handleMessage(message);
    }
  }

  async sendMessage(payload: object): Promise<void> {
    const content = Buffer.from(JSON.stringify(payload), 'utf8');
    const header = Buffer.alloc(4);
    header.writeUInt32BE(content.length, 0);
    
    const packet = Buffer.concat([header, content]);
    this.client.write(packet);
  }
}

封包格式建議

• Header (4 bytes)：封包長度
• Body (N bytes)：JSON 或 Protocol Buffers

錯誤處理與重連機制

• 實作指數退避重連策略
• 設定最大重試次數
• 健康檢查 (Heartbeat) 機制

3. HTTP/Express 整合

Controller 與 Gateway 協作

@Controller('notifications')
export class NotificationController {
  constructor(private readonly gameGateway: GameGateway) {}

  @Post('broadcast')
  broadcastMessage(@Body() dto: BroadcastDto) {
    this.gameGateway.server.to(dto.roomId).emit('notification', dto.message);
    return { success: true };
  }
}

4. 跨協定資料流

典型流程：HTTP → Service → WebSocket

[Client A (HTTP)] → [REST API] → [NotificationService] 
                                         ↓
                              [GameGateway.server.emit()]
                                         ↓
                              [Client B, C, D (WebSocket)]

典型流程：TCP → Service → WebSocket

[Wallet Server (TCP)] → [TcpClientService]
                              ↓
                      [WalletEventHandler]
                              ↓
                      [GameGateway.server.to(userId).emit()]

Constraints

• 🚨 WebSocket 認證必要：生產環境必須在 handleConnection 驗證 Token。
• ⚠️ TCP 封包黏包處理：必須實作封包邊界處理邏輯，避免資料截斷。
• 📝 事件命名一致性：WebSocket 事件名稱統一使用 camelCase。
• 🔒 敏感操作驗證：涉及錢包操作的 TCP 通訊必須加入簽章驗證。
• 📌 日誌記錄：所有協定的連線/斷線/錯誤事件必須記錄日誌。