久久久久久久av_日韩在线中文_看一级毛片视频_日本精品二区_成人深夜福利视频_武道仙尊动漫在线观看

springboot+redis實現微博熱搜排行榜的示例代碼

本文主要介紹了springboot+redis實現微博熱搜排行榜的示例代碼,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學

技術模擬思路:

采用26個英文字母來實現排行,隨機為每個字母生成一個隨機數作為score

為了更好的體驗,先做幾件事:

  • 先初始化1個月的歷史數據
  • 定時5秒鐘,模擬微博的熱度刷新(例如模擬點贊 收藏 評論的熱度值更新)
  • 定時1小時合并統計 天、周、月的排行榜。

步驟1:先初始化1個月的歷史數據

@Service
@Slf4j
public class InitService {

? ? @Autowired
? ? private RedisTemplate redisTemplate;

? ? /**
? ? ?* 先初始化1個月的歷史數據
? ? ?*/
? ? public void init30day(){
? ? ? ? //計算當前的小時key
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? //初始化近30天,每天24個key
? ? ? ? for(int i=1;i<24*30;i++){
? ? ? ? ? ? //倒推過去30天
? ? ? ? ? ? String ?key=Constants.HOUR_KEY+(hour-i);
? ? ? ? ? ? this.initMember(key);
? ? ? ? ? ? System.out.println(key);
? ? ? ? }
? ? }

? ? /**
? ? ?*初始化某個小時的key
? ? ?*/
? ? public void initMember(String key) {
? ? ? ? Random rand = new Random();
? ? ? ? //采用26個英文字母來實現排行,隨機為每個字母生成一個隨機數作為score
? ? ? ? for(int i = 1;i<=26;i++){
? ? ? ? ? ? this.redisTemplate.opsForZSet().add(key,String.valueOf((char)(96+i)),rand.nextInt(10));
? ? ? ? }
? ? }

}

步驟2:定時刷新數據

