今天小编给大家分享一下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进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。