百度360必应搜狗淘宝本站头条
php redisredis 命令oracle位图索引redis 锁redis 主从
当前位置：网站首页 > 技术教程 > 正文

Redis学习2——SpringBoot整合Redis，Redis工具类

mhr18 2024-12-06 17:44 29 浏览 0 评论

1. 依赖和配置

1.1. pom.xml

SpringBoot整合Redis，需要引入spring-boot-starter-data-redis依赖

  <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

当我们需要配置redis的连接池时，还需要引入commons-pool2依赖

 <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

1.2. application.yml配置

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    database: 0
    jedis:
      pool:
        max-idle: 8
        max-active: 8
        min-idle: 0

这里的jedis指的是使用jedis客户端，这里也可以将jedis改为lettuce，表示使用lettuce客户端，客户端下面的pool表示的是连接池的相关配置。

上述的配置针对的是单机redis配置，如果使用的是集群，配置如下：

spring:
  redis:
    password: 123456
    cluster:
      nodes: 10.255.144.115:7001,10.255.144.115:7002,10.255.144.115:7003,10.255.144.115:7004,10.255.144.115:7005,10.255.144.115:7006
      max-redirects: 3

2. RedisTemplate

上述的配置完毕后，我们就可以在项目中操作redis了，操作的时候，可以直接使用spring-boot-starter-data-redis为我们提供的RedisTemplate这个类，也可以使用StringRedisTemplate，两者的方法基本一致，后者可以看作RedisTemplate<String, String> 。

在上一节中，提到，Redis有多种数据类型，比如string、list、hash、set、zset等，这些类型的操作在RedisTemplate分别对应opsForValue(), opsForList(), opsForHash(), opsForSet(), opsForZSet()。

具体的操作演示如下：


@SpringBootTest
public class RedisAppTest {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Test
    public void testGet() {
        System.out.println("字符串操作=================");
        redisTemplate.opsForValue().set("name", "cxy");
        System.out.println(redisTemplate.opsForValue().get("name"));

        System.out.println("列表操作");
        redisTemplate.opsForList().leftPush("school", "华南理工大学");
        redisTemplate.opsForList().leftPush("school", "中山大学");
        redisTemplate.opsForList().leftPush("school", "华南农业大学");
        List<String> school = redisTemplate.opsForList().range("school", 0, 5);
        for (String s : school) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("hash操作");
        redisTemplate.opsForHash().put("student", "name", "cxy");
        redisTemplate.opsForHash().put("student", "age", "21");
        redisTemplate.opsForHash().put("student", "sex", "male");
        System.out.println(redisTemplate.opsForHash().get("student", "name"));
        System.out.println(redisTemplate.opsForHash().get("student", "age"));
        System.out.println(redisTemplate.opsForHash().get("student", "sex"));

        System.out.println("set操作");
        redisTemplate.opsForSet().add("project", "软件工程", "计算机技术", "通信工程", "软件工程");
        Set<String> project = redisTemplate.opsForSet().members("project");
        for (String s : project) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("zset操作");
        redisTemplate.opsForZSet().add("movie", "热辣滚烫", 2.7d);
        redisTemplate.opsForZSet().add("movie", "飞驰人生", 9.1d);
        redisTemplate.opsForZSet().add("movie", "熊出没之逆转时空", 9.3d);
        redisTemplate.opsForZSet().add("movie", "二十一条", 8.2d);
        Set<String> movie = redisTemplate.opsForZSet().rangeByScore("movie", 3.0d, 9.3d);
        for (String s : movie) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("基数操作");
        redisTemplate.opsForHyperLogLog().add("accessIp", "127.0.0.1");
        redisTemplate.opsForHyperLogLog().add("accessIp", "192.168.10.1");
        redisTemplate.opsForHyperLogLog().add("accessIp", "192.168.0.1");
        redisTemplate.opsForHyperLogLog().add("accessIp", "33.45.23.1");
        System.out.println(redisTemplate.opsForHyperLogLog().size("accessIp"));

    }

}

运行结果如下：

3. RedisUtils工具类

