从头开始学Redisson--------分布式集合之本地缓存映射(RLocalCachedMap)

x33g5p2x  于2021-12-28 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(716)

一、RLocalCachedMap本地缓存映射

       都说存在就是合理,上一节的分布式集合映射(RMap)已经实现了分布式情况下类似于Redis的hash功能。那为什么现在又冒出来一个本地缓存映射(RLocalCachedMap)呢?从代码的角度来看,本地缓存映射RLocalCachedMap继承了映射(RMap),因此就具备了RMap的所有功能。

public interface RLocalCachedMap<K, V> extends RMap<K, V> ...

      我们知道,热点数据绝大多数的情况都是查询,例如经典的查询字典表,也就是系统里的下拉框。我们完全可以把字典表的所有数据加入到缓存中,下次下拉框查询就直接查询缓存,不用再去查询数据库。我们只需要增加一个定时任务,定期把字典表的最新数据刷入缓存就可以了。

      既然都是查询,那么查询当然是越快越好。之前的缓存数据在RMap中,现在可以优化成使用本地缓存映射(RLocalCachedMap)。本地缓存映射的查询速度是RMap的45倍。一句话,本地缓存映射(RLocalCachedMap)的查询速度比映射(RMap)快的多。

      官方文档:
在特定的场景下,映射(RMap)上的高度频繁的读取操作,使网络通信都被视为瓶颈时,使用Redisson提供的带有本地缓存功能的分布式本地缓存映射RLocalCachedMapJava对象会是一个很好的选择。它同时实现了java.util.concurrent.ConcurrentMapjava.util.Map两个接口。本地缓存功能充分的利用了JVM的自身内存空间,对部分常用的元素实行就地缓存,这样的设计让读取操作的性能较分布式映射相比提高最多 45倍 。

官方示例:
RLocalCachedMap<String, Integer> map = redisson.getLocalCachedMap("test", options);

String prevObject = map.put("123", 1);
String currentObject = map.putIfAbsent("323", 2);
String obj = map.remove("123");

二、缓存字典表

       现有字典表如下。会有一个mapper把这几条数据全部查询出来,按照type类型进行分组。

       

        如下代码。先从数据库中将这6条数据全部查询出来,封装这6条数据到List<Parameter>中。然后对这6条数据根据type属性进行分组,会得到两个组,结果封装到Map<String,List<Parameter>>中。然后通过redisson#getLocalCacheMap拿到本地缓存映射(RLocalCachedMap),最后把分组结果加入到缓存中。

@RestController
@RequestMapping(value = "/redisson/map/parameter/")
public class RLocalCacheMapController {

    private static final Logger LOGGER = LoggerFactory.getLogger(RLocalCacheMapController.class);

    @Autowired
    private RedissonClient redisson;

    @Autowired
    private ParameterMapper mapper;

    @GetMapping(value = "/syn_cache")
    public List<Parameter> synCache() {
        LOGGER.info("同步缓存");
        List<Parameter> allParameter = mapper.getAll();
        if (CollectionUtils.isEmpty(allParameter)) {
            return CollectionUtils.emptyList();
        }
        //通过type进行分组
        Map<String, List<Parameter>> parameterGroupByType =
                allParameter.stream().collect(Collectors.groupingBy(Parameter::getType));

        //通过Redisson获取  本地映射缓存RLocalCachedMap
        RLocalCachedMap<String, List<Parameter>> localCacheMap =
                redisson.getLocalCachedMap(Constant.REDISSON_LOCAL_CACHE_MAP, 
                                                     LocalCachedMapOptions.defaults());
        //将分组的结果加入缓存
        LOGGER.info("分组结果加入本地缓存映射");
        localCacheMap.clear();
        localCacheMap.putAll(parameterGroupByType);

        return allParameter;
    }
}

       查询的话。通过type类型从本地缓存映射(RLocalCachedMap)中取数据。

@GetMapping(value = "/get")
    public List<Parameter> get(@RequestParam String type) {

        //获取本地缓存映射
        RLocalCachedMap<String, List<Parameter>> localCachedMap =
                redisson.getLocalCachedMap(Constant.REDISSON_LOCAL_CACHE_MAP, 
                                                        LocalCachedMapOptions.defaults());
        if (localCachedMap != null) {
            LOGGER.info("查询本地缓存映射");
            return localCachedMap.get(type);

        } else {
            LOGGER.info("本地缓存没有查询到数据,从数据库查询");
            return mapper.getAll();
        }
    }

       最终实现效果:


使用本地缓存映射(RLocalCachedMap)加快查询速度

相关文章