@Service
@Slf4j
public class TaskService {

? ? @Autowired
? ? private RedisTemplate redisTemplate;

? ? /**
? ? ?*2. 定時5秒鐘,模擬微博的熱度刷新(例如模擬點贊 收藏 評論的熱度值更新)
? ? ?* 3. 定時1小時合并統計 天、周、月的排行榜。
? ? ?*/
? ? @PostConstruct
? ? public void init(){
? ? ? ? log.info("啟動初始化 ..........");
// ? ? ? ?2. 定時5秒鐘,模擬微博的熱度刷新(例如模擬點贊 收藏 評論的熱度值更新)
? ? ? ? new Thread(()->this.refreshDataHour()).start();
// ? ? ? ?3. 定時1小時合并統計 天、周、月的排行榜。
? ? ? ? new Thread(()->this.refreshData()).start();
? ? }

? ? /**
? ? ?*采用26個英文字母來實現排行,隨機為每個字母生成一個隨機數作為score
? ? ?*/
? ? public void refreshHour(){
? ? ? ? //計算當前的小時key
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? //為26個英文字母來實現排行,隨機為每個字母生成一個隨機數作為score
? ? ? ? Random rand = new Random();
? ? ? ? for(int i = 1;i<=26;i++){
? ? ? ? ? ? //redis的ZINCRBY 新增這個積分值
? ? ? ? ? ? this.redisTemplate.opsForZSet().incrementScore(Constants.HOUR_KEY+hour,String.valueOf((char)(96+i)),rand.nextInt(10));
? ? ? ? }
? ? }

? ? /**
? ? ?*刷新當天的統計數據
? ? ?*/
? ? public void refreshDay(){
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? List<String> otherKeys=new ArrayList<>();
? ? ? ? //算出近24小時內的key
? ? ? ? for(int i=1;i<23;i++){
? ? ? ? ? ? String ?key=Constants.HOUR_KEY+(hour-i);
? ? ? ? ? ? otherKeys.add(key);
? ? ? ? }
? ? ? ? //把當前的時間key,并且把后推23個小時,共計近24小時,求出并集存入Constants.DAY_KEY中
? ? ? ? //redis ZUNIONSTORE 求并集
? ? ? ? this.redisTemplate.opsForZSet().unionAndStore(Constants.HOUR_KEY+hour,otherKeys,Constants.DAY_KEY);

? ? ? ? //設置當天的key 40天過期,不然歷史數據浪費內存
? ? ? ? for(int i=0;i<24;i++){
? ? ? ? ? ? String ?key=Constants.HOUR_KEY+(hour-i);
? ? ? ? ? ? this.redisTemplate.expire(key,40, TimeUnit.DAYS);
? ? ? ? }
? ? ? ? log.info("天刷新完成..........");
? ? }
? ? /**
? ? ?*刷新7天的統計數據
? ? ?*/
? ? public void refreshWeek(){
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? List<String> otherKeys=new ArrayList<>();
? ? ? ? //算出近7天內的key
? ? ? ? for(int i=1;i<24*7-1;i++){
? ? ? ? ? ? String ?key=Constants.HOUR_KEY+(hour-i);
? ? ? ? ? ? otherKeys.add(key);
? ? ? ? }
? ? ? ? //把當前的時間key,并且把后推24*7-1個小時,共計近24*7小時,求出并集存入Constants.WEEK_KEY中
? ? ? ? this.redisTemplate.opsForZSet().unionAndStore(Constants.HOUR_KEY+hour,otherKeys,Constants.WEEK_KEY);

? ? ? ? log.info("周刷新完成..........");
? ? }

? ? /**
? ? ?*刷新30天的統計數據
? ? ?*/
? ? public void refreshMonth(){
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? List<String> otherKeys=new ArrayList<>();
? ? ? ? //算出近30天內的key
? ? ? ? for(int i=1;i<24*30-1;i++){
? ? ? ? ? ? String ?key=Constants.HOUR_KEY+(hour-i);
? ? ? ? ? ? otherKeys.add(key);
? ? ? ? }
? ? ? ? //把當前的時間key,并且把后推24*30個小時,共計近24*30小時,求出并集存入Constants.MONTH_KEY中
? ? ? ? this.redisTemplate.opsForZSet().unionAndStore(Constants.HOUR_KEY+hour,otherKeys,Constants.MONTH_KEY);
? ? ? ? log.info("月刷新完成..........");
? ? }

? ? /**
? ? ?*定時1小時合并統計 天、周、月的排行榜。
? ? ?*/
? ? public void refreshData(){
? ? ? ? while (true){
? ? ? ? ? ? //刷新當天的統計數據
? ? ? ? ? ? this.refreshDay();
// ? ? ? ? ? ?刷新7天的統計數據
? ? ? ? ? ? this.refreshWeek();
// ? ? ? ? ? ?刷新30天的統計數據
? ? ? ? ? ? this.refreshMonth();
? ? ? ? ? ? //TODO 在分布式系統中,建議用xxljob來實現定時
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? Thread.sleep(1000*60*60);
? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }

? ? /**
? ? ?*定時5秒鐘,模擬微博的熱度刷新(例如模擬點贊 收藏 評論的熱度值更新)
? ? ?*/
? ? public void refreshDataHour(){
? ? ? ? while (true){
? ? ? ? ? ? this.refreshHour();
? ? ? ? ? ? //TODO 在分布式系統中,建議用xxljob來實現定時
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? Thread.sleep(5000);
? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

步驟3:排行榜查詢接口

@RestController
@Slf4j
public class Controller {

? ? @Autowired
? ? private RedisTemplate redisTemplate;


? ? @GetMapping(value = "/getHour")
? ? public Set getHour() {
? ? ? ? long hour=System.currentTimeMillis()/(1000*60*60);
? ? ? ? //ZREVRANGE 返回有序集key中,指定區(qū)間內的成員,降序。
? ? ? ? Set<ZSetOperations.TypedTuple<Integer>> rang= this.redisTemplate.opsForZSet().reverseRangeWithScores(Constants.HOUR_KEY+hour,0,30);
? ? ? ? return rang;
? ? }
? ? @GetMapping(value = "/getDay")
? ? public Set getDay() {
? ? ? ? Set<ZSetOperations.TypedTuple<Integer>> rang= this.redisTemplate.opsForZSet().reverseRangeWithScores(Constants.DAY_KEY,0,30);
? ? ? ? return rang;
? ? }

? ? @GetMapping(value = "/getWeek")
? ? public Set getWeek() {
? ? ? ? Set<ZSetOperations.TypedTuple<Integer>> rang= this.redisTemplate.opsForZSet().reverseRangeWithScores(Constants.WEEK_KEY,0,30);
? ? ? ? return rang;
? ? }

? ? @GetMapping(value = "/getMonth")
? ? public Set getMonth() {
? ? ? ? Set<ZSetOperations.TypedTuple<Integer>> rang= this.redisTemplate.opsForZSet().reverseRangeWithScores(Constants.MONTH_KEY,0,30);
? ? ? ? return rang;
? ? }
}

到此這篇關于springboot+redis實現微博熱搜排行榜的示例代碼的文章就介紹到這了,更多相關springboot redis微博熱搜排行榜內容請搜索html5模板網以前的文章希望大家以后多多支持html5模板網!

【網站聲明】本站部分內容來源于互聯網,旨在幫助大家更快的解決問題,如果有圖片或者內容侵犯了您的權益,請聯系我們刪除處理,感謝您的支持!

相關文檔推薦

主站蜘蛛池模板: 中文字幕一区二区三区四区不卡 | 国产一区二 | 97视频在线免费 | 色狠狠桃花综合 | 日韩精品一区二区三区中文在线 | 天天操网| 网站黄色av | 久久69精品久久久久久久电影好 | 亚洲电影一级片 | 成人亚洲视频 | 99综合网 | 国产精品视频一 | 欧美黄色网 | 男女午夜免费视频 | 自拍视频一区二区三区 | 韩国理论电影在线 | 国产精品亚洲精品日韩已方 | 欧美一区二区三区四区视频 | 亚洲男人的天堂网站 | 美女黄网站 | 欧美日韩国产一区二区三区 | 亚洲人成人一区二区在线观看 | 国产98色在线 | 日韩 | 美女爽到呻吟久久久久 | 国产电影一区二区在线观看 | 丝袜美腿一区二区三区 | 成人av一区二区三区 | 亚洲九九精品 | 在线中文字幕第一页 | 久草在线中文888 | 亚洲成人免费视频在线观看 | jav成人av免费播放 | 激情一区二区三区 | 成人在线免费观看 | 亚洲一区 | 精品三级在线观看 | 福利色导航 | 天天干干| 欧美激情五月 | 中文字幕国产一区 | 精品av |