在一个复杂的业务系统中，需要实时分析用户行为数据（如点击、浏览、购买等），以提供个性化推荐服务。请设计一个系统架构，描述主要组件及其功能，以及数据的流动过程。

答题要点

可使用分层分析法来设计系统架构。关键要点：数据采集层负责收集用户的各种行为数据，通过埋点等技术将数据发送到消息队列。消息队列作为缓冲，确保数据的可靠传输，避免数据丢失。数据处理层对消息队列中的数据进行实时处理，如清洗、转换和聚合。存储层将处理后的数据存储到数据库或数据仓库，方便后续查询和分析。推荐引擎根据存储的数据和用户特征，生成个性化推荐结果。示例话术：首先，在前端页面埋点收集用户行为数据，发送到 Kafka 消息队列。接着，Flink 实时处理这些数据，将结果存入 HBase 存储。最后，推荐引擎从 HBase 获取数据，为用户生成个性化推荐。