Method Run

web/ws/hub.go:73–112

Run 启动Hub

()

// Run 启动Hub
func (h *Hub) Run() {
	for {
		select {
		case client := <-h.register:
			h.mu.Lock()
			h.clients[client] = true
			h.mu.Unlock()

			// 发送连接成功消息
			msg := Message{
				Type:      MsgConnected,
				Timestamp: time.Now().UnixMilli(),
				Data:      map[string]string{"status": "connected"},
			}
			if data, err := json.Marshal(msg); err == nil {
				client.send <- data
			}

		case client := <-h.unregister:
			h.mu.Lock()
			if _, ok := h.clients[client]; ok {
				delete(h.clients, client)
				close(client.send)
			}
			h.mu.Unlock()

		case message := <-h.broadcast:
			h.mu.Lock()
			for client := range h.clients {
				select {
				case client.send <- message:
				default:
					close(client.send)
					delete(h.clients, client)
				}
			}
			h.mu.Unlock()
		}
	}
}

// Broadcast 广播消息给所有客户端
func (h *Hub) Broadcast(msgType MessageType, data interface{}) {