日处理20亿数据，实时用户行为服务系统架构实践

另外,数据发生积压的情况下,可以调整Worker的消费游标,从最新的数据重新开始消费,保证最新数据得到处理.中间未经处理的一段数据则启动backupWorker,指定起止游标,在消费完指定区间的数据之后,backupWorker会自动停止.(如下图)

图6：积压数据消解

三、可用性?

作为基础服务,对可用性的要求比一般的服务要高得多,因为下游依赖的服务多,一旦出现故障,有可能会引起级联反应影响大量业务.项目从设计上对以下问题做了处理,保障系统的可用性：

• 系统是否有单点?
• DB扩容/维护/故障怎么办?
• Redis维护/升级补丁怎么办?
• 服务万一挂了如何快速恢复?如何尽量不影响下游应用?

（编辑：温州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!