SpringBoot如何使用redis
更新時間:2025年03月10日 10:02:55 作者:今天的接口寫完了嗎?
文章主要介紹了如何在Spring Boot項目中配置Redis并解決亂碼問題,同時提供了使用Redis操作不同類型數(shù)據(jù)(如String、List、Hash、Set、ZSet和Bitmap)的代碼示例
一、pom.xml
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies>
二、application.properties
# Redis服務(wù)器地址 spring.redis.host=192.168.11.84 # Redis服務(wù)器連接端口 spring.redis.port=6379 # Redis服務(wù)器連接密碼(默認(rèn)為空) spring.redis.password= # Redis數(shù)據(jù)庫索引(默認(rèn)為0) 共15個 spirng.redis.database=0 ## 連接超時時間(毫秒) spring.redis.timout=30000 # 連接池最大連接數(shù)(使用負(fù)值表示沒有限制) 默認(rèn) 8 spring.redis.lettuce.pool.max-active=8 # 連接池中的最大空閑連接 默認(rèn) 8 spring.redis.lettuce.pool.max-idle=8 # 連接池中的最小空閑連接 默認(rèn) 0 spring.redis.lettuce.pool.min-idle=1 #連接池中最大空閑等待時間,3s沒有活干的時候直接驅(qū)逐該鏈接 spring.redis.lettuce.pool.min-evicate-idle-time-millis=3000 # 連接池最大阻塞等待時間(使用負(fù)值表示沒有限制) 默認(rèn) -1 spring.redis.lettuce.pool.max-wait=-1
三、編寫一個配置類用于解決亂碼問題和對象真實的類型問題
package com.by.config; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; 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 java.net.UnknownHostException; @Configuration public class RedisConfig { @Bean @ConditionalOnMissingBean(name = "redisTemplate") public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException { RedisTemplate<Object, Object> template = new RedisTemplate<>(); template.setConnectionFactory(redisConnectionFactory); // key序列化方式 template.setKeySerializer(StringRedisSerializer.UTF_8); //Jackson2JsonRedisSerializer 序列化方式 來代替自來的jdk序列化方式,因為后者會亂碼 Jackson2JsonRedisSerializer jack = new Jackson2JsonRedisSerializer(Object.class); template.setValueSerializer(jack); template.setHashKeySerializer(StringRedisSerializer.UTF_8); template.setHashValueSerializer(jack); /** * 使用objeck設(shè)置對象的類型為真實的對象類型 而不是hsash */ ObjectMapper mapper=new ObjectMapper(); // 啟用默認(rèn)類型推理,將類型信息作為屬性寫入JSON // 就是把對象的全類名寫入json mapper.activateDefaultTyping(mapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL); // 將類型的信息作為屬性傳給json jack.setObjectMapper(mapper); return template; } }
四、代碼案例
4.1 model 準(zhǔn)備 因為有可能存對象
- Student.java
@Data @AllArgsConstructor @NoArgsConstructor @Builder public class Student implements Serializable { private Integer id; private String name; }
- Product.java
@Data @AllArgsConstructor @NoArgsConstructor @Builder public class Product implements Serializable { private Integer id; private String name; }
4.2 使用redis 操作string
@Slf4j @SpringBootTest class StringTest { /** * 使用redis 操作string */ @Autowired private StringRedisTemplate str; // 自動序列化,用 @Autowired報錯 @Resource(name ="redisTemplate") private RedisTemplate<String,Student> redisTemplate; private final String key ="zhouxingxing"; /** * 將對象序列化 不用手動將對象轉(zhuǎn)成字符串 */ @Test void m8() { // jdk 序列化 Student student = Student.builder().id(1).name("張三").build(); // JdkSerializationRedisSerializer serializer =new JdkSerializationRedisSerializer(); // byte[] serialize = serializer.serialize(student); // String s=new String(serialize); // s亂碼 redisTemplate.opsForValue().set("student", student); Student student1 = redisTemplate.opsForValue().get("student"); System.out.println(student1.getName()); } /** * string里的get set 方法 */ @Test void m1() { str.opsForValue().set("xiaolong", "帥呆了"); String xiaolong = str.opsForValue().get("xiaolong"); log.info("xiaolong:{}", xiaolong); } /** * string里的strlen 方法 * append 方法:追加字符串 */ @Test void m2() { str.opsForValue().set("xiaolong", "帥呆了"); String xiaolong = str.opsForValue().get("xiaolong"); log.info("xiaolong:{}", xiaolong); // 追加字符串 str.opsForValue().append("xiaolong", "哈哈"); // 獲取長度 Long size = str.opsForValue().size("xiaolong"); log.info("長度為:{}", size);//15 } /** * string里的incr 方法 * incrBy 方法:增加指定值 */ @Test void m3() { str.opsForValue().set("xiaolong", "100"); Long xiaolong = str.opsForValue().decrement("xiaolong", 2); log.info("xiaolong:{}", xiaolong); //98 } /** * 將student 對象存到redis 里 * JSONUtil.toJsonStr(對象)--->將對象轉(zhuǎn)成序列化的json字符串 */ @Test void m4() { Student student = Student.builder().id(1).name("張三").build(); str.opsForValue().set("student", JSONUtil.toJsonStr(student)); log.info("student:{}", str.opsForValue().get("student"));//student:{"id":1,"name":"張三"} } @Test public void m7() { str.opsForHash().put(key,"20220325","鄭州"); str.opsForHash().put(key,"20220326","洛陽"); // 拿到所有小key的值 List<Object> values = str.opsForHash().values(key); for (Object value : values) { System.out.println(value); } }
4.3 使用redis 操作list
@SpringBootTest @Slf4j public class ListTest { @Autowired private StringRedisTemplate redisTemplate; private final String key = "xiaolong"; /** * 給list左推元素和又推元素 * 從右方刪除元素并返回刪除的元素 */ @Test void m1() { redisTemplate.opsForList().leftPush(key, "g1"); redisTemplate.opsForList().leftPush(key, "g2"); redisTemplate.opsForList().leftPush(key, "g3"); redisTemplate.opsForList().rightPush(key, "g4");//順序為 g3 g2 g1 g4 // 從右邊刪除元素 并返回刪除的元素 String s = redisTemplate.opsForList().rightPop(key); log.info("刪除元素為:{}", s);// g4 } @Test public void m2() { List<Object> obj = redisTemplate.executePipelined((RedisCallback<Object>) connection -> { //隊列沒有元素會阻塞操作,直到隊列獲取新的元素或超時 return connection.bLPop(600, "list1".getBytes()); }, new StringRedisSerializer()); for (Object str : obj) { System.out.println(str); } }
4.4 使用redis 操作hash
@Slf4j @SpringBootTest public class HashTest { @Autowired private StringRedisTemplate redisTemplate; // 自動序列化 @Resource(name ="redisTemplate") private RedisTemplate<String, Student> redisTemplate1; // 設(shè)置大key private final String key = "xiaolong"; @Test void m10() { Student student = Student.builder().id(1).name("張三").build(); redisTemplate1.opsForHash().put(key, "g1", student); Object o = redisTemplate1.opsForHash().get(key, "g1"); } // 設(shè)置商品黑名單 @Test public void m9() { Product p1 = Product.builder().id(1).name("華為").build(); Product p2 = Product.builder().id(2).name("小米").build(); redisTemplate1.opsForHash().put("黑名單","名單列表1",p1); redisTemplate1.opsForHash().put("黑名單","名單列表2",p2); } /** * 獲取大key里所有小key的值 */ @Test public void m1() { redisTemplate.opsForHash().put(key, "g1", "小芳"); redisTemplate.opsForHash().put(key, "g2", "小紅"); // 拿到所有小key的值 List<Object> values = redisTemplate.opsForHash().values(key); for (Object value : values) { log.info("所有小key的值為:"+value); } }
4.5 使用redis 操作set
@SpringBootTest @Slf4j public class SetTest { @Autowired private StringRedisTemplate redisTemplate; private final String xiaoming = "xiaoming"; private final String xiaohong = "xiaohong"; @Test// 交集 void m1() { // 添加小明同學(xué)感興趣的學(xué)科 redisTemplate.opsForSet().add(xiaoming, "語文", "數(shù)學(xué)","物理"); // 添加小紅同學(xué)感興趣的學(xué)科 redisTemplate.opsForSet().add(xiaohong, "語文", "英語"); // 獲取兩位同學(xué)共同感興趣的學(xué)科 Set<String> tong = redisTemplate.opsForSet().intersect(xiaohong, xiaoming); for (String s : tong) { log.info("小明和小紅共同感興趣的學(xué)科為:"+s);// 語文 } } @Test//并集 void m2() { // 添加小明同學(xué)感興趣的學(xué)科 redisTemplate.opsForSet().add(xiaoming, "語文", "數(shù)學(xué)","物理"); // 添加小紅同學(xué)感興趣的學(xué)科 redisTemplate.opsForSet().add(xiaohong, "語文", "英語"); // 獲取兩位同學(xué)共同感興趣的學(xué)科 Set<String> tong = redisTemplate.opsForSet().union(xiaohong, xiaoming); for (String s : tong) { log.info("小明和小紅共同感興趣的學(xué)科為:"+s);// 語文 } }
4.6 使用redis 操作zset
@SpringBootTest @Slf4j public class ZsetTest { @Autowired private StringRedisTemplate redisTemplate; @Resource(name = "redisTemplate") private RedisTemplate<String, Integer> redisTemplate1; private String key = "xiaolong"; /** * zset有序集合唯一 去重 適用于今日頭條和熱搜 * 給xiaolong 添加三門得成績 */ @Test public void m1() { redisTemplate.opsForZSet().add(key, "語文", 90); redisTemplate.opsForZSet().add(key, "數(shù)學(xué)", 100); redisTemplate.opsForZSet().add(key, "英語", 80); Long aLong = redisTemplate.opsForZSet().zCard(key); log.info("{科目數(shù)量為:}", aLong); // 獲取xiaolong的最高分 spring 沒有給我們封裝 redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection connection) throws DataAccessException { return connection.bLPop(5, key.getBytes()); } }); }
4.7 Redis 操作BitMap
@Component public class BitMapDemo { @Autowired private StringRedisTemplate stringRedisTemplate; private final String key ="sign#2022#zhouxingxing"; public void test(){ //設(shè)置簽到 stringRedisTemplate.opsForValue().setBit(key,2,true); stringRedisTemplate.opsForValue().setBit(key,85,true); //獲取周星星同學(xué)的簽到天數(shù) RedisCallback<Long> callback = connection -> { return connection.bitCount(key.getBytes(),0,365);}; Long count = stringRedisTemplate.execute(callback); //打印周星星2022年簽到天數(shù) System.out.println("周星星2022年一共簽到天數(shù):"+count); } }
總結(jié)
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
淺試仿?mapstruct實現(xiàn)微服務(wù)編排框架詳解
這篇文章主要為大家介紹了淺試仿?mapstruct實現(xiàn)微服務(wù)編排框架詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-08-08SpringBoot實現(xiàn)點餐系統(tǒng)的登錄與退出功能流程詳解
結(jié)束了Springboot+MyBatisPlus也是開始了項目之旅,將從后端的角度出發(fā)來整理這個項目中重點業(yè)務(wù)功能的梳理與實現(xiàn)2022-10-10Java中double和float類型的區(qū)別與使用方法
float和double都是用來表示浮點數(shù)的數(shù)據(jù)類型,但是它們之間有一些區(qū)別,這篇文章主要給大家介紹了關(guān)于Java中double和float類型的區(qū)別與使用方法的相關(guān)資料,需要的朋友可以參考下2024-07-07Springboot之restTemplate配置及使用方式
這篇文章主要介紹了Springboot之restTemplate配置及使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-04-04Spring Security實現(xiàn)自動登陸功能示例
自動登錄在很多網(wǎng)站和APP上都能用的到,解決了用戶每次輸入賬號密碼的麻煩。本文就使用Spring Security實現(xiàn)自動登陸功能,具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-11-11