虽然RedisTemplate提供的redis操作很全面，但对于不了解redis的开发同学来说，直接看RedisTemplate的方法不够见名知义，因此一般情况下，我们都会单独封装一个工具类，将常用的一些方法进行抽象，以方便后续使用。

创建Redis配置类，配置RedisTemplate

@Configuration
public class RedisConfiguration {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        return redisTemplate;
    }
}

工具类代码如下：

package org.example.util;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Component;

import java.util.*;
import java.util.concurrent.TimeUnit;

@Component
public class RedisUtils {
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public boolean removeKey(String key) {
        return redisTemplate.delete(key);
    }

    public boolean hasKey(String key) {
        if (StringUtils.isEmpty(key)) {
            return false;
        }
        return redisTemplate.hasKey(key);
    }

    public boolean expire(String key, long time) {
        return expire(key, time, TimeUnit.SECONDS);
    }

    public boolean expire(String key, long time, TimeUnit timeUnit) {
        if (StringUtils.isEmpty(key)) {
            return false;
        }
        return redisTemplate.expire(key, time, timeUnit);
    }

    public void addKey(String key, Object value, long time) {
        addKey(key, value, time, TimeUnit.SECONDS);
    }

    public void addKey(String key, Object value, long time, TimeUnit timeUnit) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForValue().set(key, value, time, timeUnit);
    }

    public void addKey(String key, Object value) {
        redisTemplate.opsForValue().set(key, value);
    }

    public Object getKey(String key) {
        if (StringUtils.isEmpty(key)) {
            return null;
        }
        return redisTemplate.opsForValue().get(key);
    }

    public void increment(String key) {
        increment(key, 1L);
    }

    public void increment(String key, long delta) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForValue().increment(key, delta);
    }

    public void decrement(String key) {
        decrement(key, 1L);
    }

    public void decrement(String key, long delta) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForValue().decrement(key, delta);
    }

    public void leftPush(String key, List<Object> values) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForList().leftPushAll(key, values);
    }

    public void leftPush(String key, Object... value) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForList().leftPushAll(key, value);
    }

    public Object leftPop(String key) {
        if (StringUtils.isEmpty(key)) {
            return null;
        }
        return redisTemplate.opsForList().leftPop(key);
    }

    public List<Object> range(String key, long start, long end) {
        if (StringUtils.isEmpty(key)) {
            return new ArrayList<>();
        }
        return redisTemplate.opsForList().range(key, start, end);
    }

    public Object indexOfList(String key, int index) {
        if (StringUtils.isEmpty(key)) {
            return null;
        }
        return redisTemplate.opsForList().index(key, index);
    }

    public void addHash(String key, Map<String, Object> map) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        if (map == null || map.isEmpty()) {
            return;
        }
        map.forEach((field, value) -> {
            redisTemplate.opsForHash().put(key, field, value);
        });
    }

    public void addField(String key, String field, Object value) {
        if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {
            return;
        }
        redisTemplate.opsForHash().put(key, field, value);
    }

     public void removeField(String key, String field) {
        if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {
            return;
        }
        redisTemplate.opsForHash().delete(key, field);
    }

    public Map<String, Object> getEntries(String key) {
        if (StringUtils.isEmpty(key)) {
            return new HashMap<>();
        }
        Map<Object, Object> entries = redisTemplate.opsForHash().entries(key);
        Map<String, Object> result = new HashMap<>();
        entries.forEach((k, v) -> {
            result.put(k.toString(), v);
        });
        return result;
    }

    public Object getField(String key, String field) {
        if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {
            return null;
        }
        return redisTemplate.opsForHash().get(key, field);
    }

    public Boolean hasField(String key, String field) {
        if (StringUtils.isEmpty(key) || StringUtils.isEmpty(field)) {
            return false;
        }
        return redisTemplate.opsForHash().hasKey(key, field);
    }

    public void addSet(String key, String... value) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForSet().add(key, value);
    }

    public Set<Object> members(String key) {
        if (StringUtils.isEmpty(key)) {
            return new HashSet<>();
        }
        return redisTemplate.opsForSet().members(key);
    }

    public Boolean isMember(String key, Object value) {
        if (StringUtils.isEmpty(key)) {
            return false;
        }
        return redisTemplate.opsForSet().isMember(key, value);
    }

    public void addZSet(String key, Object value, Double score) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForZSet().add(key, value, score);
    }

    public Set<Object> rangeByScore(String key, Double min, Double max) {
        if (StringUtils.isEmpty(key)) {
            return new HashSet<>();
        }
        return redisTemplate.opsForZSet().rangeByScore(key, min, max);
    }

    public Set<ZSetOperations.TypedTuple<Object>> rangeByScoreWithScore(String key, Double min, Double max) {
        if (StringUtils.isEmpty(key)) {
            return new HashSet<>();
        }
       return redisTemplate.opsForZSet().rangeByScoreWithScores(key, min, max);
    }

    public void addHyperLogLog(String key, Object... value) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForHyperLogLog().add(key, value);
    }

    public void addHyperLogLog(String key, List value) {
        if (StringUtils.isEmpty(key)) {
            return;
        }
        redisTemplate.opsForHyperLogLog().add(key, value);
    }

    public Long countHyperLogLog(String key) {
        if (StringUtils.isEmpty(key)) {
            return 0L;
        }
        return redisTemplate.opsForHyperLogLog().size(key);
    }
}

