Java与SpringBoot对redis的使用方式
作者:青柠果 发布时间:2021-06-11 19:23:39
标签:Java,redis,使用
1.Java连接redis
redis支持哪些语言可以操作 (去redis官网查询)
1.1 使用Jedis
(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();
}
}
1.2 使用连接池连接redis
@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));
}
1.3 java连接redis集群模式
连接集群时要保证集群里面没有存值, 要是存值需要删除之前生成的文件(注意删除干净)
还有就是放行对应的端口: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();
}
2.SpringBoot整合redis
springboot对redis的操作封装了两个StringRedisTemplate和RedisTemplate类,StringRedisTemplate是RedisTemplate的子类,StringRedisTemplate它只能存储字符串类型,无法存储对象类型。要想用StringRedisTemplate存储对象必须把对象转为json字符串。
springboot整合redis时提供了两个模板工具类,StringRedisTemplate和RedisTemplate。
2.1 StringRedisTemplate
(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);
}
2.2 RedisTemplate
此处会有乱码,因为它序列化方式和反序列化方式默认为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;
}
}
来源:https://blog.csdn.net/qq_50896786/article/details/126111148
0
投稿
猜你喜欢
- 上篇文章介绍了Spring boot初级教程:spring boot(一):入门篇,方便大家快速入门、了解实践Spring boot特性;本
- SpringBoot使用过滤器、 * 和 * 一、SpringBoot使用过滤器Spring boot过滤器的使用(两种方式)使用sprin
- 本文为大家分享了java多线程的简单实现及线程池实例,供大家参考,具体内容如下一、多线程的两种实现方式1、继承Thread类的多线程/**
- 本文实例讲述了Java数组的定义、初始化、及二维数组用法。分享给大家供大家参考,具体如下:数组的定义1.数组是有序数据的集合,数组中的每个元
- 队列的定义:队列(Queue)是只允许在一端进行插入,而在另一端进行删除的运算受限的线性表。 (1)允许删除的一端称为队头(Fro
- 本文实例为大家分享了Java实现小型图书馆管理系统的具体代码,供大家参考,具体内容如下以下为小型图书馆管理系统模式图:模式总体概述:其中IB
- java 单例的五种实现方式及其性能分析序言在23种设计模式中,单例是最简单的设计模式,但是也是很常用的设计模式。从单例的五种实现方式中我们
- 错误内容:com.alibaba.druid.pool.GetConnectionTimeoutException: wait millis
- SpringBoot集成Mybatis时mybatis.mapper-locations和@MapperScan的作用1、mybatis.m
- 一个图片识别小工具,原先主要是识别以前公司的软件注册码截图里的数字和字母(每次要一个一个框复制出来粘贴到注册器里,很麻烦!),因为注册码出现
- MyBatis 获取子类的属性这里有个model类:基类public class user { pu
- //构造文件File类File f=new File(fileName);//判断是否为目录f.isDirectory();//获取目录下的
- 前言代码生成器,也叫逆向工程,是根据数据库里的表结构,自动生成对应的实体类、映射文件和接口。看到很多小伙伴在为数据库生成实体类发愁,现分享给
- 在Word文档中,超链接是指在特定文本或者图片中插入的能跳转到其他位置或网页的链接,它也是我们在编辑制作Word文档时广泛使用到的功能之一。
- 内存模型Flink可以使用堆内和堆外内存,内存模型如图所示:flink使用内存划分为堆内内存和堆外内存。按照用途可以划分为task所用内存,
- 气球状提示框的介绍和系统通知变化NotifyIcon控件表示系统右下角任务栏上的托盘图标,其ShowBalloonTip方法用于显示任务栏中
- 算法描述堆排序算法的描述如下:将待排序的数组调整为最大堆,此时未排序的长度 N 为数组的长度,调整的过程就是倒序将数组的
- Java中自动生成构造方法详解每个类在没有声明构造方法的前提下,会自动生成一个不带参数的构造方法,如果类一但声明有构造方法,就不会产生了.证
- 本文实例讲述了Java实现的微信图片处理工具类。分享给大家供大家参考,具体如下:现在 外面核心,图片文章比较少,看了拷贝代码,而用不了,用相
- 概述从今天开始, 小白我将带大家开启 Jave 数据结构 & 算法的新篇章.循环队列循环队列 (Circular Queue) 是一