推荐系统架构设计
1.分析用户行为数据:
收集用户的活跃时间、点击行为、浏览历史等数据。分析用户的活跃模式,确定用户最活跃的时间段。kafka + flink +数据库 分析用户行为并存储
2. 预生成推荐内容:
在用户活跃时间之前,预先生成推荐内容并存储到Redis缓存中。生成的推荐内容可以包括多个页面,以应对用户可能的分页请求。(模型支持历史推荐去重)
定时扫描,或定时触发生成推荐内容
3. 使用Redis缓存:
将预生成的推荐内容存储到Redis中,设置合理的过期时间。在用户请求时,优先从Redis缓存中获取推荐内容。
4. 动态更新推荐内容:
根据用户的实时行为,动态调整推荐内容。定期重新生成推荐内容,并更新Redis缓存。
5. 分页查询:
根据用户的请求,从Redis缓存中提取当前页面的内容。(对于已消费的内容,进行Redis删除)。给Redis推荐池设置一个阈值,查询时发现如果Redis缓存中没有足够的内容,就向推荐系统发起消费,推荐系统收到从消费请求,就进行生成推荐内容并更新Redis缓存。