RedisTemplate集成+封装RedisUtil

2024-08-31 08:12
文章标签 封装 集成 redistemplate redisutil

本文主要是介绍RedisTemplate集成+封装RedisUtil，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

    • 1.项目搭建
        • 1.创建一个redis模块
        • 2.调整pom.xml，使其成为单独的模块
          • 1.sun-common-redis的pom.xml 取消parent
          • 2.sun-common的pom.xml 取消对redis模块的管理
          • 3.sun-frame的pom.xml 增加对redis模块的管理
          • 4.关于只在modules中配置子模块，但是子模块没有配置parent的用处
            • **1. 多模块项目的构建管理**
            • **2. 统一的版本管理**
            • **3. 项目结构的组织和清晰度**
        • 3.sun-common-redis引入redis依赖
    • 2.sun-user集成RedisTemplate
        • 1.pom.xml引入sun-common-redis
        • 2.application.yml配置redis（集群模式）
        • 3.TestController.java测试RedisTemplate
          • 1.代码
          • 2.访问测试（发现有乱码）
        • 4.重写RedisTemlate
          • 1.引入Jackson的依赖
          • 2.RedisConfig.java
          • 3.测试
    • 3.封装RedisUtil
        • 1.RedisUtil.java

1.项目搭建

1.创建一个redis模块

CleanShot 2024-07-19 at 10.38.16@2x

2.调整pom.xml，使其成为单独的模块
1.sun-common-redis的pom.xml 取消parent

CleanShot 2024-07-19 at 10.42.55@2x

2.sun-common的pom.xml 取消对redis模块的管理

CleanShot 2024-07-19 at 10.43.33@2x

3.sun-frame的pom.xml 增加对redis模块的管理

CleanShot 2024-07-19 at 10.46.29@2x

4.关于只在modules中配置子模块，但是子模块没有配置parent的用处
1. 多模块项目的构建管理

使用标签可以将多个子模块组织在一个顶层的父项目中，从而实现以下几个目标：

a. 单点构建

你可以在父项目的根目录下运行一次mvn install命令，就可以构建和安装所有子模块到本地Maven仓库，而不需要分别进入每个子模块目录单独运行构建命令。这大大简化了多模块项目的构建过程。

b. 构建顺序管理

Maven会根据模块间的依赖关系，自动确定各个模块的构建顺序，确保在构建一个模块之前，先构建它所依赖的模块。这在多模块项目中是非常有用的，可以避免手动管理依赖顺序的麻烦。

2. 统一的版本管理

即使子模块没有指定父项目，使用标签仍然可以帮助你管理各个子模块的版本一致性。你可以在父项目的POM文件中统一指定各个子模块的版本号，然后在每个子模块的POM文件中引用这个版本号。

3. 项目结构的组织和清晰度

将多个子模块组织在一个父项目中，可以使项目结构更加清晰，便于管理。通过标签，你可以一目了然地看到项目中包含哪些子模块，以及它们之间的组织结构。

3.sun-common-redis引入redis依赖
    <dependencies><!-- redis --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>2.4.2</version></dependency><!-- redis的pool --><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.9.0</version></dependency></dependencies>

2.sun-user集成RedisTemplate

1.pom.xml引入sun-common-redis
        <!-- 引入sun-common-redis --><dependency><groupId>com.sunxiansheng</groupId><artifactId>sun-common-redis</artifactId><version>1.0-SNAPSHOT</version></dependency>
2.application.yml配置redis（集群模式）
spring:#  配置redis（集群模式）redis:password: # Redis服务器密码database: 0 # 默认数据库为0号timeout: 10000ms # 连接超时时间是10000毫秒lettuce:pool:max-active: 8 # 最大活跃连接数,使用负值表示没有限制，最佳配置为核数*2max-wait: 10000ms # 最大等待时间,单位为毫秒,使用负值表示没有限制，这里设置为10秒max-idle: 200 # 最大空闲连接数min-idle: 5 # 最小空闲连接数cluster:nodes:
3.TestController.java测试RedisTemplate
1.代码
package com.sunxiansheng.user.controller;import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;/*** Description:* @Author sun* @Create 2024/7/8 17:55* @Version 1.0*/
@RestController
public class TestController {@Resourceprivate RedisTemplate redisTemplate;@RequestMapping("/testRedis")public String testRedis() {redisTemplate.opsForValue().set("name", "sunxiansheng");return "Hello World!";}
}
2.访问测试（发现有乱码）

