spring boot:使用spring cache+caffeine做进程内缓存(本地缓存)(spring boot 2.3.1)

2021-04-14 09:27

阅读：369

标签：param home enum 应用服务 ase 清除情况 https 并保存

一，为什么要使用caffeine做本地缓存？

1,spring boot默认集成的进程内缓存在1.x时代是guava cache

在2.x时代更新成了caffeine,

功能上差别不大，但后者在性能上更胜一筹，

使用caffeine做本地缓存，取数据可以达到微秒的级别，

一次取数据用时经常不足1毫秒，

这样可以及时响应请求，在高并发的情况下把请求拦截在上游，

避免把压力带到数据库，

所以我们在应用中集成它对于系统的性能有极大的提升

2，与之相比，即使是本地的redis,

响应时间也比进程内缓存用时要更久，

而且在应用服务器很少有专门配备redis缓存的做法，

而是使用专门的redis集群做为分布式缓存

说明：刘宏缔的架构森林是一个专注架构的博客，地址：https://www.cnblogs.com/architectforest

对应的源码可以访问这里获取： https://github.com/liuhongdi/

说明：作者:刘宏缔邮箱: 371125307@qq.com

二，演示项目的相关信息

1,项目地址:

https://github.com/liuhongdi/caffeine

2,项目原理:

我们建立了两个cache:goods,goodslist

分别用来缓存单个商品详情和商品列表

3,项目结构:

如图:

技术图片

三，配置文件说明

1,pom.xml

        
        dependency>
            groupId>org.springframework.bootgroupId>
            artifactId>spring-boot-starter-cacheartifactId>
        dependency>
        dependency>
            groupId>com.github.ben-manes.caffeinegroupId>
            artifactId>caffeineartifactId>
            version>2.8.5version>
        dependency>

2,application.properties

#profile
spring.profiles.active=cacheable

这个值用来配置cache是否生效

我们在测试或调试时有时会用关闭缓存的需求

如果想关闭cache，把这个值改变一下即可

3,mysql的数据表结构：

