奉献于开源社区,手写伪集群自适应系统配置,稳定容差,为新手低成本提供了一个非常好的mq实战平台,降低了mq类集群学习的经济成本。
点击空白处退出提示
奉献于开源社区,手写伪集群自适应系统配置,稳定容差,为新手低成本提供了一个非常好的mq实战平台,降低了mq类集群学习的经济成本。
1. 用戶在 UI 點擊 broker-master-1 的「啟動」
2. 前端 POST /api/clusters/{id}/nodes/{nodeId}/start
3. API 控制器 → 應用用例
4. 應用通過 ClusterProviderRegistry 選適配器(PSEUDO, ROCKETMQ)
5. Pseudo 適配器啟動嵌入式 broker 進程
6. Broker 向進程內 NameServer 註冊
7. 適配器發布 TopologyChangedEvent 到 STOMP topic
8. 前端 hook 接收事件 → React 重新渲染拓撲圖
9. 活動日誌條目也推送到 /topic/.../activity
前端是 Next.js 16 應用(App Router、React 19、TypeScript 嚴格模式),渲染儀表盤、拓撲圖、消息工作台和監控圖表。
後端是 Spring Boot 4.1.0 應用,嵌入真實 Apache RocketMQ 5.3.3 運行時,提供 REST + WebSocket 端點。
通信通過 REST(/api)發送命令,通過 STOMP over WebSocket(/ws)接收實時事件流。



评论