CleanShot 2024-07-19 at 11.09.08@2x

4.重写RedisTemlate
1.引入Jackson的依赖
        <!-- 重写RedisTemlate需要的jackson序列化工具 --><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId><version>2.8.5</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.11.4</version></dependency>

CleanShot 2024-07-19 at 12.03.26@2x

2.RedisConfig.java
package com.sunxiansheng.redis.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
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.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;/*** Description: RedisConfig配置类* @Author sun* @Create 2024/7/19 11:11* @Version 1.0*/
@Configuration
public class RedisConfig {/*** 重写RedisTemplate 解决乱码问题** @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// key就使用redis提供的序列化RedisSerializer即可RedisSerializer<String> redisSerializer = new StringRedisSerializer();redisTemplate.setKeySerializer(redisSerializer);redisTemplate.setHashKeySerializer(redisSerializer);// value要使用Jackson的序列化redisTemplate.setValueSerializer(jackson2JsonRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer());return redisTemplate;}/*** 获取一个Jackson的序列化对象逻辑** @return*/private Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer() {// 创建一个Jackson2JsonRedisSerializer对象，用于序列化和反序列化Java对象Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);// 创建一个ObjectMapper对象，用于JSON序列化和反序列化的配置ObjectMapper objectMapper = new ObjectMapper();// 设置ObjectMapper的可见性，使其可以访问所有属性objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);// 配置ObjectMapper，使其在遇到未知属性时不会抛出异常objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);// 将配置好的ObjectMapper设置到Jackson2JsonRedisSerializer中jackson2JsonRedisSerializer.setObjectMapper(objectMapper);// 返回配置好的Jackson2JsonRedisSerializer对象return jackson2JsonRedisSerializer;}}

CleanShot 2024-07-19 at 12.02.35@2x

3.测试

CleanShot 2024-07-19 at 12.04.03@2x

3.封装RedisUtil

1.RedisUtil.java
package com.sunxiansheng.redis.util;import org.springframework.data.redis.core.Cursor;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ScanOptions;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Component;import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import java.util.stream.Stream;/*** Description: RedisUtil工具类* @Author sun* @Create 2024/6/5 14:17* @Version 1.0*/
@Component
public class RedisUtil {@Resourceprivate RedisTemplate redisTemplate;private static final String CACHE_KEY_SEPARATOR = ".";/*** 构建缓存key* @param strObjs 多个字符串拼接成缓存key* @return 拼接后的缓存key*/public String buildKey(String... strObjs) {return Stream.of(strObjs).collect(Collectors.joining(CACHE_KEY_SEPARATOR));}/*** 是否存在key* @param key Redis中的key* @return true如果key存在，否则false*/public boolean exist(String key) {return redisTemplate.hasKey(key);}/*** 删除key* @param key Redis中的key* @return true如果删除成功，否则false*/public boolean del(String key) {return redisTemplate.delete(key);}/*** 设置key-value对* @param key Redis中的key* @param value 要设置的值*/public void set(String key, String value) {redisTemplate.opsForValue().set(key, value);}/*** 设置key-value对，如果key不存在，则设置成功，并指定过期时间* @param key Redis中的key* @param value 要设置的值* @param time 过期时间* @param timeUnit 时间单位* @return true如果设置成功，否则false*/public boolean setNx(String key, String value, Long time, TimeUnit timeUnit) {return redisTemplate.opsForValue().setIfAbsent(key, value, time, timeUnit);}/*** 获取指定key的值* @param key Redis中的key* @return key对应的值*/public String get(String key) {return (String) redisTemplate.opsForValue().get(key);}/*** 向有序集合中添加元素* @param key Redis中的key* @param value 元素的值* @param score 元素的分数* @return true如果添加成功，否则false*/public Boolean zAdd(String key, String value, Long score) {return redisTemplate.opsForZSet().add(key, value, Double.valueOf(String.valueOf(score)));}/*** 获取有序集合的元素数量* @param key Redis中的key* @return 元素数量*/public Long countZset(String key) {return redisTemplate.opsForZSet().size(key);}/*** 获取有序集合指定范围内的元素* @param key Redis中的key* @param start 起始位置* @param end 结束位置* @return 指定范围内的元素集合*/public Set<String> rangeZset(String key, long start, long end) {return redisTemplate.opsForZSet().range(key, start, end);}/*** 删除有序集合中的指定元素* @param key Redis中的key* @param value 要删除的元素* @return 被删除的元素数量*/public Long removeZset(String key, Object value) {return redisTemplate.opsForZSet().remove(key, value);}/*** 删除有序集合中的多个元素* @param key Redis中的key* @param value 要删除的元素集合*/public void removeZsetList(String key, Set<String> value) {value.forEach(val -> redisTemplate.opsForZSet().remove(key, val));}/*** 获取有序集合中指定元素的分数* @param key Redis中的key* @param value 元素的值* @return 元素的分数*/public Double score(String key, Object value) {return redisTemplate.opsForZSet().score(key, value);}/*** 获取有序集合中指定分数范围内的元素* @param key Redis中的key* @param start 起始分数* @param end 结束分数* @return 指定分数范围内的元素集合*/public Set<String> rangeByScore(String key, long start, long end) {return redisTemplate.opsForZSet().rangeByScore(key, Double.valueOf(String.valueOf(start)), Double.valueOf(String.valueOf(end)));}/*** 增加有序集合中指定元素的分数* @param key Redis中的key* @param obj 元素的值* @param score 增加的分数* @return 增加后的分数*/public Object addScore(String key, Object obj, double score) {return redisTemplate.opsForZSet().incrementScore(key, obj, score);}/*** 获取有序集合中指定元素的排名* @param key Redis中的key* @param obj 元素的值* @return 元素的排名*/public Object rank(String key, Object obj) {return redisTemplate.opsForZSet().rank(key, obj);}/*** 从 Redis 有序集合（Sorted Set）中按分数范围获取成员及其分数* @param key 排行榜的key* @param start 起始位置（包含）* @param end 结束位置（包含）* @return Set<ZSetOperations.TypedTuple<String>> : 每个 TypedTuple 对象包含以下内容：value: 集合中的成员，score: 成员的分数。*/public Set<ZSetOperations.TypedTuple<String>> rankWithScore(String key, long start, long end) {return redisTemplate.opsForZSet().reverseRangeWithScores(key, start, end);}/*** 向Redis中的hash结构存储数据* @param key 一个hash结构的key* @param hashKey hash中的小key* @param hashVal hash中的小value*/public void putHash(String key, String hashKey, Object hashVal) {redisTemplate.opsForHash().put(key, hashKey, hashVal);}/*** Redis中的String类型，获取value时将其转换为int类型* @param key Redis中的key* @return key对应的整数值*/public Integer getInt(String key) {return (Integer) redisTemplate.opsForValue().get(key);}/*** Redis中的String类型，将value增加一* @param key Redis中的key* @param count 增加的数量*/public void increment(String key, Integer count) {redisTemplate.opsForValue().increment(key, count);}/*** Redis中的hash类型，根据key来将每一个hashKey和hashValue转换为Map类型* @param key Redis中的hash结构的key* @return Map<Object, Object> 包含hash结构中的所有键值对*/public Map<Object, Object> getHashAndDelete(String key) {Map<Object, Object> map = new HashMap<>();// 扫描hash，指定每一个Entry的类型，这里返回的就是Map的游标，可以进行遍历Cursor<Map.Entry<Object, Object>> cursor = redisTemplate.opsForHash().scan(key, ScanOptions.NONE);// 遍历每一条数据，放到map中while (cursor.hasNext()) {Map.Entry<Object, Object> next = cursor.next();Object hashKey = next.getKey();Object hashValue = next.getValue();map.put(hashKey, hashValue);// 每遍历一条就删除redisTemplate.opsForHash().delete(key, hashKey);}return map;}
}

这篇关于RedisTemplate集成+封装RedisUtil的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1123356。

相关文章

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

随着区块链技术的快速发展，越来越多的企业开始将其应用于实际业务中。然而，区块链技术的专业性使得其集成开发成为一项挑战。针对此，广东中创智慧科技有限公司基于国产开源联盟链 FISCO BCOS 推出了区块链集成开发平台。该平台基于区块链技术，提供一套全面的区块链开发工具和开发环境，支持开发者快速开发和部署区块链应用。此外，该平台还可以提供一套全面的区块链开发教程和文档，帮助开发者快速上手区块链开发。
阅读更多...
JavaSE——封装、继承和多态

JavaSE——封装、继承和多态

1. 封装 1.1 概念      面向对象程序三大特性：封装、继承、多态 。而类和对象阶段，主要研究的就是封装特性。何为封装呢？简单来说就是套壳屏蔽细节 。     比如：对于电脑这样一个复杂的设备，提供给用户的就只是：开关机、通过键盘输入，显示器， USB 插孔等，让用户来和计算机进行交互，完成日常事务。但实际上：电脑真正工作的却是CPU 、显卡、内存等一些硬件元件。
阅读更多...
【Shiro】Shiro 的学习教程（三）之 SpringBoot 集成 Shiro

【Shiro】Shiro 的学习教程（三）之 SpringBoot 集成 Shiro

目录 1、环境准备2、引入 Shiro3、实现认证、退出3.1、使用死数据实现3.2、引入数据库，添加注册功能后端代码前端代码 3.3、MD5、Salt 的认证流程 4.、实现授权4.1、基于角色授权4.2、基于资源授权 5、引入缓存5.1、EhCache 实现缓存5.2、集成 Redis 实现 Shiro 缓存 1、环境准备 新建一个 SpringBoot 工程，引入依赖：
阅读更多...
系统架构师-ERP+集成

系统架构师-ERP+集成

ERP   集成平台end：就懒得画新的页
阅读更多...
Spring Boot集成Tess4J实现OCR

Spring Boot集成Tess4J实现OCR

1.什么是Tess4j？ Tesseract是一个开源的光学字符识别（OCR）引擎，它可以将图像中的文字转换为计算机可读的文本。支持多种语言和书面语言，并且可以在命令行中执行。它是一个流行的开源OCR工具，可以在许多不同的操作系统上运行。Tess4J是一个基于Tesseract OCR引擎的Java接口，可以用来识别图像中的文本，说白了，就是封装了它的API，让Java可以直接调用。 Tess
阅读更多...
哈希表的封装和位图

哈希表的封装和位图

文章目录 2 封装2.1 基础框架2.2 迭代器(1)2.3 迭代器(2) 3. 位图3.1 问题引入3.2 左移和右移？3.3 位图的实现3.4 位图的题目3.5 位图的应用 2 封装 2.1 基础框架 文章 有了前面map和set封装的经验，容易写出下面的代码 // UnorderedSet.h#pragma once#include "HashTable.h"
阅读更多...
封装MySQL操作时Where条件语句的组织

封装MySQL操作时Where条件语句的组织

在对数据库进行封装的过程中，条件语句应该是相对难以处理的，毕竟条件语句太过于多样性。 条件语句大致分为以下几种： 1、单一条件，比如：where id = 1; 2、多个条件，相互间关系统一。比如：where id > 10 and age > 20 and score < 60; 3、多个条件，相互间关系不统一。比如：where (id > 10 OR age > 20) AND sco
阅读更多...
使用Spring Boot集成Spring Data JPA和单例模式构建库存管理系统

使用Spring Boot集成Spring Data JPA和单例模式构建库存管理系统

引言 在企业级应用开发中，数据库操作是非常重要的一环。Spring Data JPA提供了一种简化的方式来进行数据库交互，它使得开发者无需编写复杂的JPA代码就可以完成常见的CRUD操作。此外，设计模式如单例模式可以帮助我们更好地管理和控制对象的创建过程，从而提高系统的性能和可维护性。本文将展示如何结合Spring Boot、Spring Data JPA以及单例模式来构建一个基本的库存管理系统
阅读更多...
Spring Boot集成PDFBox实现电子签章

Spring Boot集成PDFBox实现电子签章

概述 随着无纸化办公的普及，电子文档的使用越来越广泛。电子签章作为一种有效的身份验证方式，在很多场景下替代了传统的纸质文件签名。Apache PDFBox 是一个开源的Java库，可以用来渲染、生成、填写PDF文档等操作。本文将介绍如何使用Spring Boot框架结合PDFBox来实现电子签章功能。 准备工作 环境搭建：确保你的开发环境中安装了JDK 8或更高版本，并且配置好了Maven或
阅读更多...
springboot+maven搭建的项目，集成单元测试

springboot+maven搭建的项目，集成单元测试

springboot+maven搭建的项目，集成单元测试 1.在pom.xml文件中引入单元测试的依赖包 <!--单元测试依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></depen
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2