CREATE TABLE `goods` (
 `goodsId` int(11) NOT NULL AUTO_INCREMENT COMMENT ‘id‘,
 `goodsName` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL DEFAULT ‘‘ COMMENT ‘name‘,
 `subject` varchar(200) NOT NULL DEFAULT ‘‘ COMMENT ‘标题‘,
 `price` decimal(15,2) NOT NULL DEFAULT ‘0.00‘ COMMENT ‘价格‘,
 `stock` int(11) NOT NULL DEFAULT ‘0‘ COMMENT ‘stock‘,
 PRIMARY KEY (`goodsId`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT=‘商品表‘

四，java代码说明

1,CacheConfig.java

@Profile("cacheable")   //这个当profile值为cacheable时缓存才生效
@Configuration
@EnableCaching //开启缓存
public class CacheConfig {
    public static final int DEFAULT_MAXSIZE = 10000;
    public static final int DEFAULT_TTL = 600;
    private SimpleCacheManager cacheManager = new SimpleCacheManager();

    //定义cache名称、超时时长（秒）、最大容量
    public enum CacheEnum{
        goods(600,3000),          //有效期600秒 , 最大容量3000
        goodslist(600,1000),  //有效期600秒 , 最大容量1000
        ;
        CacheEnum(int ttl, int maxSize) {
            this.ttl = ttl;
            this.maxSize = maxSize;
        }
        private int maxSize=DEFAULT_MAXSIZE;    //最大數量
        private int ttl=DEFAULT_TTL;        //过期时间（秒）
        public int getMaxSize() {
            return maxSize;
        }
        public int getTtl() {
            return ttl;
        }
    }

    //创建基于Caffeine的Cache Manager
    @Bean
    @Primary
    public CacheManager caffeineCacheManager() {
        ArrayList caches = new ArrayList();
        for(CacheEnum c : CacheEnum.values()){
            caches.add(new CaffeineCache(c.name(),
                    Caffeine.newBuilder().recordStats()
                            .expireAfterWrite(c.getTtl(), TimeUnit.SECONDS)
                            .maximumSize(c.getMaxSize()).build())
            );
        }
        cacheManager.setCaches(caches);
        return cacheManager;
    }

    @Bean
    public CacheManager getCacheManager() {
        return cacheManager;
    }
}

说明：根据CacheEnum这个enum的内容来生成Caffeine Cache,并保存到cachemanager中

如果需要新增缓存，保存到CacheEnum中

@Profile("cacheable"): 当spring.profiles.active的值中包括cacheable时cache才起作用，不包含此值时则cache被关闭不生效

@EnableCaching : 用来开启缓存

recordStats:记录统计数据

expireAfterWrite:在写入到达一定时间后过期

maximumSize:指定最大容量

2,GoodsServiceImpl.java

@Service
public class GoodsServiceImpl implements GoodsService {

    @Resource
    private GoodsMapper goodsMapper;

    //得到一件商品的信息
    @Cacheable(value = "goods", key="#goodsId",sync = true)
    @Override
    public Goods getOneGoodsById(Long goodsId) {
        System.out.println("query database");
        Goods goodsOne = goodsMapper.selectOneGoods(goodsId);
        return goodsOne;
    }

    //获取商品列表，只更新缓存
    @CachePut(value = "goodslist", key="#currentPage")
    @Override
    public Map putAllGoodsByPage(int currentPage) {
        Map res = getAllGoodsByPageDdata(currentPage);
        return res;
    }

    //获取商品列表，加缓存
    //@Cacheable(key = "#page+‘-‘+#pageSize") 多个参数可以用字符串连接起来
    @Cacheable(value = "goodslist", key="#currentPage",sync = true)
    @Override
    public Map getAllGoodsByPage(int currentPage) {
        Map res = getAllGoodsByPageDdata(currentPage);
        return res;
    }

    //从数据库获取商品列表
    public Map getAllGoodsByPageDdata(int currentPage) {
        System.out.println("-----从数据库得到数据");
        Map res = new HashMap();
        PageHelper.startPage(currentPage, 5);
        List goodsList = goodsMapper.selectAllGoods();
        res.put("goodslist",goodsList);
        PageInfo pageInfo = new PageInfo(goodsList);
        res.put("pageInfo",pageInfo);
        return res;
    }
}

说明:

@Cacheable(value = "goodslist", key="#currentPage",sync = true):

当缓存中存在数据时，则直接从缓存中返回,

如果缓存中不存在数据，则要执行方法返回数据后并把数据保存到缓存.

@CachePut(value = "goodslist", key="#currentPage"):

不判断缓存中是否存在数据，只更新缓存

3,HomeController.java

    //商品列表 参数:第几页
    @GetMapping("/goodslist")
    public String goodsList(Model model,
                            @RequestParam(value="p",required = false,defaultValue = "1") int currentPage) {
        Map res = goodsService.getAllGoodsByPage(currentPage);
        model.addAttribute("pageInfo", res.get("pageInfo"));
        model.addAttribute("goodslist", res.get("goodslist"));
        return "goods/goodslist";
    }

    //更新
    @ResponseBody
    @GetMapping("/goodslistput")
    public String goodsListPut(@RequestParam(value="p",required = false,defaultValue = "1") int currentPage) {
        Map res = goodsService.putAllGoodsByPage(currentPage);
        return "cache put succ";
    }

    //清除
    @CacheEvict(value="goodslist", allEntries=true)
    @ResponseBody
    @GetMapping("/goodslistevict")
    public String goodsListEvict() {
        return "cache evict succ";
    }

说明：

@CacheEvict(value="goodslist", allEntries=true)：用来清除goodslist中的缓存

4，StatsController.java

@Profile("cacheable")
@Controller
@RequestMapping("/stats")
public class StatsController {
    //统计，如果是生产环境，需要加密才允许访问
    @Resource
    private CacheManager cacheManager;

    @GetMapping("/stats")
    @ResponseBody
    public String stats() {
        CaffeineCache caffeine = (CaffeineCache)cacheManager.getCache("goodslist");
        Cache goods = caffeine.getNativeCache();
        String statsInfo="cache名字:goodslist
";
        Long size = goods.estimatedSize();
        statsInfo += "size:"+size+"
";
        ConcurrentMap map= goods.asMap();
        statsInfo += "map keys:
";
        for(Object key : map.keySet()) {
            statsInfo += "key:"+key.toString()+";value:"+map.get(key)+"
";
        }
        statsInfo += "统计信息:"+goods.stats().toString();
        return statsInfo;
    }
}

五，效果测试

1,访问地址:

http://127.0.0.1:8080/home/goodslist/?p=1

如图:

技术图片

刷新几次后，可以看到,在使用cache时:

costtime aop 方法doafterreturning:毫秒数:0

使用的时间不足1毫秒

2,查看统计信息,访问:

http://127.0.0.1:8080/stats/stats

如图:

技术图片

3,清除cache信息:

http://127.0.0.1:8080/home/goodslistevict

查看缓存的统计:

cache名字:goodslist
size:0
map keys:
统计信息:CacheStats{hitCount=1, missCount=3, loadSuccessCount=3, loadFailureCount=0, totalLoadTime=596345574, evictionCount=0, evictionWeight=0}

可以看到数据已被清空

六，查看spring boot的版本

  .   ____          _            __ _ _
 /\\ / ___‘_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | ‘_ | ‘_| | ‘_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  ‘  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v2.3.1.RELEASE)

spring boot:使用spring cache+caffeine做进程内缓存(本地缓存)(spring boot 2.3.1)

标签：param home enum 应用服务 ase 清除情况 https 并保存

原文地址：https://www.cnblogs.com/architectforest/p/13337171.html

上一篇：spring 注解实现自动装配

下一篇：java入门

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：spring boot:使用spring cache+caffeine做进程内缓存(本地缓存)(spring boot 2.3.1)
文章链接：http://soscw.com/index.php/essay/75601.html

亲，登录后才可以留言！

spring boot:使用spring cache+caffeine做进程内缓存(本地缓存)(spring boot 2.3.1)

一，为什么要使用caffeine做本地缓存？

二，演示项目的相关信息

三，配置文件说明

四，java代码说明

五，效果测试

六，查看spring boot的版本

评论

热门文章

推荐文章

最新文章

置顶文章