SpringBoot怎么整合SpringDataRedis

SpringBoot整合SpringDataRedis

1.创建项目添加依赖

创建SpringBoot项目，并添加如下依赖:org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-data-redisorg.springframework.bootspring-boot-starter-testtestredis.clientsjedis2.9.01 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23

2.设置application.properties文件

spring.redis.jedis.pool.max-idle=10 spring.redis.jedis.pool.min-idle=5 spring.redis.pool.max-total=20 spring.redis.hostName=192.168.88.120 spring.redis.port=6379 1 2 3 4 5

3.添加Redis的配置类

添加Redis的java配置类，设置相关的信息。

/*** @program:springboot-redis-demo* @description: Redis的配置类* @author: 波波烤鸭* @create: 2019-05-20 23:40*/@Configuration public class RedisConfig {/*** 1.创建JedisPoolConfig对象。在该对象中完成一些链接池配置* @ConfigurationProperties:会将前缀相同的内容创建一个实体。

*/@Bean@ConfigurationProperties(prefix=”spring.redis.pool”) public JedisPoolConfig jedisPoolConfig(){JedisPoolConfig config = new JedisPoolConfig();/*//最大空闲数config.setMaxIdle(10);//最小空闲数config.setMinIdle(5);//最大链接数config.setMaxTotal(20);*/ System.out.println(“默认值：”+config.getMaxIdle());System.out.println(“默认值：”+config.getMinIdle());System.out.println(“默认值：”+config.getMaxTotal());return config;}/*** 2.创建JedisConnectionFactory：配置redis链接信息*/@Bean@ConfigurationProperties(prefix=”spring.redis”) public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig config){System.out.println(“配置完毕：”+config.getMaxIdle());System.out.println(“配置完毕：”+config.getMinIdle());System.out.println(“配置完毕：”+config.getMaxTotal());JedisConnectionFactory factory = new JedisConnectionFactory();//关联链接池的配置对象factory.setPoolConfig(config);//配置链接Redis的信息//主机地址/*factory.setHostName(“192.168.70.128”);//端口factory.setPort(6379);*/ return factory;}/*** 3.创建RedisTemplate:用于执行Redis操作的方法*/@Bean public RedisTemplate redisTemplate(JedisConnectionFactory factory){RedisTemplate template = new RedisTemplate<>();//关联template.setConnectionFactory(factory);//为key设置序列化器template.setKeySerializer(new StringRedisSerializer());//为value设置序列化器template.setValueSerializer(new StringRedisSerializer());return template;}}1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67

4.添加pojo

/*** @program: springboot-redis-demo* @description: Users* @author: 波波烤鸭* @create: 2019-05-20 23:47*/ public class Users implements Serializable {private Integer id;private String name;private Integer age;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}@Override public String toString() {return “Users [id=” + id + “, name=” + name + “, age=” + age + “]”;}}1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35

5.单元测试

@RunWith(SpringRunner.class)@SpringBootTest(classes = SpringbootRedisDemoApplication.class) public class SpringbootRedisDemoApplicationTests {@Autowired private RedisTemplate redisTemplate;/*** 添加一个字符串*/@Test public void testSet(){this.redisTemplate.opsForValue().set(“key”, “bobokaoya…”);}/*** 获取一个字符串*/@Test public void testGet(){String value = (String)this.redisTemplate.opsForValue().get(“key”);System.out.println(value);}/*** 添加Users对象*/@Test public void testSetUesrs(){Users users = new Users();users.setAge(20);users.setName(“张三丰”);users.setId(1);//重新设置序列化器this.redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());this.redisTemplate.opsForValue().set(“users”, users);}/*** 取Users对象*/@Test public void testGetUsers(){//重新设置序列化器this.redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());Users users = (Users)this.redisTemplate.opsForValue().get(“users”);System.out.println(users);}/*** 基于JSON格式存Users对象*/@Test public void testSetUsersUseJSON(){Users users = new Users();users.setAge(20);users.setName(“李四丰”);users.setId(1);this.redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Users.class));this.redisTemplate.opsForValue().set(“users_json”, users);}/*** 基于JSON格式取Users对象*/@Test public void testGetUseJSON(){this.redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Users.class));Users users = (Users)this.redisTemplate.opsForValue().get(“users_json”);System.out.println(users);}}