- hambomb-cache是基于spring开发的业务层缓存框架
- hambomb-cache采用预加载的方式在应用启动时将需要的缓存加载到缓存中。
- hambomb-cache可以通过配置实现多种部署方式，也可以支持多种缓存模式。
用于开发的本地方式和简单应用下的单机部署方式。
用于应用多实例集群部署。
用于复杂情况下，本机+分布式缓存的模式。
全量加载需要缓存的数据，支持单机和集群模式。
增量加载从某个时间点未及时加载到分布式缓存中的数据和操作，支持集群模式。
- Guava Cache
适合单机开发情况下。
- Caffeine Cache
适合单机部署的简单应用场景。
- Redis
- Tair--暂时不支持
可根据实际情况定义属于自己的存储模式,支持本地内存、Redis、Tari之外的方式。
- 本地策略
- Redis策略
- 排列
- 组合
- 默认
- 实现CacheObjectMapper接口。
- 使用@CacheKey描述缓存对象的查询key。
@Mapper
public interface PersonSelfMapper extends CacheObjectMapper<Person> {
@Select("select id,name,gender,age,height,weight,cardId,address " +
"from t_person ")
@Cachekey(findKeys = {"cardId"})
@Override
List<Person> selectAllCacheObject();
}
- 在查询被缓存数据的时候使用，被标识的方法在执行原逻辑之前会先查询缓存。
- 如果命中直接将缓存数据返回。
- 如果未命中则查询数据库，并将数据缓存到缓存中。
@PreGetProcess(args = {"#0"})
public Person getPersonByCardId(String cardId) {
return personMapper.selectByCardId(cardId);
}
- 在更新被缓存数据的时候使用，被标识的方式在执行原逻辑之前会将更新的数据刷新到缓存中。
@AfterUpdateProcess
public void modifyAddressById(Person modifyPerson) {
personMapper.updateAddressById(modifyPerson.getId(),modifyPerson.getAddress());
}
- 在删除被缓存数据的时候使用，被标识的方式在执行原逻辑之后会将删除的数据从缓存中删除。
@AfterDeleteProcess(cacheObjectClass = Person.class)
public void deletePersonById(Long id) {
personMapper.deleteById(id);
}
- 在追加被缓存数据时使用，被标识的方法在执行原逻辑之后会将新增的数据刷新到缓存中。
@AfterInsertProcess
public void insertPerson(Person person) {
personMapper.insert(person);
}
- 本地JVM内存模式
@org.springframework.context.annotation.Configuration
@ComponentScan(basePackages = {"org.hambomb.cache"})
public class LocalDevelopConfig {
@Bean
public HambombCacheConfiguration hambombCacheConfig() {
HambombCacheConfiguration hambombCacheConfiguration = new HambombCacheConfiguration();
hambombCacheConfiguration.addScanPackageName("org.hambomb.cache.examples.mapper");
hambombCacheConfiguration.addCacheServerStrategy(CacheServerStrategy.DEVELOP);
return hambombCacheConfiguration;
}
@Bean
@Autowired
public HambombCache hambombCache(HambombCacheConfiguration hambombCacheConfiguration) {
HambombCache hambombCache = new HambombCache(hambombCacheConfiguration);
return hambombCache;
}
}
- 分布式缓存-redis
@Configuration
@ComponentScan(basePackages = {"org.hambomb.cache"})
public class RedisClusterConfig {
@Bean
public RedisConnectionFactory redisConnectionFactory() {
return new LettuceConnectionFactory(new RedisStandaloneConfiguration("localhost", 6379));
}
@Bean
@Autowired
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(factory);
template.setEnableDefaultSerializer(false);
template.setValueSerializer(new KryoSerializationRedisSerializer());
template.setKeySerializer(new KryoSerializationRedisSerializer<>());
// template.setDefaultSerializer(new KryoSerializationRedisSerializer());
// template.setHashValueSerializer(new KryoSerializationRedisSerializer());
template.afterPropertiesSet();
return template;
}
@Bean
@Autowired
public HambombCacheConfiguration hambombCacheConfig(RedisTemplate<String, Object> redisTemplate) {
HambombCacheConfiguration hambombCacheConfiguration = new HambombCacheConfiguration();
hambombCacheConfiguration.addScanPackageName("org.hambomb.cache.examples.mapper");
hambombCacheConfiguration.addZKUrl("localhost:2181");
hambombCacheConfiguration.addKeyGeneratorStrategy(new RedisKeyGeneratorStrategy());
hambombCacheConfiguration.addCacheServerStrategy(CacheServerStrategy.CLUSTER);
hambombCacheConfiguration.redisTemplate = redisTemplate;
return hambombCacheConfiguration;
}
@Bean
@Autowired
public HambombCache hambombCache(HambombCacheConfiguration hambombCacheConfiguration) {
HambombCache hambombCache = new HambombCache(hambombCacheConfiguration);
return hambombCache;
}
}
- 使用@EnableHambombCache标注Springboot启动类
@SpringBootApplication
@EnableHambombCache
@MapperScan(basePackages = {"org.hambomb.cache.examples.mapper"})
public class AutoConfigApplication {
public static void main(String[] args) {
SpringApplication.run(AutoConfigApplication.class, args);
}
}
- 在配置文件中描述具体配置
hambomb:
cache:
cacheServerStrategy: cluster
zkUrl: localhost:2181
scanPackageName: org.hambomb.cache.examples.mapper,org.hambomb.cache.examples.mapper
dataLoadStrategy: full
更多的例子见工程中的例子工程。