SpringBoot(spring-data-redis)物事へのサポート
4333 ワード
官文:https://docs.spring.io/spring-data/data-redis/docs/current/reference/html/#redis:template
RedisTemplateはmulti/exec/discardメソッドを提供するが、コードの前後でmultiとexecを直接呼び出すと異常(ERR EXEC without MULTI)が放出されることを理解する.公式呼び出しポーズについてお話しします.
Spring-data-redisは、物事のサポートに2つの方法を提供しています.
シナリオ1:redisTemplateを使用する.execute(callback...), callbackを実装することによって、1つのconnection内の操作のセットが実装される.
シナリオ2:springの事物注釈自動管理機能を用いて、以下のように実現する.
次にcontrollerで次のサービスを呼び出し、物事の効果を試して、redisで値が正常に設定されているかどうかを見ます.(老
RedisTemplateはmulti/exec/discardメソッドを提供するが、コードの前後でmultiとexecを直接呼び出すと異常(ERR EXEC without MULTI)が放出されることを理解する.公式呼び出しポーズについてお話しします.
Spring-data-redisは、物事のサポートに2つの方法を提供しています.
シナリオ1:redisTemplateを使用する.execute(callback...), callbackを実装することによって、1つのconnection内の操作のセットが実装される.
List
シナリオ2:springの事物注釈自動管理機能を用いて、以下のように実現する.
package com.demo.api.redis;
import java.nio.charset.Charset;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
/**
* @author tom
* redis
*/
@Configuration
@EnableTransactionManagement // :
public class RedisTemplateConfiguration {
@Bean
@Primary
public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
RedisTemplate redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(factory);
Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jacksonSeial.setObjectMapper(om);
redisTemplate.setValueSerializer(jacksonSeial);
redisTemplate.setKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(jacksonSeial);
//support transaction :
redisTemplate.setEnableTransactionSupport(true);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
// : bean, jdbc transactionManager
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) throws SQLException {
return new DataSourceTransactionManager(dataSource);
}
@Bean
public DataSource dataSource() {
return DruidDataSourceBuilder.create().build();
}
}
次にcontrollerで次のサービスを呼び出し、物事の効果を試して、redisで値が正常に設定されているかどうかを見ます.(老
package com.demo.api.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
public class RedisService {
@Autowired
private RedisTemplate redis;
@Transactional
public void testOk() {
redis.opsForValue().set("a", "aa");
redis.opsForValue().set("b", "cc");
}
@Transactional
public void testError() {
redis.opsForValue().set("d", "aa");
redis.opsForValue().set(null, "cc");//
redis.opsForValue().set("f", "cc");
}
}