Redis的常用命令是我们操作Redis的基础,那么我们在Java程序当中如何来操作Redis呢?
像Jedis和Lettuce其实相对来说是比较底层的或者说比较原始的方式来操作,而Spring Data Redis它是Spirng家族的一个框架,对Redis底层的这两个开发包进行了高度的封装,在Spring项目当中,可以使用Spring Data Redis来简化操作。
Spring对Redis客户端进行了整合,提供了Spring Data Redis,在Spring Boot项目当中还提供了对应的 Starter,即spring-boot-starter-data-redis。
网址:https://spring.io/projects/spring-data-redis
操作步骤:
- 创建SpringBoot工程,勾选起步依赖:Lombok + Spring Web(Web开发的起步依赖) + Spring Data Redis(Acess+Driver) => 在NoSQL里面勾选
- 在application.yml中配置Redis的连接信息
- 在单元测试中,直接注入RedisTemplate对象
- 通过RedisTemplate对象操作Redis
- 因为在Spring Data Redis当中,它就给我们提供了一个操作Redis的一个模版对象:RedisTemplate,RedisTemplate为执行各种Redis操作、异常转换和序列化支持提供了高级抽象!Template - 模版
1. Spring Boot提供了对应的Starter,Maven坐标:引入spring-boot-starter-data-redis依赖
<!-- Redis的起步依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2. 在application.yml中配置Redis的连接信息:配置Redis数据源
# 配置Redis的连接信息
spring:
data:
redis:
host: 127.0.0.1
port: 6379
password: 123456
database: 0
lettuce是Java用来操作Redis的一个Jar包!
3. 在单元测试类当中注入RedisTemplate
Spring Data Redis中提供了一个高度封装的类:RedisTemplate,RedisTemplate针对大量相关的API进行了归类封装,将同一数据类型的操作封装为对应的Operation接口,具体分类如下:
ValueOperations:String数据操作
SetOperations:Set类型数据操作
ZSetOperations:ZSet类型数据操作
HashOperations:Hash类型的数据操作
ListOperations:List类型的数据操作
package com.gch;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import java.util.concurrent.TimeUnit;
@SpringBootTest
class SpringDataRedisQuickStartApplicationTests {
// 注入RedisTemplate对象
@Autowired
private RedisTemplate redisTemplate;
/**
* 往Redis当中写入String类型的数据并设置过期时间
* @param key
* @param value
* @param timeout Key的过期时间
* @return 返回写入的Value
*/
public Object setString(String key, Object value, Long timeout) {
// 往Redis当中写入String类型的数据
redisTemplate.opsForValue().set(key, value);
// 如果时限不为null
if (timeout != null) {
/**
* 则对该Key设置有效期 / 过期时间
* 补充:在Redis里面默认是会开启这个持久化机制的,相当于每个数据都会持久化到硬盘里面去的
* 每次把Redis当成数据库用:对Key不设置有效期,每次查询都会把它放在Redis里面(内存)
* 如果对Key不设置有效期,它就会一直存储在内存里面,而内存又是非常有限的,最终有一天会把内存撑爆
* 直接就导致Redis服务崩了,所以,注意事项:对我们的Redis的Key一定要去设置一个有效期
*/
redisTemplate.expire(key, timeout, TimeUnit.SECONDS);
}
// 获取写入的Value并返回
return redisTemplate.opsForValue().get(key);
}
@Test
public void testRedis() {
// 查找返回所有的Key,返回值是一个Set集合
System.out.println(redisTemplate.keys("*"));
// 往Redis当中写入String类型的数据
System.out.println("name = " + setString("name", "Redis", 1000L));
}
}
package com.gch.config;
import lombok.extern.slf4j.Slf4j;
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.StringRedisSerializer;
/**
* 声明当前类是一个配置类
* @Configuration里面封装了@Component,@Service里面封装的也是@Component
*/
@Slf4j
@Configuration
public class RedisConfig {
/**
* 自定义RedisTemplate
* @param redisConnectionFactory
* @return
*/
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
log.info("开始创建Redis模板对象....");
RedisTemplate<Object, Object> template = new RedisTemplate<>();
// 设置redis的连接工厂对象
template.setConnectionFactory(redisConnectionFactory);
/**
* 设置redis key的序列化器
* 指定大Key以及Hash中的小Key的序列化方式
* 建议只去设置Key的序列化范式,因为Value的形式多种多样,因为不同类型的数据它的序列化方式是不一样的
* 等价于template.setKeySerializer(RedisSerializer.string()); => 按照字符串的方式来序列化
*/
template.setKeySerializer(new StringRedisSerializer()); // 设置Key的序列化方式
template.setHashKeySerializer(new StringRedisSerializer()); // 设置Hash Key的序列化方式
return template;
}
}
/**
* 操作String字符串类型的数据
*/
@Test
void testString() {
// 存数据,并设置过期时间
redisTemplate.opsForValue().set("name","Jerry",300L,TimeUnit.SECONDS);
// 取数据,并打印输出
Object name = redisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
// 当该数据不存在时才写入/存数据(setnx),Absent:不存在,该方法返回值类型为Boolean,返回true代表执行成功(成功写入)
Boolean result = redisTemplate.opsForValue().setIfAbsent("count","528",528L,TimeUnit.SECONDS);
System.out.println(result == true ? "写入成功,count = " + redisTemplate.opsForValue().get("count") : "该数据存在,无法写入");
}
/**
* 操作List列表类型的数据:lpush,lpop,rpush,rpop
*/
@Test
void testList() {
// lpush
redisTemplate.opsForList().leftPushAll("list01","A","B","C","D","E","F");
// 获取List列表中元素的个数
Long list01Size = redisTemplate.opsForList().size("list01");
System.out.println("list01列表中元素的个数为:" + list01Size);
// range-获取
List list01 = redisTemplate.opsForList().range("list01",0L,-1L);
System.out.println("lpush后list01列表中出元素的顺序为:" + list01);
// lpop-leftPop(K key):删除并返回存储在Key列表中的第一个元素
Object firstObj = redisTemplate.opsForList().leftPop("list01");
System.out.println("存储在list01列表中的第一个元素为:" + firstObj);
System.out.println("-------------------分割线条--------------------");
// rpush
redisTemplate.opsForList().rightPushAll("list02","A","B","C","D","E","F");
// 获取List列表中元素的个数
Long list02Size = redisTemplate.opsForList().size("list02");
System.out.println("list02列表中元素的个数为:" + list02Size);
// range-获取
List list02 = redisTemplate.opsForList().range("list02",0L,-1L);
System.out.println("rpush后list02列表中取出元素的顺序为:" + list02);
// rpop-rightPop(K key):删除并返回存储在Key列表中的最后一个元素
Object lastObj = redisTemplate.opsForList().rightPop("list02");
System.out.println("存储在list02列表中的最后一个元素为:" + lastObj);
}
/**
* 操作Set集合类型的元素:sadd,smembers,scard
*/
@Test
void testSet() {
// sadd
redisTemplate.opsForSet().add("set01","A","B","C","D","E","F","A","B","C");
// size
Long set01Size = redisTemplate.opsForSet().size("set01");
System.out.println("set01集合中元素的个数为:" + set01Size);
// smembers
Set<Object> set01 = redisTemplate.opsForSet().members("set01");
System.out.println("set01集合中元素的顺序为:" + set01);
System.out.println("-----------分割线-----------");
// sadd
redisTemplate.opsForSet().add("set02","C","D","E","G","H","I");
// size
Long set02Size = redisTemplate.opsForSet().size("set02");
System.out.println("set02集合中元素的个数为:" + set02Size);
// smembers
Set<Object> set02 = redisTemplate.opsForSet().members("set02");
System.out.println("set02集合中元素的顺序为:" + set02);
// sinter:获取两个集合的交集 union:求并集 diff:求差集
Set<Object> sinterSet = redisTemplate.opsForSet().intersect("set01","set02");
System.out.println("set01集合与set02集合的交集为:" + sinterSet);
}
/**
* 操作Hash类型的数据:hset,hget,hmset,hmget,hkeys,hvals
*/
@Test
void testHash() {
// hset = put()
redisTemplate.opsForHash().put("tb_user","name","Rose");
// hmset:批量操作 - putAll()
Map<String,Object> map = new HashMap<>();
map.put("age","6");
map.put("year","2008");
redisTemplate.opsForHash().putAll("tb_user",map);
// hget
Object value = redisTemplate.opsForHash().get("tb_user","year");
System.out.println("year = " + value);
// hmget:取多个Field的值
List<Object> valueList = redisTemplate.opsForHash().multiGet("tb_user", Arrays.asList("name","age","year"));
System.out.println(valueList);
// hkeys Key:获取指定哈希键所有的Field
Set<Object> allField = redisTemplate.opsForHash().keys("tb_user");
System.out.println("哈希表中所有的Field为:" + allField);
// hvals Key:获取哈希表中所有的Value
List allValue = redisTemplate.opsForHash().values("tb_user");
System.out.println("哈希表中所有的Value为:" + allValue);
// hgetall key:获取所有的Field和Value entries()
Map<String,Object> all = redisTemplate.opsForHash().entries("tb_user");
System.out.println("哈希表中所有的Field和Value为:" + all);
}
/**
* ZSet有序集合类型数据的操作
*/
@Test
void testZSet() {
// zadd
redisTemplate.opsForZSet().add("ZSetType","Java",80);
redisTemplate.opsForZSet().add("ZSetType","Web",75);
redisTemplate.opsForZSet().add("ZSetType","Go",90);
redisTemplate.opsForZSet().add("ZSetType","Python",85);
redisTemplate.opsForZSet().add("ZSetType","Rust",98);
// 按分数从小到大,升序排序 => zrange
Set<Object> range = redisTemplate.opsForZSet().range("ZSetType",0,-1);
System.out.println("编程语言按分数从小到大,升序排序为:" + range);
// 按分数从大到小,降序排序 => zreverange
Set<Object> reverseRange = redisTemplate.opsForZSet().reverseRange("ZSetType",0,-1);
System.out.println("编程语言按分数从大到小,降序排序为:" + reverseRange);
// rangeByScore(key,min,max) 获取按照指定分数区间的Value并按照从小到大,升序排序,返回值类型为Set
// reverseRangeByScore(key,min,max) 获取指定分数区间的Value并按照从大到小,降序顺序,返回值类型为Set
}
/**
* 通用命令的操作
* 补充:要使用同一格式来进行序列化与反序列化
*/
@Test
void testCommon() {
// 1. 获取所有的Key
Set<Object> allKeys = redisTemplate.keys("*");
System.out.println("所有的Key为:" + allKeys);
// 2. 删除Key
Boolean result = redisTemplate.delete("key");
System.out.println(result == true ? "删除成功" : "删除失败");
}
方案1:在Redis当中存放一个对象,使用JSON序列化与反序列化(太Low了~!)
方案2:直接使用Redis自带的序列化方式存储对象~!
package com.gch.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@AllArgsConstructor
@NoArgsConstructor
/**
* 该实体类想要存放到Redis当中,就必须被序列化,因此要实现Serializable接口
*/
public class User implements Serializable {
private String name;
private Integer age;
}
/**
* 保存对象:保存在Redis当中的数据是要被序列化的
*/
@Test
void testObject() {
// 保存对象
redisTemplate.opsForValue().set("tb_user",new User("Jerry",6));
// 获取对象
Object obj = redisTemplate.opsForValue().get("tb_user");
System.out.println("保存的对象数据为:" + obj.toString());
}
文章浏览阅读63次。题目给定一个整数 n,返回 n! 结果尾数中零的数量。解题思路每个0都是由2 * 5得来的,相当于要求n!分解成质因子后2 * 5的数目,由于n中2的数目肯定是要大于5的数目,所以我们只需要求出n!中5的数目。C++代码class Solution {public: int trailingZeroes(int n) { ...
文章浏览阅读992次,点赞27次,收藏15次。UTF-8是Unicode字符集的一种编码方案,采取可变长编码方案,共分四个长度区:1个字节,2个字节,3个字节,4个字节。文件字节输入流:每次读取多个字节到字节数组中去,返回读取的字节数量,读取完毕会返回-1。注意1:字符编码时使用的字符集,和解码时使用的字符集必须一致,否则会出现乱码。定义一个与文件一样大的字节数组,一次性读取完文件的全部字节。UTF-8字符集:汉字占3个字节,英文、数字占1个字节。GBK字符集:汉字占2个字节,英文、数字占1个字节。GBK规定:汉字的第一个字节的第一位必须是1。_outputstream释放
文章浏览阅读1.8k次,点赞3次,收藏3次。解决jeecgboot每次登录进去都会弹出请重新登录问题,在utils文件下找到request.js文件注释这段代码即可_jeecg 登录自动退出
文章浏览阅读3.4k次。我国目前普遍采用需要系数法和二项式系数法确定用电设备的负荷,其中需要系数法是国际上普遍采用的确定计算负荷的方法,最为简便;而二项式系数法在确定设备台数较少且各台设备容量差..._数据中心用电负荷统计变压器
文章浏览阅读7k次,点赞4次,收藏46次。HTML5期末大作业:网页制作代码 网站设计——人电影网站(5页) HTML+CSS+JavaScript 学生DW网页设计作业成品 dreamweaver作业静态HTML网页设计模板常见网页设计作业题材有 个人、 美食、 公司、 学校、 旅游、 电商、 宠物、 电器、 茶叶、 家居、 酒店、 舞蹈、 动漫、 明星、 服装、 体育、 化妆品、 物流、 环保、 书籍、 婚纱、 军事、 游戏、 节日、 戒烟、 电影、 摄影、 文化、 家乡、 鲜花、 礼品、 汽车、 其他 等网页设计题目, A+水平作业_网页设计成品百度网盘
文章浏览阅读392次。jailhouse 文章翻译,Look Mum, no VM Exits!_jailhouse sr-iov
文章浏览阅读751次。本文由chatgpt生成,文章没有在chatgpt生成的基础上进行任何的修改。以上只是chatgpt能力的冰山一角。作为通用的Aigc大模型,只是展现它原本的实力。对于颠覆工作方式的ChatGPT,应该选择拥抱而不是抗拒,未来属于“会用”AI的人。AI职场汇报智能办公文案写作效率提升教程 专注于AI+职场+办公方向。下图是课程的整体大纲下图是AI职场汇报智能办公文案写作效率提升教程中用到的ai工具。_python 删除文件特定几行
文章浏览阅读2.1k次。【代码】Java过滤特殊字符的正则表达式。_java正则表达式过滤特殊字符
文章浏览阅读5.7k次,点赞4次,收藏17次。css中背景的设置至关重要,也是一个难点,因为属性众多,对应的属性值也比较多,这里详细的列举了背景相关的7个属性及对应的属性值,并附上演示代码,后期要用的话,可以随时查看,那我们坐稳开车了······1: background-color 设置背景颜色2:background-image来设置背景图片- 语法:background-image:url(相对路径);-可以同时为一个元素指定背景颜色和背景图片,这样背景颜色将会作为背景图片的底色,一般情况下设置背景..._background设置背景图片
文章浏览阅读2.6k次,点赞2次,收藏8次。Win10 安装系统跳过创建用户,直接启用 Administrator_windows10msoobe进程
文章浏览阅读10w+次,点赞653次,收藏3k次。Windows安装pycharm教程新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入下载安装PyCharm1、进入官网PyCharm的下载地址:http://www.jetbrains.com/pycharm/downl_pycharm2021
文章浏览阅读835次。本节书摘来自异步社区出版社《跨境电商——速卖通搜索排名规则解析与SEO技术》一书中的第1章,第1.1节,作者: 冯晓宁,更多章节内容可以访问云栖社区“异步社区”公众号查看。1.1 初识速卖通的搜索引擎1.1.1 初识速卖通搜索作为速卖通卖家都应该知道,速卖通经常被视为“国际版的淘宝”。那么请想一下,普通消费者在淘宝网上购买商品的时候,他的行为应该..._跨境电商 速卖通搜索排名规则解析与seo技术 pdf