Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Autowired
- private RedisTemplate redisTemplate;
- public void test() {
- String redisKey = "lock.foo";
- String value = "RUNNING";
- long expire = 20L;
- Boolean result = (Boolean) redisTemplate.execute((RedisCallback<Boolean>) connection -> {
- byte[] redisKeyBytes = redisTemplate.getKeySerializer().serialize(redisKey);
- byte[] valueBytes = redisTemplate.getValueSerializer().serialize(value);
- Expiration expiration = Expiration.from(expire, TimeUnit.SECONDS);
- return connection.set(redisKeyBytes, valueBytes, expiration, RedisStringCommands.SetOption.SET_IF_ABSENT);
- });
- System.out.println("result = " + result);
- }
- @Configuration
- public class RedisConfig {
- @Bean
- public RedisSerializer<String> keySerializer() {
- return new StringRedisSerializer();
- }
- @Bean
- public RedisSerializer<Object> valueSerializer() {
- return new GenericJackson2JsonRedisSerializer();
- }
- @Bean
- public RedisTemplate redisTemplate(RedisTemplate redisTemplate, RedisSerializer keySerializer, RedisSerializer valueSerializer) {
- //set key serializer
- redisTemplate.setKeySerializer(keySerializer);
- redisTemplate.setHashKeySerializer(keySerializer);
- //set value serializer
- redisTemplate.setValueSerializer(valueSerializer);
- redisTemplate.setHashValueSerializer(valueSerializer);
- return redisTemplate;
- }
- }
Add Comment
Please, Sign In to add comment