需求

  • 猜你喜欢:基于用户行为推荐,当用户对商品进行评分时,根据用户历史评分商品,结 合 itemCF 计算推荐结果。
  • 热门商品:历史热门商品
  • 好评商品:评分较高的商品
  • 实时热门商品:对过去一个小时热门商品进行统计,每5分钟滑动一次

    架构设计

    image.png

    需求分析

    推荐模块
  1. 离线推荐
    1. 历史热门商品
      1. 对所有时间用户评分的商品根据评分次数进行倒序排列
      2. 使用flink将hbase的rating表加载到内存中,根据productid分组,统计出现次数并倒序排列
    2. 好评商品
      1. 根据商品评分均分倒序排列
    3. 看过该商品的人还看了
      1. 基于物品推荐(itemCF)
  2. 实时推荐
    1. 实时热门商品
      1. 每五分钟对过去一小时数据进行排序,选出热门商品。

    2. 猜你喜欢