首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >建立缓存,防高并发代码demo

建立缓存,防高并发代码demo

作者头像
算法之名
发布2019-08-20 17:25:47
6240
发布2019-08-20 17:25:47
举报
文章被收录于专栏:算法之名算法之名

我在之前的博客中提到过——缓存并发,当一个key过期时,访问这个key的请求量过大,穿透到数据库.解决办法:1,分布式锁,保证每个key同时只有一个线程去查询数据库,其他线程没有获得分布式锁的权限,只需要等待.具体实现如下

@Override
public AppUser findById(Long id) {
    if (redisService.exists("user:" + id)) {
        String appUserStr = redisService.get("user:" + id);
        return JSONObject.parseObject(appUserStr,AppUser.class);
    } else {
        //获取分布式锁
        if (RedisTool.tryGetDistributedLock(redisService,"useridlock:" + id,Long.toString(id),180)) {
            AppUser appUser = appUserDao.findById(id);
            redisService.set("user:" + id, JSONObject.toJSONString(appUser));
            redisService.expire("user:" + id, 864000);
            //释放分布式锁
            RedisTool.releaseDistributedLock(redisService,"useridlock:" + id,Long.toString(id));
            return appUser;
        } else {   //无获得分布式锁权限时
            try {  //当前线程休眠1秒,可根据适当情况调整这个休眠时间
                Thread.currentThread().sleep(1000);
                if (redisService.exists("user:" + id)) {
                    String appUserStr = redisService.get("user:" + id);
                    return JSONObject.parseObject(appUserStr,AppUser.class);
                }else {
                    return null;
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
                return null;
            }
        }
    }
}

Redis分布式锁的写法可参考本人上一篇博客,谢谢!

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档