溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
今天小編給大家分享一下Java與SpringBoot對redis的使用方式是什么的相關知識點，內容詳細，邏輯清晰，相信大部分人都還太了解這方面的知識，所以分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后有所收獲，下面我們一起來了解一下吧。
redis支持哪些語言可以操作 （去redis官網查詢）
(1)添加jedis依賴
<dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <!--只能在測試類中使用--> <scope>test</scope> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.6.0</version> </dependency>
(2)代碼測試
public class TestJedis {
@Test
public void test01(){
//連接redis--必須保證你的redis服務運行遠程連接
//該對象把每個redis命令封裝成對應的方法
//注意端口號
//xshell中的redis要運行起來，注意防火墻釋放端口號，注意配置文件的修改
Jedis jedis=new Jedis("192.168.1.16",6379);
//對于字符串操作的命令
String set = jedis.set("k1", "v1");
System.out.println(set);
String set1 = jedis.set("k2", "v2");
System.out.println(set1);
String set2 = jedis.set("k3", "v3");
System.out.println(set2);
//對于hash的操作
jedis.hset("k4","name","小花");
Long hset = jedis.hset("k4", "age", "18");
System.out.println(hset);
Map<String ,String> map=new HashMap<>();
map.put("name","小明");
map.put("age","20");
Long k = jedis.hset("k5", map);
System.out.println(k);
jedis.close();
}
} @Test
public void test02(){
//創建連接池的配置類
JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
jedisPoolConfig.setMaxIdle(20);
jedisPoolConfig.setMinIdle(5);
jedisPoolConfig.setMaxWait(Duration.ofMillis(3000));
JedisPool jedisPool=new JedisPool(jedisPoolConfig,"192.168.1.16",6379);
long start = System.currentTimeMillis();
for (int i = 0; i < 1000; i++) {
//從jedis連接池獲取資源
Jedis jedis=jedisPool.getResource();
String ping = jedis.ping();
jedis.close();//是否關閉池子
}
long end=System.currentTimeMillis();
//是為了比較使用池子還是不使用快，結論是使用池子快
System.out.println("總耗時："+(end-start));
}連接集群時要保證集群里面沒有存值， 要是存值需要刪除之前生成的文件（注意刪除干凈）
還有就是放行對應的端口：6001、6002、6003、6004、6005、6006，因為之前放行的實在10000端口，注意以上兩點，才可以使用idea創建成功。
@Test
public void test03(){
Set<HostAndPort> nodes=new HashSet<>();
nodes.add(new HostAndPort("192.168.227.175",6001));
nodes.add(new HostAndPort("192.168.227.175",6002));
nodes.add(new HostAndPort("192.168.227.175",6003));
nodes.add(new HostAndPort("192.168.227.175",6004));
nodes.add(new HostAndPort("192.168.227.175",6005));
nodes.add(new HostAndPort("192.168.227.175",6006));
JedisCluster jedisCluster=new JedisCluster(nodes);
jedisCluster.set("k6", "小老虎和小兔子");
jedisCluster.close();
}
springboot對redis的操作封裝了兩個StringRedisTemplate和RedisTemplate類，StringRedisTemplate是RedisTemplate的子類，StringRedisTemplate它只能存儲字符串類型，無法存儲對象類型。要想用StringRedisTemplate存儲對象必須把對象轉為json字符串。
springboot整合redis時提供了兩個模板工具類，StringRedisTemplate和RedisTemplate。
(1) 引入相關的依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
(2)注入StringRedisTemplate該類對象
@Autowired private StringRedisTemplate redisTemplate;
(3)使用StringRedisTemplate
該類把對每種數據類型的操作，單獨封了相應的內部類。
此處不會有亂碼，因為已經給它序列化方式和反序列化方式換成為String型。
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
public void test01(){
//對hash類型的操作
HashOperations<String, Object, Object> forHash = stringRedisTemplate.opsForHash();
forHash.put("k1","name","張三");
forHash.put("k1","age","15");
Map<String,String> map=new HashMap<>();
map.put("name","李四");
map.put("age","25");
forHash.putAll("k36",map);
Object o = forHash.get("k1", "name");
System.out.println(o);
Set<Object> k1 = forHash.keys("k1");
System.out.println(k1);
List<Object> k11 = forHash.values("k1");
System.out.println(k11);
//獲取k1對于的所有的field和value
Map<Object, Object> k12 = forHash.entries("k1");
System.out.println(k12);
}
@Test
void contextLoads() {
//刪除指定的key
// stringRedisTemplate.delete("k");
//查看所有的key
//stringRedisTemplate.keys("k");
//是否存在指定的key
//stringRedisTemplate.hasKey("k");
//對字符串數據類型的操作ValueOperations
ValueOperations<String, String> forValue = stringRedisTemplate.opsForValue();
//存儲字符串類型--key value long uint setex()
forValue.set("k1","張三",30, TimeUnit.SECONDS);
//等價于setnx 存入成功返回true ,失敗返回false
Boolean absent = forValue.setIfAbsent("k11", "李四", 30, TimeUnit.SECONDS);
System.out.println(absent);
//append拼接
Integer append = forValue.append("k11", "真好看");
String k11 = forValue.get("k11");
System.out.println(k11);
}此處會有亂碼，因為它序列化方式和反序列化方式默認為JDK。
@SpringBootTest
class SbredisApplicationTests02 {
//當你存儲的value類型為對象類型使用redisTemplate
//存儲的value類型為字符串。StringRedisTemplate 驗證碼
@Autowired
private RedisTemplate redisTemplate;
@Test
public void test01(){
//必須認為指定序列化方式
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<Object>(Object.class));
//對String類型操作類
ValueOperations forValue = redisTemplate.opsForValue();
//redis中key和value都變成了亂碼
//key和value都沒有指定序列化方式，默認采用jdk的序列化方式
forValue.set("k1","張三");
//value默認采用jdk，類必須實現序列化接口
forValue.set("k44",new User(1,"haha",12));
}
}上面的RedisTemplate需要每次都指定key value以及field的序列化方式，能不能搞一個配置類，已經為RedisTemplate指定好序列化。以后再用就無需指定。
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
template.setConnectionFactory(factory);
//key序列化方式
template.setKeySerializer(redisSerializer);
//value序列化
template.setValueSerializer(jackson2JsonRedisSerializer);
//value hashmap序列化 filed value
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.setHashKeySerializer(redisSerializer);
return template;
}
}以上就是“Java與SpringBoot對redis的使用方式是什么”這篇文章的所有內容，感謝各位的閱讀！相信大家閱讀完這篇文章都有很大的收獲，小編每天都會為大家更新不同的知識，如果還想學習更多的知識，請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
