# Send Websocket Hub Patterns to your agent Hand the extracted package to your coding agent with a concrete install brief instead of figuring it out manually. ## Fast path - Download the package from Yavira. - Extract it into a folder your agent can access. - Paste one of the prompts below and point your agent at the extracted folder. ## Suggested prompts ### New install ```text I downloaded a skill package from Yavira. Read SKILL.md from the extracted folder and install it by following the included instructions. Then review README.md for any prerequisites, environment setup, or post-install checks. Tell me what you changed and call out any manual steps you could not complete. ``` ### Upgrade existing ```text I downloaded an updated skill package from Yavira. Read SKILL.md from the extracted folder, compare it with my current installation, and upgrade it while preserving any custom configuration unless the package docs explicitly say otherwise. Then review README.md for any prerequisites, environment setup, or post-install checks. Summarize what changed and any follow-up checks I should run. ``` ## Machine-readable fields ```json { "schemaVersion": "1.0", "item": { "slug": "websocket-hub-patterns", "name": "Websocket Hub Patterns", "source": "tencent", "type": "skill", "category": "开发工具", "sourceUrl": "https://clawhub.ai/wpank/websocket-hub-patterns", "canonicalUrl": "https://clawhub.ai/wpank/websocket-hub-patterns", "targetPlatform": "OpenClaw" }, "install": { "downloadUrl": "/downloads/websocket-hub-patterns", "sourceDownloadUrl": "https://wry-manatee-359.convex.site/api/v1/download?slug=websocket-hub-patterns", "sourcePlatform": "tencent", "targetPlatform": "OpenClaw", "packageFormat": "ZIP package", "primaryDoc": "SKILL.md", "includedAssets": [ "README.md", "SKILL.md" ], "downloadMode": "redirect", "sourceHealth": { "source": "tencent", "slug": "websocket-hub-patterns", "status": "healthy", "reason": "direct_download_ok", "recommendedAction": "download", "checkedAt": "2026-05-10T23:53:19.555Z", "expiresAt": "2026-05-17T23:53:19.555Z", "httpStatus": 200, "finalUrl": "https://wry-manatee-359.convex.site/api/v1/download?slug=websocket-hub-patterns", "contentType": "application/zip", "probeMethod": "head", "details": { "probeUrl": "https://wry-manatee-359.convex.site/api/v1/download?slug=websocket-hub-patterns", "contentDisposition": "attachment; filename=\"websocket-hub-patterns-1.0.0.zip\"", "redirectLocation": null, "bodySnippet": null, "slug": "websocket-hub-patterns" }, "scope": "item", "summary": "Item download looks usable.", "detail": "Yavira can redirect you to the upstream package for this item.", "primaryActionLabel": "Download for OpenClaw", "primaryActionHref": "/downloads/websocket-hub-patterns" }, "validation": { "installChecklist": [ "Use the Yavira download entry.", "Review SKILL.md after the package is downloaded.", "Confirm the extracted package contains the expected setup assets." ], "postInstallChecks": [ "Confirm the extracted package includes the expected docs or setup files.", "Validate the skill or prompts are available in your target agent workspace.", "Capture any manual follow-up steps the agent could not complete." ] } }, "links": { "detailUrl": "https://openagent3.xyz/skills/websocket-hub-patterns", "downloadUrl": "https://openagent3.xyz/downloads/websocket-hub-patterns", "agentUrl": "https://openagent3.xyz/skills/websocket-hub-patterns/agent", "manifestUrl": "https://openagent3.xyz/skills/websocket-hub-patterns/agent.json", "briefUrl": "https://openagent3.xyz/skills/websocket-hub-patterns/agent.md" } } ``` ## Documentation ### WebSocket Hub Patterns Production patterns for horizontally-scalable WebSocket connections with Redis-backed coordination. ### OpenClaw / Moltbot / Clawbot npx clawhub@latest install websocket-hub-patterns ### When to Use Real-time bidirectional communication Chat applications, collaborative editing Live dashboards with client interactions Need horizontal scaling across multiple gateway instances ### Hub Structure type Hub struct { // Local state connections map[*Connection]bool subscriptions map[string]map[*Connection]bool // channel -> connections // Channels register chan *Connection unregister chan *Connection broadcast chan *Event // Redis for scaling redisClient *redis.Client redisSubs map[string]*goredis.PubSub redisSubLock sync.Mutex // Optional: Distributed registry connRegistry *ConnectionRegistry instanceID string // Shutdown done chan struct{} wg sync.WaitGroup } ### Hub Main Loop func (h *Hub) Run() { for { select { case <-h.done: return case conn := <-h.register: h.connections[conn] = true if h.connRegistry != nil { h.connRegistry.RegisterConnection(ctx, conn.ID(), info) } case conn := <-h.unregister: if _, ok := h.connections[conn]; ok { if h.connRegistry != nil { h.connRegistry.UnregisterConnection(ctx, conn.ID()) } h.removeConnection(conn) } case event := <-h.broadcast: h.broadcastToChannel(event) } } } ### Lazy Redis Subscriptions Subscribe to Redis only when first local subscriber joins: func (h *Hub) subscribeToChannel(conn *Connection, channel string) error { // Add to local subscriptions if h.subscriptions[channel] == nil { h.subscriptions[channel] = make(map[*Connection]bool) } h.subscriptions[channel][conn] = true // Lazy: Only subscribe to Redis on first subscriber h.redisSubLock.Lock() defer h.redisSubLock.Unlock() if _, exists := h.redisSubs[channel]; !exists { pubsub := h.redisClient.Subscribe(context.Background(), channel) h.redisSubs[channel] = pubsub go h.forwardRedisMessages(channel, pubsub) } return nil } func (h *Hub) unsubscribeFromChannel(conn *Connection, channel string) { if subs, ok := h.subscriptions[channel]; ok { delete(subs, conn) // Cleanup when no local subscribers if len(subs) == 0 { delete(h.subscriptions, channel) h.closeRedisSubscription(channel) } } } ### Redis Message Forwarding func (h *Hub) forwardRedisMessages(channel string, pubsub *goredis.PubSub) { ch := pubsub.Channel() for { select { case <-h.done: return case msg, ok := <-ch: if !ok { return } h.broadcast <- &Event{ Channel: channel, Data: []byte(msg.Payload), } } } } func (h *Hub) broadcastToChannel(event *Event) { subs := h.subscriptions[event.Channel] for conn := range subs { select { case conn.send <- event.Data: // Sent default: // Buffer full - close slow client h.removeConnection(conn) } } } ### Connection Write Pump func (c *Connection) writePump() { ticker := time.NewTicker(54 * time.Second) // Ping interval defer func() { ticker.Stop() c.conn.Close() }() for { select { case message, ok := <-c.send: c.conn.SetWriteDeadline(time.Now().Add(10 * time.Second)) if !ok { c.conn.WriteMessage(websocket.CloseMessage, []byte{}) return } c.conn.WriteMessage(websocket.TextMessage, message) // Batch drain queue for i := 0; i < len(c.send); i++ { c.conn.WriteMessage(websocket.TextMessage, <-c.send) } case <-ticker.C: if err := c.conn.WriteMessage(websocket.PingMessage, nil); err != nil { return } } } } ### Connection Registry for Horizontal Scaling type ConnectionRegistry struct { client *redis.Client instanceID string } func (r *ConnectionRegistry) RegisterConnection(ctx context.Context, connID string, info ConnectionInfo) error { info.InstanceID = r.instanceID data, _ := json.Marshal(info) return r.client.Set(ctx, "ws:conn:"+connID, data, 2*time.Minute).Err() } func (r *ConnectionRegistry) HeartbeatInstance(ctx context.Context, connectionCount int) error { info := InstanceInfo{ InstanceID: r.instanceID, Connections: connectionCount, } data, _ := json.Marshal(info) return r.client.Set(ctx, "ws:instance:"+r.instanceID, data, 30*time.Second).Err() } ### Graceful Shutdown func (h *Hub) Shutdown() { close(h.done) // Close all Redis subscriptions h.redisSubLock.Lock() for channel, pubsub := range h.redisSubs { pubsub.Close() delete(h.redisSubs, channel) } h.redisSubLock.Unlock() // Close all connections for conn := range h.connections { conn.Close() } h.wg.Wait() } ### Decision Tree SituationApproachSingle instanceSkip ConnectionRegistryMulti-instanceEnable ConnectionRegistryNo subscribers to channelLazy unsubscribe from RedisSlow clientClose on buffer overflowNeed message historyUse Redis Streams + Pub/Sub ### Related Skills Meta-skill: ai/skills/meta/realtime-dashboard/ — Complete realtime dashboard guide dual-stream-architecture — Event publishing resilient-connections — Connection resilience ### NEVER Do NEVER block on conn.send — Use select with default to detect overflow NEVER skip graceful shutdown — Clients need close frames NEVER share pubsub across channels — Each channel needs own subscription NEVER forget instance heartbeat — Dead instances leave orphaned connections NEVER send without ping/pong — Load balancers close "idle" connections ## Trust - Source: tencent - Verification: Indexed source record - Publisher: wpank - Version: 1.0.0 ## Source health - Status: healthy - Item download looks usable. - Yavira can redirect you to the upstream package for this item. - Health scope: item - Reason: direct_download_ok - Checked at: 2026-05-10T23:53:19.555Z - Expires at: 2026-05-17T23:53:19.555Z - Recommended action: Download for OpenClaw ## Links - [Detail page](https://openagent3.xyz/skills/websocket-hub-patterns) - [Send to Agent page](https://openagent3.xyz/skills/websocket-hub-patterns/agent) - [JSON manifest](https://openagent3.xyz/skills/websocket-hub-patterns/agent.json) - [Markdown brief](https://openagent3.xyz/skills/websocket-hub-patterns/agent.md) - [Download page](https://openagent3.xyz/downloads/websocket-hub-patterns)