在Java中操作Redis-程序员宅基地

技术标签: 缓存  数据库  redis  

Redis中如何的去存放一个Java对象?

  1. 直接存放Json类型即可,因为我们Json类型最终就是一个String类型。
  2. 直接存二进制。。。。

在Redis中存放对象可以使用JSON和二进制有哪些区别吗?

  • 二进制它本质上来说也是一个String类型的,只不过它转换成了0101,但是0101它也可以转换成String类型。
  • 你如果存Java语言的二进制对象那你只能在Java里面用,不能跨平台,因此对于需要跨语言频繁查询的对象,建议使用JSON格式;
  • 对于不需要跨语言频繁查看的对象,直接在Redis当中存放二进制对象即可。

Redis的Java客户端 

Redis的常用命令是我们操作Redis的基础,那么我们在Java程序当中如何来操作Redis呢?

  • 要想基于Java语言来操作Redis数据库,这就需要使用到Redis的Java客户端,就如同我们使用JDBC操作MySQL数据库一样。
Redis的Java客户端很多,常用的几种:
  • Jedis
  • Lettuce
  • Spring Data 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。 

Spring Data框架:

  • Spring Data框架它里面就封装了操作各种各样数据库的技术! 

Spring Data Redis环境准备及介绍

网址:https://spring.io/projects/spring-data-redis 

介绍

  • Spring Data Redis是Spring的一部分,提供了在Spring应用中通过简单的配置就可以访问Redis服务,对Redis底层开发包进行了高度封装,在Spring项目中,可以使用Spring Data Redis来简化Redis操作。 

Spring Data Redis的使用方式:Spring Boot整合Redis

操作步骤:

  1. 创建SpringBoot工程,勾选起步依赖:Lombok + Spring Web(Web开发的起步依赖) + Spring Data Redis(Acess+Driver) => 在NoSQL里面勾选
  2. 在application.yml中配置Redis的连接信息
  3. 在单元测试中,直接注入RedisTemplate对象
  4. 通过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
  • database:指定使用Redis的哪个数据库,Redis服务启动后默认有16个数据库,编号分别是从0到15,可以通过修改Redis的配置文件来指定数据库的数量。 

lettuce是Java用来操作Redis的一个Jar包! 

3. 在单元测试类当中注入RedisTemplate

为什么可以直接注入呢?
  • 因为引入了Redis的起步依赖,所以Spring Boot框架会自动装配RedisTemplate对象! 
  • RedisAutoConfiguration:RedisTemplate的自动配置类  =>  SpringBoot自动装配的原理
  • 底层还会再声明一个Bean:StringRedisTemplate,它继承了RedisTemplate,并且限制了泛型为<String,String>!

Spring Data Redis中提供了一个高度封装的类:RedisTemplateRedisTemplate针对大量相关的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));
    }
}

  • 我们会发现我们存到Redis中的数据和原始数据有差别,这是为什么呢? 
我们来看以下RedisTemplate的源码:

  • 通过上面源码我们发现,Spring Boot框架会自动装配RedisTemplate对象,但是默认的Key和Value的序列化器为JdkSerializationRedisSerializer,默认是采用JDK序列化器,虽然说RedisTemplate可以接收任意Object作为值写入到Redis,但是写入前会把Object序列化为字节形式,从而导致我们存到Redis中的数据和原始数据有差别,因为我们要进行设置我们可以自己定义声明了一个名为redisTemplate的Bean,自己来手动定义序列化方式,从而让源码中的RedisTemplate不声明,以此来覆盖掉源码当中的Bean。
JDK序列化器的缺点:
  • 可读性差
  • 内存占用较大,但是JDK的序列化方式效率要高一些

SpringDataRedis - 序列化方式配置

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;
    }
}

操作常见类型数据

