关于java基于redis有序集合实现排行榜(2)-木庄网络博客

在这里插入图片描述

因为排行榜对实时性要求比较高，个人认为没必要进行持久化到数据库

/**
 * 根据公司名找到指定公司
 * @param companyName
 * @return
 */
@Override
public AjaxResult selectCompanyName(String companyName) {
    Set<Object> set =  redisUtils.sGet("company");
    for(Object i : set){
        String json = JSONObject.toJSONString(i);
        JSONObject jsonObject = JSONObject.parseObject(json);
        if(jsonObject.getString("companyName").equals(companyName)){
            //搜索次数 + 1
            redisUtils.sortSetZincrby("companyRank",companyName,1);
            log.info("直接缓存中返回");
            return new AjaxResult().ok(jsonObject);
        }
    }
    log.error("缓存中没有,查数据库");
    TbCommpanyExample tbCommpanyExample = new TbCommpanyExample();
    tbCommpanyExample.createCriteria().andCompanyNameEqualTo(companyName);
    List<TbCommpany> list = tbCommpanyMapper.selectByExample(tbCommpanyExample);
    if(list.size() != 0){
        //放入缓存中
        redisUtils.sSet("company",list.get(0));
        //数据库中存在
        //搜索次数 + 1
        redisUtils.sortSetZincrby("companyRank",companyName,1);
        log.info("sql");
        return new AjaxResult().ok(list.get(0));
    }else{
        return new AjaxResult().error("没有找到该公司："+companyName);
    }
}

获取排名

/**
 * 获得公司排行榜(前十)
 * @return
 */
@Override
public AjaxResult getCompanyRank() {
    Set set = redisUtils.sortSetRange("companyRank",0,9);
    if(set.size() == 0){
        return new AjaxResult().error("公司排行榜为空");
    }
    return new AjaxResult().ok(set);
}