毫秒级别，
一切同步。

全部数据实时同步。多个机器人实例共享状态，犹如一个完整系统般协同运转。

Bot A

Bot B

同步引擎

Database

Cache

所有事件 皆可流式传输。

实时可视化机器人之间的事件传播。可立即查看哪个机器人将哪种事件传播到了哪个存储。

  • 全事件的实时数据流

  • 对来源、事件类型、目标的追踪

  • 传播延迟的监控

  • 事件过滤与搜索

事件流

14:32:01.001

Bot A

message.create

→ DB + Cache

2ms

14:32:01.004

Engine

state.broadcast

→ Bot A, Bot B

1ms

14:32:01.228

Bot B

member.join

→ DB

3ms

14:32:01.231

Engine

state.broadcast

→ Bot A, Bot B

1ms

14:32:01.445

Bot A

role.assign

→ Cache

1ms

14:32:01.890

Bot B

command.execute

→ DB + Cache

4ms

同步的生命周期

从事件产生到数据存储的持久化，通过 4 段式流水线保证一致性。每一步都在毫秒级别完成。

事件产生

用户执行命令、接收消息等事件发生。

发布

事件信息经 Pub/Sub 发送至同步引擎，延迟为毫秒级。

数据传播

变更传播到所有相关实例，确保一致性。

存储更新

持久化到 Redis / PostgreSQL，Pod 重启时也可恢复状态。

可经得起生产考验的 实时基础设施。

  • Pub/Sub 消息

    事件驱动的响应式架构

  • 分布式锁

    通过 Redis Redlock 实现严格的互斥控制

  • 事件溯源

    全部变更按时间顺序记录，可重放

  • WebSocket 集成

    向客户端即时推送通知

  • 背压控制

    在过载时缓冲事件

< 5ms

平均同步延迟

10K+

并发连接数

强一致

数据一致性

自动

故障恢复

实时基础设施的全部

Pub/Sub 消息

事件驱动的响应式架构。所有实例都能立即接收事件，保持状态一致性。

分布式锁

通过 Redis Redlock 消除竞态条件，实现严格的互斥控制。

事件溯源

按时间顺序记录全部变更，可将状态重建到任意时点。

WebSocket 集成与自动恢复

向客户端即时推送通知。通过断线自动重连、背压控制与事件缓冲，防止数据丢失。