sparkStreaming+kafka+redis小項目實戰

1、項目說明 一、需求 實時更新每一個用戶走的總步數；html 每隔5s統計一次，包括某個用戶新統計時的時間、所在地點、新增步數；java 這裏爲了方便只將每一個用戶以及實時更新的步數總和兩個維度保存到redis數據庫中；git 二、業務流程 首先造一些模擬數據實時傳入kafka隊列，而後sparkStreaming從kafka實時讀取這些模擬數據並作相關分析，最終將分析結果存入redis;git

>>阅读原文<<