Java手撸一个缓存类似Redis

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: `LocalExpiringCache`是Java实现的一个本地缓存类,使用ConcurrentHashMap存储键值对,并通过ScheduledExecutorService定时清理过期的缓存项。类中包含`put`、`get`、`remove`等方法操作缓存,并有`clearCache`方法来清除过期的缓存条目。初始化时,会注册一个定时任务,每500毫秒检查并清理一次过期缓存。单例模式确保了类的唯一实例。
package com.boot.cache.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @author liu pei
 * @date 2024年01月22日 下午5:01
 * @Description:
 */
public class LocalExpiringCache {
   

    public static void main(String[] args) {
   
        LocalExpiringCache.getInstance().put("","",100);
    }

    protected static final Logger log = LoggerFactory.getLogger(LocalExpiringCache.class);

    /* 定时清理缓存 */
    private static final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();

    private static Map<String, CacheItem> cache = null;

    private class CacheItem {
   
        private Object value;
        private Long expirationTime;
        public CacheItem(Object value, long expirationTime) {
   
            this.value = value;
            this.expirationTime = expirationTime;
        }

        public Object getValue() {
   
            return value;
        }

        public void setValue(Object value) {
   
            this.value = value;
        }

        public Long getExpirationTime() {
   
            return expirationTime;
        }

        public void setExpirationTime(Long expirationTime) {
   
            this.expirationTime = expirationTime;
        }
    }

    private static class ExpiringCacheHolder {
   
        private static final LocalExpiringCache INSTANCE = new LocalExpiringCache();
    }

    public static final LocalExpiringCache getInstance() {
   
        return LocalExpiringCache.ExpiringCacheHolder.INSTANCE;
    }

    private LocalExpiringCache() {
   
        log.info("正在初始化缓存池.........");

        cache = new ConcurrentHashMap<>();

        // 注册一个定时线程任务,服务启动1秒之后,每隔500毫秒执行一次
        // 定时清理过期缓存 1000 首次执行时间 500 (毫秒)执行周期,5分钟清理一次
        executor.scheduleAtFixedRate(LocalExpiringCache::clearCache, 1000, 1000*50, TimeUnit.MILLISECONDS);
    }


    public void put(String key, Object value, long expirationSecond) {
   
        long expirationTime = System.currentTimeMillis() + expirationSecond * 1000;
        CacheItem item = new CacheItem(value, expirationTime);
        cache.put(key, item);
    }

    public Object get(String key) {
   
        CacheItem item = cache.get(key);
        if (item != null && System.currentTimeMillis() < item.getExpirationTime()) {
   
            return item.getValue();
        }
        return null; // 缓存项已过期或不存在
    }
    public void remove(String key) {
   
        cache.remove(key);
    }
    public void clear() {
   
        cache.clear();
    }
    public boolean containsKey(String key) {
   
        return cache.containsKey(key);
    }
    public boolean isEmpty() {
   
        return cache.isEmpty();
    }
    public int size() {
   
        return cache.size();
    }


    /**
     * 清理过期的缓存数据
     */
    private static void clearCache() {
   
        if (cache.size() <= 0) {
   
            return;
        }
        // 判断是否过期 过期就从缓存Map删除这个元素
        cache.entrySet().removeIf(entry -> entry.getValue().getExpirationTime() != null && entry.getValue().getExpirationTime() < System.currentTimeMillis());
    }
}
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
5天前
|
缓存 安全 Java
7张图带你轻松理解Java 线程安全,java缓存机制面试
7张图带你轻松理解Java 线程安全,java缓存机制面试
|
1天前
|
NoSQL Java Redis
如何在redis中设置文件夹名java - 蓝易云
在这个例子中,"folder:subfolder:key"就像一个文件夹路径,并且键的值被设置为"value"。然后,我们使用相同的键来获取并打印值。最后,记得关闭Jedis连接。
16 0
|
3天前
|
NoSQL Redis 缓存
【后端面经】【缓存】36|Redis 单线程:为什么 Redis 用单线程而 Memcached 用多线程?
【5月更文挑战第17天】Redis常被称为单线程,但实际上其在处理命令时采用单线程,但在6.0后IO变为多线程。持久化和数据同步等任务由额外线程处理,因此严格来说Redis是多线程的。面试时需理解Redis的IO模型,如epoll和Reactor模式,以及其内存操作带来的高性能。Redis使用epoll进行高效文件描述符管理,实现高性能的网络IO。在讨论Redis与Memcached的线程模型差异时,应强调Redis的单线程模型如何通过内存操作和高效IO实现高性能。
28 7
【后端面经】【缓存】36|Redis 单线程:为什么 Redis 用单线程而 Memcached 用多线程?
|
4天前
|
缓存 算法 Java
数据结构~缓存淘汰算法--LRU算法(Java的俩种实现方式,万字解析
数据结构~缓存淘汰算法--LRU算法(Java的俩种实现方式,万字解析
|
4天前
|
NoSQL 算法 Java
【redis源码学习】持久化机制,java程序员面试算法宝典pdf
【redis源码学习】持久化机制,java程序员面试算法宝典pdf
|
6天前
|
缓存 NoSQL 关系型数据库
【Redis】Redis 缓存重点解析
【Redis】Redis 缓存重点解析
15 0
|
6天前
|
缓存 NoSQL 关系型数据库
【Redis】Redis作为缓存
【Redis】Redis作为缓存
8 0
|
6天前
|
消息中间件 缓存 NoSQL
Redis经典问题:缓存雪崩
本文介绍了Redis缓存雪崩问题及其解决方案。缓存雪崩是指大量缓存同一时间失效,导致请求涌入数据库,可能造成系统崩溃。解决方法包括:1) 使用Redis主从复制和哨兵机制提高高可用性;2) 结合本地ehcache缓存和Hystrix限流降级策略;3) 设置随机过期时间避免同一时刻大量缓存失效;4) 使用缓存标记策略,在标记失效时更新数据缓存;5) 实施多级缓存策略,如一级缓存失效时由二级缓存更新;6) 通过第三方插件如RocketMQ自动更新缓存。这些策略有助于保障系统的稳定运行。
291 1
|
6天前
|
存储 消息中间件 缓存
Redis缓存技术详解
【5月更文挑战第6天】Redis是一款高性能内存数据结构存储系统,常用于缓存、消息队列、分布式锁等场景。其特点包括速度快(全内存存储)、丰富数据类型、持久化、发布/订阅、主从复制和分布式锁。优化策略包括选择合适数据类型、设置过期时间、使用Pipeline、开启持久化、监控调优及使用集群。通过这些手段,Redis能为系统提供高效稳定的服务。
|
6天前
|
存储 缓存 监控
利用Redis构建高性能的缓存系统
在现今高负载、高并发的互联网应用中,缓存系统的重要性不言而喻。Redis,作为一款开源的、内存中的数据结构存储系统,它可以用作数据库、缓存和消息代理。本文将深入探讨Redis的核心特性,以及如何利用Redis构建高性能的缓存系统,并通过实际案例展示Redis在提升系统性能方面的巨大潜力。