天天看点

优雅使用二级缓存,让查询接口支持万级并发

作者:javaroad

多级缓存实际上是在二级缓存的基础上,为了更好地提高系统的性能和可靠性,更适用于大型分布式系统的应用场景。

使用多级缓存的原因包括:

  1. 数据缓存分层:不同级别的缓存可以被用来缓存不同类型、不同频率访问的数据。在这种情况下,系统会先在本地缓存中寻找数据,如果找不到再到其他级别的缓存中查找,并最终到数据库中获取数据。这种方式可以更快地响应不同类型的请求,并且让处理分布式系统访问的数据变得更容易。
  2. 优化系统响应时间:多级缓存的分层结构使之非常适用于尽快响应用户数据请求的场景。对于访问频率较高的数据,缓存在更接近应用程序的本地缓存中,可以快速获取;对于访问频率较低的数据,存储在较远缓存层级上,直到有需要时才会访问;在最后一级缓存搜索失败后,才会从数据库中获取所需的数据。这种方式在响应时间方面非常优秀。
  3. 提高可靠性和容错性:多级缓存通常包括主缓存和备用缓存,如果主缓存挂了,系统会自动切换到备用缓存,保证系统正常运行,数据不会丢失。
  4. 降低资源开销:多级缓存可以大大降低系统资源的使用成本。将频繁访问的数据将存入低延迟、高效的本地缓存中,避免大量的RPC(远程过程调用)和数据库查询。

总的来说,多级缓存旨在提高系统的性能和可靠性,并降低资源利用率。在大规模、高计算量、分布式系统中使用多级缓存是必不可少的

Spring Boot是Spring Framework的增强版本,可以快速开发基于Spring的应用程序。在Spring Boot中使用Jetcache的二级缓存也是极为简单的。

下面是Spring Boot Jetcache二级缓存的用法:

  1. 添加Jetcache和Hazelcast的依赖

在pom.xml文件中添加Jetcache和Hazelcast的依赖。

<dependency>
    <groupId>com.alicp.jetcache</groupId>
    <artifactId>jetcache-starter-redis</artifactId>
    <version>2.5.3</version>
</dependency>
<dependency>
    <groupId>com.hazelcast</groupId>
    <artifactId>hazelcast-spring</artifactId>
    <version>4.1.1</version>
</dependency>
            
  1. 配置JetCache

在application.properties配置文件中添加JetCache的配置,来配置二级缓存。

# JetCache配置 jetcache.cacheType=default jetcache.default.local.expireAfterWrite=10m 
jetcache.default.local.expireAfterAccess=10m jetcache.default.local.limit=1000 
jetcache.default.local.nullable=true 
jetcache.default.local.keyConvertor=tiger.pathos.car.impl.JacksonKeyConvertor 
jetcache.default.remote.expireAfterWrite=10m 
jetcache.default.remote.expireAfterAccess=10m 
jetcache.default.remote.serializer=hazelcast 
jetcache.default.remote.addresses=localhost:5701
            

cacheType指定缓存提供者,默认为default。expireAfterWrite和expireAfterAccess表示写入时间和最后访问时间后的到期时间。limit为本地缓存大小。nullable表示是否缓存null值。keyConvertor指定使用的键值转换器。remote.serializer表示远程缓存使用的序列化器。remote.addresses指定远程缓存的地址。

  1. 使用注解添加缓存

在需要缓存处理的方法上使用JetCache提供的注解。

示例方法:

@Service
public class UserServiceImpl implements UserService {
 
    @Autowired
    private UserRepository userRepository;
 
    @Override
    @Cached(name = "userCache:", key = "#id", expire = 7200, cacheType = CacheType.BOTH)
    public User getUserById(Long id) {
        return userRepository.findById(id).orElse(null);
    }
}           

在这个示例中,使用@Cached注解将getUserById方法中的结果缓存。name即为缓存的名称,key为缓存的键值,expire为缓存过期的时间,cacheType即为缓存类型。

  1. 测试

使用Junit等测试框架编写测试用例,测试Spring Boot应用程序中的JetCache二级缓存是否成功启用,缓存是否生效。

@SpringBootTest
@RunWith(SpringRunner.class)
public class UserServiceImplTest {
   
    @Autowired
    private UserService userService;
    
    @Test
    public void testGetUserById() {
        Long id = 1L;
        User user = userService.getUserById(id);
        // TODO 测试缓存是否生效
    }
    
}           

至此,Spring Boot应用程序就已经成功使用了JetCache的二级缓存。

加群交流

继续阅读