sparkStreaming+kafka+redis小项目实战

1、项目说明 一、需求 实时更新每一个用户走的总步数；html 每隔5s统计一次，包括某个用户新统计时的时间、所在地点、新增步数；java 这里为了方便只将每一个用户以及实时更新的步数总和两个维度保存到redis数据库中；git 二、业务流程 首先造一些模拟数据实时传入kafka队列，而后sparkStreaming从kafka实时读取这些模拟数据并作相关分析，最终将分析结果存入redis;git

>>阅读原文<<