医疗AI时代的生物医学Go编程:高性能计算与精准医疗的案例分析(七)
说明:
持久化: 使用BadgerDB作为嵌入式持久化存储。每个事件在发布时都会被序列化(JSON)并存储到DB中,键为event:<event_id>。
恢复: recoverFromDB在系统启动时运行,遍历DB中所有事件,重新发布到内部publishChan,实现故障恢复。
至少一次语义: 事件在持久化成功后才被分发给订阅者。如果进程在分发后、处理前崩溃,重启后