1. 操作String字符串类型数据

    /**
     * 操作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") : "该数据存在,无法写入");
    }

2. 操作List列表类型数据

    /**
     * 操作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);
    }

3. 操作Set集合类型数据 

    /**
     * 操作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);
    }

4. 操作Hash哈希类型数据

    /**
     * 操作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);
    }

5. 操作ZSet有序集合类型数据 

    /**
     * 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 ? "删除成功" : "删除失败");
    }

在项目当中的真实应用是要保存对象:使用Redis的二进制形式存放对象(序列化)  

方案1:在Redis当中存放一个对象,使用JSON序列化与反序列化(太Low了~!)

方案2:直接使用Redis自带的序列化方式存储对象~!

  • 注意:保存在Redis当中的数据是要被序列化的(存放二进制的时候必须要把对象序列化的),因此一个对象要想能够成功的保存到Redis当中,那么该对象所归属的类就必须要实现一个接口:Serializable序列化接口,否则直接存放运行后程序会报错!
  • 因此,在后续的项目当中,所有的实体类都要实现Serializable序列化接口!
  • 注意:需要序列化的对象一定要实现Serializable序列化接口!
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());
    }

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_53622554/article/details/134206347

智能推荐

leetcode 172. 阶乘后的零-程序员宅基地

文章浏览阅读63次。题目给定一个整数 n,返回 n! 结果尾数中零的数量。解题思路每个0都是由2 * 5得来的,相当于要求n!分解成质因子后2 * 5的数目,由于n中2的数目肯定是要大于5的数目,所以我们只需要求出n!中5的数目。C++代码class Solution {public: int trailingZeroes(int n) { ...

Day15-【Java SE进阶】IO流(一):File、IO流概述、File文件对象的创建、字节输入输出流FileInputStream FileoutputStream、释放资源。_outputstream释放-程序员宅基地

文章浏览阅读992次,点赞27次,收藏15次。UTF-8是Unicode字符集的一种编码方案,采取可变长编码方案,共分四个长度区:1个字节,2个字节,3个字节,4个字节。文件字节输入流:每次读取多个字节到字节数组中去,返回读取的字节数量,读取完毕会返回-1。注意1:字符编码时使用的字符集,和解码时使用的字符集必须一致,否则会出现乱码。定义一个与文件一样大的字节数组,一次性读取完文件的全部字节。UTF-8字符集:汉字占3个字节,英文、数字占1个字节。GBK字符集:汉字占2个字节,英文、数字占1个字节。GBK规定:汉字的第一个字节的第一位必须是1。_outputstream释放

jeecgboot重新登录_jeecg 登录自动退出-程序员宅基地

文章浏览阅读1.8k次,点赞3次,收藏3次。解决jeecgboot每次登录进去都会弹出请重新登录问题,在utils文件下找到request.js文件注释这段代码即可_jeecg 登录自动退出

数据中心供配电系统负荷计算实例分析-程序员宅基地

文章浏览阅读3.4k次。我国目前普遍采用需要系数法和二项式系数法确定用电设备的负荷,其中需要系数法是国际上普遍采用的确定计算负荷的方法,最为简便;而二项式系数法在确定设备台数较少且各台设备容量差..._数据中心用电负荷统计变压器

HTML5期末大作业:网页制作代码 网站设计——人电影网站(5页) HTML+CSS+JavaScript 学生DW网页设计作业成品 dreamweaver作业静态HTML网页设计模板_网页设计成品百度网盘-程序员宅基地

文章浏览阅读7k次,点赞4次,收藏46次。HTML5期末大作业:网页制作代码 网站设计——人电影网站(5页) HTML+CSS+JavaScript 学生DW网页设计作业成品 dreamweaver作业静态HTML网页设计模板常见网页设计作业题材有 个人、 美食、 公司、 学校、 旅游、 电商、 宠物、 电器、 茶叶、 家居、 酒店、 舞蹈、 动漫、 明星、 服装、 体育、 化妆品、 物流、 环保、 书籍、 婚纱、 军事、 游戏、 节日、 戒烟、 电影、 摄影、 文化、 家乡、 鲜花、 礼品、 汽车、 其他 等网页设计题目, A+水平作业_网页设计成品百度网盘

【Jailhouse 文章】Look Mum, no VM Exits_jailhouse sr-iov-程序员宅基地

文章浏览阅读392次。jailhouse 文章翻译,Look Mum, no VM Exits!_jailhouse sr-iov

随便推点

chatgpt赋能python:Python怎么删除文件中的某一行_python 删除文件特定几行-程序员宅基地

文章浏览阅读751次。本文由chatgpt生成,文章没有在chatgpt生成的基础上进行任何的修改。以上只是chatgpt能力的冰山一角。作为通用的Aigc大模型,只是展现它原本的实力。对于颠覆工作方式的ChatGPT,应该选择拥抱而不是抗拒,未来属于“会用”AI的人。AI职场汇报智能办公文案写作效率提升教程 专注于AI+职场+办公方向。下图是课程的整体大纲下图是AI职场汇报智能办公文案写作效率提升教程中用到的ai工具。_python 删除文件特定几行

Java过滤特殊字符的正则表达式_java正则表达式过滤特殊字符-程序员宅基地

文章浏览阅读2.1k次。【代码】Java过滤特殊字符的正则表达式。_java正则表达式过滤特殊字符

CSS中设置背景的7个属性及简写background注意点_background设置背景图片-程序员宅基地

文章浏览阅读5.7k次,点赞4次,收藏17次。css中背景的设置至关重要,也是一个难点,因为属性众多,对应的属性值也比较多,这里详细的列举了背景相关的7个属性及对应的属性值,并附上演示代码,后期要用的话,可以随时查看,那我们坐稳开车了······1: background-color 设置背景颜色2:background-image来设置背景图片- 语法:background-image:url(相对路径);-可以同时为一个元素指定背景颜色和背景图片,这样背景颜色将会作为背景图片的底色,一般情况下设置背景..._background设置背景图片

Win10 安装系统跳过创建用户,直接启用 Administrator_windows10msoobe进程-程序员宅基地

文章浏览阅读2.6k次,点赞2次,收藏8次。Win10 安装系统跳过创建用户,直接启用 Administrator_windows10msoobe进程

PyCharm2021安装教程-程序员宅基地

文章浏览阅读10w+次,点赞653次,收藏3k次。Windows安装pycharm教程新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入下载安装PyCharm1、进入官网PyCharm的下载地址:http://www.jetbrains.com/pycharm/downl_pycharm2021

《跨境电商——速卖通搜索排名规则解析与SEO技术》一一1.1 初识速卖通的搜索引擎...-程序员宅基地

文章浏览阅读835次。本节书摘来自异步社区出版社《跨境电商——速卖通搜索排名规则解析与SEO技术》一书中的第1章,第1.1节,作者: 冯晓宁,更多章节内容可以访问云栖社区“异步社区”公众号查看。1.1 初识速卖通的搜索引擎1.1.1 初识速卖通搜索作为速卖通卖家都应该知道,速卖通经常被视为“国际版的淘宝”。那么请想一下,普通消费者在淘宝网上购买商品的时候,他的行为应该..._跨境电商 速卖通搜索排名规则解析与seo技术 pdf

推荐文章

热门文章

相关标签