修改之前的测试代码，将redisTemplate，改为我们的工具类

@Autowired
    private RedisUtils redisUtils;

    @Test
    public void testRedisUtils() {
        System.out.println("字符串操作=================");
       redisUtils.addKey("name", "cxy");
        System.out.println(redisUtils.getKey("name"));

        System.out.println("列表操作");
        redisUtils.leftPush("school", "华南理工大学");
        redisUtils.leftPush("school", "中山大学");
        redisUtils.leftPush("school", "华南农业大学");
        List<Object> school = redisUtils.range("school", 0, 5);
        for (Object s : school) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("hash操作");
        redisUtils.addField("student", "name", "cxy");
        redisUtils.addField("student", "age", "21");
        redisUtils.addField("student", "sex", "male");
        System.out.println(redisUtils.getField("student", "name"));
        System.out.println(redisUtils.getField("student", "age"));
        System.out.println(redisUtils.getField("student", "sex"));

        System.out.println("set操作");
        redisUtils.addSet("project", "软件工程", "计算机技术", "通信工程", "软件工程");
        Set<Object> project = redisUtils.members("project");
        for (Object s : project) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("zset操作");
        redisUtils.addZSet("movie", "热辣滚烫", 2.7d);
        redisUtils.addZSet("movie", "飞驰人生", 9.1d);
        redisUtils.addZSet("movie", "熊出没之逆转时空", 9.3d);
        redisUtils.addZSet("movie", "二十一条", 8.2d);
        Set<Object> movie = redisUtils.rangeByScore("movie", 3.0d, 9.3d);
        for (Object s : movie) {
            System.out.print(s + " ");
        }
        System.out.println();

        System.out.println("基数操作");
        redisUtils.addHyperLogLog("accessIp", "127.0.0.1");
        redisUtils.addHyperLogLog("accessIp", "192.168.10.1");
        redisUtils.addHyperLogLog("accessIp", "192.168.0.1");
        redisUtils.addHyperLogLog("accessIp", "33.45.23.1");
        System.out.println(redisUtils.countHyperLogLog("accessIp"));
    }

在测试之前，先删除之前添加的数据

测试结果如下：

相关推荐

【预警通报】关于WebLogic存在远程代码执行高危漏洞的预警通报

近日，Oracle官方发布了2021年1月关键补丁更新公告CPU（CriticalPatchUpdate），共修复了包括CVE-2021-2109（WeblogicServer远程代码执行漏洞）...

医院信息系统突发应急演练记录（医院信息化应急演练）

信息系统突发事件应急预案演练记录演练内容信息系统突发事件应急预案演练参与人员信息科参与科室：全院各部门日期xxxx-xx-xx时间20:00至24:00地点信息科记录：xxx1、...

