SpringBoot整合SpringDataRedis的示例代碼
本文介紹下SpringBoot如何整合SpringDataRedis框架的,SpringDataRedis具體的內容在前面已經介紹過瞭,可自行參考。
1.創建項目添加依賴
創建SpringBoot項目,並添加如下依賴:
<dependencies> <!-- springBoot 的啟動器 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- Spring Data Redis 的啟動器 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</version> </dependency> </dependencies>
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
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<String,Object> redisTemplate(JedisConnectionFactory factory){ RedisTemplate<String, Object> template = new RedisTemplate<>(); //關聯 template.setConnectionFactory(factory); //為key設置序列化器 template.setKeySerializer(new StringRedisSerializer()); //為value設置序列化器 template.setValueSerializer(new StringRedisSerializer()); return template; } }
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 + "]"; } }
5.單元測試
@RunWith(SpringRunner.class) @SpringBootTest(classes = SpringbootRedisDemoApplication.class) public class SpringbootRedisDemoApplicationTests { @Autowired private RedisTemplate<String, Object> 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); } }
到此這篇關於SpringBoot整合SpringDataRedis的示例代碼的文章就介紹到這瞭,更多相關SpringBoot整合SpringDataRedis內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- springboot 集成redis哨兵主從的實現
- SpringBoot集成Redis並實現主從架構的實踐
- SpringBoot整合RedisTemplate實現緩存信息監控
- JAVA中 redisTemplate 和 jedis的配合使用操作
- Java與SpringBoot對redis的使用方式