// 1. Create config object Config config = new Config(); config.useSingleServer().setAddress("redis://localhost:6379").setPassword(yourPass);

// 2. Create datasource DefaultCacheDatasource datasource = new DefaultCacheDatasource(); Map<String, CacheTemplate> dsMap = datasource.initialize(new HashMap<String, CacheKeeperConfig>() {{ put("ds1", new CacheKeeperConfig(config)); }}); Map<String, List<CacheTemplate>> dssMap = datasource.initializeMulti(new HashMap<String, List<CacheKeeperConfig>>() {{ put("ds2", Collections.singletonList(new CacheKeeperConfig(config))); }});

// 3. Create datasource provider CacheTemplateProvider<CacheTemplate> provider = new CacheTemplateProvider<>(dsMap, dssMap);

// 4. Get redis template Optional<CacheTemplate> templateOptional = provider.getTemplate("ds1"); final CacheTemplate cacheTemplate = templateOptional.get(); cacheTemplate.set("foo", "bar"); // or get the read and write state of the cacheTemplate Optional<CacheTemplate> templateOptionalRW = provider.getTemplate("ds1", CacheDatasourceStatus.RW); // or get multiple cacheTemplates Collection<CacheTemplate> cacheTemplates = provider.getTemplates("ds2"); // or load balanced polling to get cacheTemplate from multiple data sources Optional<CacheTemplate> polledTemplate = provider.pollTemplate("ds2"); // or randomize cacheTemplate from multiple data sources Optional<CacheTemplate> randomedTemplate = provider.randomTemplate("ds2");

<dependency>	<groupId>org.codeba</groupId>	<artifactId>redis-keeper-spring-boot-starter</artifactId>	<version>2024.2.3</version> </dependency>

@SpringBootTest public class AppTest { @Autowired private CacheTemplateProvider<CacheTemplate> provider; @Test public void test() { String key = "foo"; String value = "bar"; final CacheTemplate cacheTemplate = provider.getTemplate("ds1").get(); // set cacheTemplate.set(key, value); cacheTemplate.setObject(key, value); // get cacheTemplate.get(key); cacheTemplate.getObject(key); cacheTemplate.getLong(key); cacheTemplate.getDouble(key); // incr cacheTemplate.incr(key); // set get bit cacheTemplate.setBit(key, 7, true); cacheTemplate.getBit(key, 7); // del exists expire ttl unlink cacheTemplate.del(key); cacheTemplate.exists(key); cacheTemplate.expire(key, 10, TimeUnit.SECONDS); cacheTemplate.expireAt(key, System.currentTimeMillis()); cacheTemplate.ttl(key); cacheTemplate.unlink(key); // geo cacheTemplate.geoAdd(key, 13.361389, 38.115556, "Sicily"); cacheTemplate.geoAdd(key, 15.087269, 37.502669, "Palermo"); cacheTemplate.geoDist(key, "Sicily", "Palermo", "km"); // hash cacheTemplate.hSet(key, "field1", value); cacheTemplate.hGet(key, "field1"); // hyberloglog cacheTemplate.pfAdd(key, Arrays.asList("a")); cacheTemplate.pfCount(key); // list cacheTemplate.rPush(key, "world", "hello"); cacheTemplate.lRange(key, 0, -1); // set cacheTemplate.sAdd(key, "hello"); cacheTemplate.sAdd(key, "world"); cacheTemplate.sAdd(key, "world"); cacheTemplate.sMembers(key); // zset cacheTemplate.zAdd(key, 1, "one"); cacheTemplate.zAdd(key, 2, "two"); cacheTemplate.zAdd(key, 3, "three"); cacheTemplate.zRange(key, 0, -1); // bloom filter cacheTemplate.bfReserve(key, 1000, 0.01); cacheTemplate.bfAdd(key, "item1"); cacheTemplate.bfAdd(key, "item1"); cacheTemplate.bfExists(key, "item2"); // lock cacheTemplate.tryLock(key, 3, TimeUnit.SECONDS); cacheTemplate.unlock(key); cacheTemplate.forceUnlock(key); // rate limiter cacheTemplate.trySetRateLimiter(key, 100, 1); cacheTemplate.tryAcquire(key); cacheTemplate.tryAcquire(key, 10); // pipeline execute cacheTemplate.pipeline(kBatch -> { kBatch.getString().setAsync(key, "bar"); kBatch.getGeo().geoAddAsync(key, 13.361389, 38.115556, "Sicily"); kBatch.getList().llenAsync(key); }); // pipeline execute and get response final List<?> responses = cacheTemplate.pipelineWithResponses(kBatch -> { kBatch.getString().setAsync(key, "bar"); kBatch.getGeo().geoAddAsync(key, 13.361389, 38.115556, "Sicily"); kBatch.getList().llenAsync(key); }); // pipeline execute async final CompletableFuture<Void> voidCompletableFuture = cacheTemplate.pipelineAsync(kBatch -> { kBatch.getString().setAsync(key, "bar"); kBatch.getGeo().geoAddAsync(key, 13.361389, 38.115556, "Sicily"); kBatch.getList().llenAsync(key); }); // pipeline execute and get response async final CompletableFuture<List<?>> listCompletableFuture = cacheTemplate.pipelineWithResponsesAsync(kBatch -> { kBatch.getString().setAsync(key, "bar"); kBatch.getGeo().geoAddAsync(key, 13.361389, 38.115556, "Sicily"); kBatch.getList().llenAsync(key); }); } }

<dependency>	<groupId>org.codeba</groupId>	<artifactId>redis-keeper-spring-boot-starter</artifactId>	<version>2024.2.3</version> </dependency>

import org.codeba.redis.keeper.support.CacheKeeperConfig; import org.codeba.redis.keeper.support.DefaultRedissonTemplate; public class MyCacheTemplate extends DefaultRedissonTemplate implements CacheTemplate { public MyCacheTemplate(CacheKeeperConfig cacheKeeperConfig) { super(cacheKeeperConfig); } public void test() { final RedissonClient redissonClient = getDataSource(); redissonClient.someMehotd(); System.out.println("hello world"); } }

import org.codeba.redis.keeper.support.CacheDatasource; import org.codeba.redis.keeper.support.CacheKeeperConfig; public class MyCacheDatasource implements CacheDatasource<MyCacheTemplate> { @Override public MyCacheTemplate instantTemplate(CacheKeeperConfig config) { return new MyCacheTemplate(config); } }

import org.codeba.redis.keeper.support.CacheDatasource; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class MyConfiguration { @Bean public CacheDatasource<MyCacheTemplate> cacheDatasource() { return new MyCacheDatasource(); } }

@SpringBootTest public class AppTest { @Autowired private CacheTemplateProvider<MyCacheTemplate> myProvider; @Test public void testMyProvider() { final Optional<MyCacheTemplate> templateOptional = myProvider.getTemplate("ds1"); if (templateOptional.isPresent()) { final MyCacheTemplate cacheTemplate = templateOptional.get(); // Custom Methods cacheTemplate.test(); } } }

<dependency>	<groupId>org.codeba</groupId>	<artifactId>redis-keeper-spring-boot-starter</artifactId>	<version>2024.2.3</version> </dependency>

import org.codeba.redis.keeper.support.CacheDatasource; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class MyConfiguration { @Bean public CacheDatasource<CacheTemplate> cacheDatasource() { return new DefaultCacheDatasource(){ @Override public Consumer<CacheKeeperConfig> configPostProcessor(Consumer<CacheKeeperConfig> consumer) { return v -> v.getConfig().setCodec(new JsonJacksonCodec()); } }; } }