一文掌握怎么利用Shell+Python实现完美版的多数据源备份程序

简介：在当今数字化时代，无论是企业还是个人，数据的安全性和业务的连续性都是至关重要的。数据一旦丢失，可能会造成无法估量的损失。因此，如何有效地对分布在不同位置的数据进行备份，尤其是异地备份，成为了一个...

docker搭建系统环境（docker搭建centos）

Docker安装（CentOS7）1.卸载旧版Docker#检查已安装版本yumlistinstalled|grepdocker#卸载旧版本yumremove-ydocker.x...

基础篇:数据库 SQL 入门教程（sql数据库入门书籍推荐）

SQL介绍什么是SQLSQL指结构化查询语言，是用于访问和处理数据库的标准的计算机语言。它使我们有能力访问数据库，可与多种数据库程序协同工作，如MSAccess、DB2、Informix、M...

Java21杀手级新特性!3行代码性能翻倍

导语某券商系统用这招，交易延迟从12ms降到0.8ms！本文揭秘Oracle官方未公开的Record模式匹配+虚拟线程深度优化+向量API神操作，代码量直降70%！一、Record模式匹配（代码量↓8...

一文读懂JDK21的虚拟线程（java虚拟线程）

概述JDK21已于2023年9月19日发布，作为Oracle标准Java实现的一个LTS版本发布，发布了15想新特性，其中虚拟线程呼声较高。虚拟线程是JDK21中引入的一项重要特性，它是一种轻量级的...

效率!MacOS下超级好用的Linux虚拟工具:Lima

对于MacOS用户来说，搭建Linux虚拟环境一直是件让人头疼的事。无论是VirtualBox还是商业的VMware，都显得过于笨重且配置复杂。今天，我们要介绍一个轻巧方便的纯命令行Linux虚拟工具...

所谓SaaS（所谓三维目标一般都应包括）

2010年前后，一个科技媒体的主编写一些关于云计算的概念性问题，就可以作为头版头条了。那时候的云计算，更多的还停留在一些概念性的问题上。而基于云计算而生的SaaS更是“养在深闺人未识”，一度成为被IT...

ORA-00600 「25027」 「x」报错（报错0xc0000001）

问题现象：在用到LOB大对象的业务中，进行数据的插入，失败了，在报警文件中报错：ORA-00600:内部错误代码,参数:[25027],[10],[0],[],[],[],[],[...

安卓7源码编译（安卓源码编译环境lunch失败,uname命令找不到）

前面已经下载好源码了，接下来是下载手机对应的二进制驱动执行编译源码命令下载厂商驱动https://developers.google.com/android/drivers?hl=zh-cn搜索NGI...

编译安卓源码（编译安卓源码 电脑配置）

前面已经下载好源码了，接下来是下载手机对应的二进制驱动执行编译源码命令下载厂商驱动https://developers.google.com/android/drivers?hl=zh-cn搜索NGI...

360 Vulcan Team首战告捷 以17.5万美金强势领跑2019“天府杯“

2019年11月16日，由360集团、百度、腾讯、阿里巴巴、清华大学与中科院等多家企业和研究机构在成都联合主办了2019“天府杯”国际网络安全大赛暨2019天府国际网络安全高峰论坛。而开幕当日最激荡人...

Syslog 日志分析与异常检测技巧（syslog发送日志配置）

系统日志包含有助于分析网络设备整体运行状况的重要信息。然而，理解并从中提取有效数据往往颇具挑战。本文将详解从基础命令行工具到专业日志管理软件的全流程分析技巧，助你高效挖掘Syslog日志价值。Gr...

从Oracle演进看数据库技术的发展（从oracle演进看数据库技术的发展的过程）

数据库技术发展本质上是应用需求驱动与基础架构演进的双向奔赴，如何分析其技术发展的脉络和方向？考虑到oracle数据库仍然是这个领域的王者，以其为例，管中窥豹，对其从Oracle8i到23ai版本的核...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表