CloddsBot WebSocket实时推送详解signal-bus信号总线如何驱动AI交易机器人【免费下载链接】CloddsBotOpen Source AI trading agent that operates autonomously across 1000 markets - Polymarket, Kalshi, Binance, Hyperliquid, Solana DEXs, 5 EVM chains. Scans for edge, executes instantly, manages risk while you sleep. Agent commerce protocol for machine-to-machine payments. Self-hosted. Built on Claude.项目地址: https://gitcode.com/GitHub_Trending/cl/CloddsBotCloddsBot 是一个开源的 AI 交易机器人AI Trading Agent可自主运行在 Polymarket、Kalshi、Binance、Hyperliquid 等 1000 市场之上。它的“神经中枢”正是signal-bus 信号总线将各交易所的 WebSocket 实时行情统一汇聚再扇出给交易策略、风险评估、WebSocket 客户端等多个消费者实现毫秒级的信号分发与实时推送。为什么需要一条信号总线CloddsBot 同时订阅多个平台的数据源预测市场Polymarket、Kalshi、Manifold、Metaculus加密货币交易所Binance、Bybit、Hyperliquid、MEXC链上 DEXSolanaJupiter、Raydium、Pump.fun、5 条 EVM 链如果没有统一的事件中枢每个模块K线记录器、特征引擎、仓位管理器、信号路由器都得各自去订阅行情逻辑会迅速失控。signal-bus 用一条总线解决了这个问题行情只被订阅一次再分发给所有消费者且单个消费者崩溃不会拖垮其他模块。其核心实现位于 src/gateway/signal-bus.ts公共类型定义在 src/types/signal-bus.ts。三大事件类型tick、orderbook、signal信号总线承载 3 种标准事件定义见 src/types/signal-bus.ts事件载荷说明tickTickUpdate每次价格变动平台、市场ID、最新价、前一价、时间戳orderbookOrderbookUpdate订单簿快照买一/卖一挂单、点差、中间价signalTradingSignal特征引擎产出的交易信号动量、反转、波动突刺、点差扩大、机会、情绪转变 6 类其中TradingSignal携带strength0–1 强度和direction买/卖/中性是驱动自动下单的最终依据。核心机制错误隔离的 emitsignal-bus 最精妙的设计是重写了emit方法src/gateway/signal-bus.ts分发事件时逐个调用监听器每个监听器都包在try/catch中某个消费者抛异常 → 只记录日志其余消费者照常收到事件正确处理.once()一次性监听器的语义这意味着即使某个策略模块出现 bug行情分发与 WebSocket 推送依然稳定运行——这是生产级交易机器人必须的健壮性。总线如何接线在网关启动时src/gateway/index.ts接线逻辑非常清晰createSignalBus()创建总线实例注册 tick 消费者K线记录器tickRecorder、实时推流器tickStreamer、特征引擎featureEngine注册 orderbook 消费者同样的三组模块featureEngine.setEmitter(signalBus)— 特征引擎算出的信号直接写回总线signalBus.connectFeeds(feeds)— 总线一次性订阅所有行情源数据流向一句话概括行情源WebSocket→ FeedManager → Signal Bus → 特征引擎 → TradingSignal → 信号路由器 → 自动下单 / 实时推送实时推送到你的浏览器总线不只服务于内部策略也直接对接对外接口。/signals/stream端点src/gateway/api-routes.ts通过Server-Sent Events将signal与tick事件实时推送给前端并带有 30 秒心跳保活。同时网关内置 WebSocket 服务器src/gateway/index.ts默认监听ws://host:8080/gateway路径支持最多 1000 个客户端并发、1MB 消息上限并通过dispatch机制向所有已认证客户端广播事件。tick-streamer 服务src/services/tick-streamer/则负责把 tick/orderbook 原始数据广播给任意数量下游客户端构建自己的行情大屏。信号路由器从信号到订单订阅signal事件的下游是Signal Routersrc/signal-router/router.ts它按配置过滤信号类型经过风险检查后交给执行层下单。整个链路全程异步、事件驱动无需轮询。快速上手克隆仓库git clone https://gitcode.com/GitHub_Trending/cl/CloddsBot安装依赖并启动网关信号总线会随 src/gateway/index.ts 自动接线浏览器访问 WebChat 或/signals/stream端点即可实时观察信号与行情推送参考 docs/API.md 与 docs/ARCHITECTURE.md 了解完整架构小结设计点收益单一订阅点行情源只订阅一次多消费者共享emit 错误隔离单模块崩溃不影响全局推送类型化事件tick / orderbook / signal 语义清晰SSE WebSocket 双通道前端推送与高频行情各取所需signal-bus 是 CloddsBot 在你睡觉时替你交易的关键基础设施——实时、解耦、容错这正是事件驱动架构在交易系统中最经典的落地范式。【免费下载链接】CloddsBotOpen Source AI trading agent that operates autonomously across 1000 markets - Polymarket, Kalshi, Binance, Hyperliquid, Solana DEXs, 5 EVM chains. Scans for edge, executes instantly, manages risk while you sleep. Agent commerce protocol for machine-to-machine payments. Self-hosted. Built on Claude.项目地址: https://gitcode.com/GitHub_Trending/cl/CloddsBot创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考