交易所前端需要频繁更新价格/盘口，你会如何设计推送/订阅机制以兼顾性能？

class OrderBookManager {
  private buffer: OrderUpdate[] = [];
  private renderTimer: number | null = null;
  private orderBook = { bids: [], asks: [] };

  constructor(private onUpdate: (book: OrderBook) => void) {
    this.connectWebSocket();
  }

  private connectWebSocket() {
    const ws = new WebSocket('wss://...');
    
    ws.onmessage = (event) => {
      const update = JSON.parse(event.data);
      this.buffer.push(update);
      this.scheduleRender();
    };
  }

  private scheduleRender() {
    if (this.renderTimer) return;
    
    this.renderTimer = window.setTimeout(() => {
      this.flushBuffer();
      this.renderTimer = null;
    }, 200); // 每 200ms 最多渲染一次
  }

  private flushBuffer() {
    // 批量应用所有更新
    for (const update of this.buffer) {
      this.applyUpdate(update);
    }
    this.buffer = [];
    
    // 通知 UI 更新
    this.onUpdate({ ...this.orderBook });
  }

  private applyUpdate(update: OrderUpdate) {
    // 增量更新订单簿
    // ...
  }
}