栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java+redission排行榜实现

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java+redission排行榜实现

Redis 排行榜实现笔记(勿喷,高手请留言指点) 项目需求

统计每个用户 每日 每月 每年 搜索到关键词排行榜

代码实现

排行榜数据采集端

//获取今日日期
String toDay = LocalDateTime.now().format(DateTimeFormatter.BASIC_ISO_DATE);
StringBuffer sb = new StringBuffer();
//构建用户今日排行榜明年空间                sb.append(RedisKeyConstant.KEYWORD_RANKING).append("day").append(":").append(toDay).append(":").append(openId);
String rankingKey = sb.toString();

RScoredSortedSet scoredSortedSet = redissonClient.getScoredSortedSet(rankingKey);
//判断搜索词kw是否存在
Double score = scoredSortedSet.getScore(kw);
if(score == null || score < 1){
	//添加搜索词
   scoredSortedSet.add(1,kw);
}else{
	//对搜索词分数加1
   scoredSortedSet.addScore(kw,1);
}
 

排行榜数据展示端

LocalDateTime now = LocalDateTime.now();
String toDay = now.format(DateTimeFormatter.BASIC_ISO_DATE);
//获取当天排行榜
String rankingToday = RedisKeyConstant.KEYWORD_RANKING+"day:"+toDay;
//获取今日排行榜
getRanking(rankingToday+":"+openId))


//获取当月排行榜
//获取当月的第几天
int day = now.getDayOfMonth();
String rankingToMonth = RedisKeyConstant.KEYWORD_RANKING+"month:"+toDay.substring(0,toDay.length()-2);
mergeRanking(day,rankingToday.substring(0,rankingToday.length()-2),rankingToMonth,openId);
getRanking(rankingToMonth+":"+openId);

//获取当年排行榜
//获取当年的第几月
int month = now.getMonthValue();
int year = now.getYear();
String rankingToYear = RedisKeyConstant.KEYWORD_RANKING+"year:"+year;
mergeRanking(month,rankingToMonth.substring(0,rankingToMonth.length()-2),rankingToYear,openId);
getRanking(rankingToYear+":"+employee.getOpenId())


//统计并计算每日每月每年的排行榜
private void mergeRanking(int day, String needRankingKey,String destinationRankingKey,String openId) {
        RScoredSortedSet sortedSetMonth = redissonClient.getScoredSortedSet(destinationRankingKey+":"+openId);
        List list = Lists.newArrayList();
        IntStream.range(0,day).forEach(it -> {
            list.add(needRankingKey + StrUtil.fill(String.valueOf(it+1),'0',2,true) +":"+openId);
        });
        sortedSetMonth.union(list.toArray(new String[]{}));
}

//获取搜索词排行榜比根据分数排序
private List getRanking(String rankingKey){
        List kws = Lists.newlinkedList();
        RScoredSortedSet scoredSortedSet = redissonClient.getScoredSortedSet(rankingKey);
        if (scoredSortedSet != null && scoredSortedSet.isExists()) {
            scoredSortedSet.entryRangeReversed(0, 2).stream().forEach(it -> {
                kws.add(BussOppoKeyWord.build(String.valueOf(it.getValue()),it.getScore().longValue()));
            });
        }
        if(!CollUtil.isEmpty(kws)){
            IntStream.range(0,kws.size()).forEach(it -> {
                BussOppoKeyWord keyWord = kws.get(it);
                if(it < kws.size()-1){
                    if(keyWord.getTotal() == kws.get(it+1).getTotal()){
                        if(keyWord.getKeyWord().compareTo(kws.get(it + 1).getKeyWord()) > 1){
                            Collections.swap(kws,it,it+1);
                        }
                    }
                }
            });
        }
        return kws;
    }
 
效果图 

转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号