当前位置:   article > 正文

Redis-SpringBoot整合_redistemplate.getconnectionfactory().getconnection

redistemplate.getconnectionfactory().getconnection

说明: 在 SpringBoot2.x 之后,原来使用的jedis 被替换为了 lettuce

jedis : 采用的直连,多个线程操作的话,是不安全的,如果想要避免不安全,使用 jedis pool 连接池! 更像 BIO 模式

lettuce : 采用 netty ,实例可以再多个线程中进行共享,不存在线程不安全的情况!可以减少线程数据了,更像 NIO 模式
 
源码分析:
  1. @Bean
  2. @ConditionalOnMissingBean(name = "redisTemplate") // 我们可以自己定义一个 redisTemplate来替换这个默认的!
  3. public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
  4. // 默认的 RedisTemplate 没有过多的设置,redis 对象都是需要序列化!
  5. // 两个泛型都是 Object, Object 的类型,我们后使用需要强制转换 <String, Object>
  6. RedisTemplate<Object, Object> template = new RedisTemplate<>();
  7. template.setConnectionFactory(redisConnectionFactory);
  8. return template;
  9. }
  10. @Bean
  11. @ConditionalOnMissingBean // 由于 String 是redis中最常使用的类型,所以说单独提出来了一个bean!
  12. public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
  13. StringRedisTemplate template = new StringRedisTemplate();
  14. template.setConnectionFactory(redisConnectionFactory);
  15. return template;
  16. }

整合测试 

1.倒入依赖

  1. <!-- 操作redis -->
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-data-redis</artifactId>
  5. </dependency>

2.配置连接

  1. # 配置redis
  2. spring.redis.host=127.0.0.1
  3. spring.redis.port=6379

3.测试

  1. @SpringBootTest
  2. class Redis02SpringbootApplicationTests {
  3. @Autowired private RedisTemplate redisTemplate;
  4. @Test void contextLoads() {
  5. // redisTemplate 操作不同的数据类型,api和我们的指令是一样的
  6. // opsForValue 操作字符串 类似String
  7. // opsForList 操作List 类似List
  8. // opsForSet
  9. // opsForHash
  10. // opsForZSet
  11. // opsForGeo
  12. // opsForHyperLogLog
  13. // 除了进本的操作,我们常用的方法都可以直接通过redisTemplate操作,比如事务,和基本的CRUD
  14. // 获取redis的连接对象
  15. // RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
  16. // connection.flushDb();
  17. // connection.flushAll();
  18. redisTemplate.opsForValue().set("mykey","关注狂神说公众号");
  19. System.out.println(redisTemplate.opsForValue().get("mykey"));
  20. }
  21. }

自己编写一个RedisTemplate:也可以看我的另一个文章:https://blog.csdn.net/weixin_44141870/article/details/115671454

  1. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  2. import com.fasterxml.jackson.annotation.PropertyAccessor;
  3. import com.fasterxml.jackson.databind.ObjectMapper;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.data.redis.connection.RedisConnectionFactory;
  7. import org.springframework.data.redis.core.RedisTemplate;
  8. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  9. import org.springframework.data.redis.serializer.StringRedisSerializer; @Configuration
  10. public class RedisConfig {
  11. // 这是我给大家写好的一个固定模板,大家在企业中,拿去就可以直接使用!
  12. // 自己定义了一个 RedisTemplate
  13. @Bean
  14. @SuppressWarnings("all")
  15. public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory){
  16. // 我们为了自己开发方便,一般直接使用 <String, Object>
  17. RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
  18. template.setConnectionFactory(factory);
  19. // Json序列化配置
  20. Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  21. ObjectMapper om = new ObjectMapper();
  22. om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  23. om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  24. jackson2JsonRedisSerializer.setObjectMapper(om);
  25. // String 的序列化
  26. StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
  27. // key采用String的序列化方式
  28. template.setKeySerializer(stringRedisSerializer);
  29. // hash的key也采用String的序列化方式
  30. template.setHashKeySerializer(stringRedisSerializer);
  31. // value序列化方式采用jackson
  32. template.setValueSerializer(jackson2JsonRedisSerializer);
  33. // hash的value序列化方式采用jackson
  34. template.setHashValueSerializer(jackson2JsonRedisSerializer);
  35. template.afterPropertiesSet();
  36. return template;
  37. }
  38. }

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Monodyee/article/detail/152059
推荐阅读
相关标签
  

闽ICP备14008679号