SpringBoot依赖之Spring Data Redis的功能抽离公共服务

2024-08-27 05:28
文章标签 java 依赖 springboot 功能 redis spring data 公共服务 抽离

本文主要是介绍SpringBoot依赖之Spring Data Redis的功能抽离公共服务，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前几期我们针对在SpringBoot中的 Spring Data Redis 依赖对Redis不同类型的存储格式进行了细分学习，今天在这里进行汇总，当然如果你的项目使用的是Spring Data Redis这个原生官方以来，下面的汇总类RedisService 也可以作为公共类用在你们的项目当中。

往期文章

SpringBoot依赖之Spring Data Redis 一 String类型

SpringBoot依赖之Spring Data Redis 一 List 类型

SpringBoot依赖之Spring Data Redis 一 Hash类型

SpringBoot依赖之Spring Data Redis一集合Set

SpringBoot依赖之Spring Data Redis一有序集合Sorted Set

SpringBoot依赖之Spring Data Redis实现位图Bitmap

SpringBoot依赖之Spring Data Redis 实现地理坐标(Geospatial)

我们可以在 RedisService 和 RedisController 中实现对 Redis 其他几种类型（String、List、Set、Sorted Set、Bitmap、HyperLogLog 等）的操作。以下是所有 Redis 数据类型的实现。

1. 更新 Redis 服务类

在 RedisService 类中添加所有类型的操作方法。

package com.dependencies.springdataredis;import org.springframework.data.domain.Range;
import org.springframework.data.geo.Circle;
import org.springframework.data.geo.Distance;
import org.springframework.data.geo.GeoResult;
import org.springframework.data.geo.Point;
import org.springframework.data.redis.connection.*;
import org.springframework.data.redis.core.*;
import org.springframework.stereotype.Service;import java.util.List;
import java.util.Map;
import java.util.Set;/*** @author zhizhou   2024/8/17 12:01*/
@Service
public class RedisService {private final RedisTemplate<String, Object> redisTemplate;private final HashOperations<String, String, Object> hashOperations;private final ListOperations<String, Object> listOperations;private final ValueOperations<String, Object> valueOperations;private final SetOperations<String, Object> setOperations;private final ZSetOperations<String, Object> zSetOperations;private final HyperLogLogOperations<String, Object> hyperLogLogOperations;private final GeoOperations<String, Object> geoOperations;public RedisService(RedisTemplate<String, Object> redisTemplate) {this.redisTemplate = redisTemplate;this.valueOperations = redisTemplate.opsForValue();this.hashOperations = redisTemplate.opsForHash();this.listOperations = redisTemplate.opsForList();this.setOperations = redisTemplate.opsForSet();this.zSetOperations = redisTemplate.opsForZSet();this.hyperLogLogOperations = redisTemplate.opsForHyperLogLog();this.geoOperations = redisTemplate.opsForGeo();}public void saveValue(String key, String value) {redisTemplate.opsForValue().set(key, value);}public String getValue(String key) {return (String) redisTemplate.opsForValue().get(key);}//hash// 保存哈希数据public void saveToHash(String key, String field, String value) {hashOperations.put(key, field, value);}// 从哈希中获取数据public String getFromHash(String key, String field) {return (String) hashOperations.get(key, field);}// 删除哈希中的某个字段public void deleteFromHash(String key, String field) {hashOperations.delete(key, field);}// 获取哈希中的所有键值对public Map<String, Object> getAllFromHash(String key) {return hashOperations.entries(key);}//list// 向列表左侧推入值public void pushToListLeft(String key, String value) {listOperations.leftPush(key, value);}// 向列表右侧推入值public void pushToListRight(String key, String value) {listOperations.rightPush(key, value);}// 从列表左侧弹出值public String popFromListLeft(String key) {return (String) listOperations.leftPop(key);}// 从列表右侧弹出值public String popFromListRight(String key) {return (String) listOperations.rightPop(key);}// 获取列表中所有值public List<Object> getList(String key) {return listOperations.range(key, 0, -1);}//Set// Set操作public void addToSet(String key, String value) {setOperations.add(key, value);}public Set<Object> getSetMembers(String key) {return setOperations.members(key);}public boolean isMemberOfSet(String key, String value) {return setOperations.isMember(key, value);}public void removeFromSet(String key, String value) {setOperations.remove(key, value);}// Sorted Set操作public void addToSortedSet(String key, String value, double score) {zSetOperations.add(key, value, score);}public Set<Object> getSortedSetRange(String key, long start, long end) {return zSetOperations.range(key, start, end);}public void removeFromSortedSet(String key, String value) {zSetOperations.remove(key, value);}// HyperLogLog操作public void addToHyperLogLog(String key, String value) {hyperLogLogOperations.add(key, value);}public long countInHyperLogLog(String key) {return hyperLogLogOperations.size(key);}// Bitmap操作public void setBit(String key, long offset, boolean value) {valueOperations.setBit(key, offset, value);}public boolean getBit(String key, long offset) {return valueOperations.getBit(key, offset);}private static final String GEO_KEY = "locations";// 添加地理坐标public void addLocation(String member, double longitude, double latitude) {geoOperations.add(GEO_KEY, new Point(longitude, latitude), member);}// 根据坐标查询附近的地点public List<GeoResult<RedisGeoCommands.GeoLocation<Object>>> getNearbyLocations(double longitude, double latitude, double radius) {Circle within = new Circle(new Point(longitude, latitude), new Distance(radius, RedisGeoCommands.DistanceUnit.KILOMETERS));return geoOperations.radius(GEO_KEY, within).getContent();}// 获取两地之间的距离public Distance getDistance(String member1, String member2) {return geoOperations.distance(GEO_KEY, member1, member2, RedisGeoCommands.DistanceUnit.METERS);}}

2. 更新控制器类

在 RedisController 中添加处理这些数据类型操作的端点。

package com.dependencies.springdataredis;import org.springframework.data.geo.Distance;
import org.springframework.data.geo.GeoResult;
import org.springframework.data.geo.Point;
import org.springframework.data.redis.connection.RedisGeoCommands;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Map;
import java.util.Set;/*** @author zhizhou   2024/8/17 12:02*/
@RestController
public class RedisController {private final RedisService redisService;public RedisController(RedisService redisService) {this.redisService = redisService;}@GetMapping("/set")public String setKey(@RequestParam String key, @RequestParam String value) {redisService.saveValue(key, value);return "保存成功";}@GetMapping("/get")public String getKey(@RequestParam String key) {return redisService.getValue(key);}@GetMapping("/hash/set")public String setHash(@RequestParam String key, @RequestParam String field, @RequestParam String value) {redisService.saveToHash(key, field, value);return "哈希值保存成功";}// 获取哈希中的数据@GetMapping("/hash/get")public String getHash(@RequestParam String key, @RequestParam String field) {return redisService.getFromHash(key, field);}// 删除哈希中的某个字段@GetMapping("/hash/delete")public String deleteHashField(@RequestParam String key, @RequestParam String field) {redisService.deleteFromHash(key, field);return "哈希字段已删除";}// 获取哈希中的所有字段和值@GetMapping("/hash/getall")public Map<String, Object> getAllHash(@RequestParam String key) {return redisService.getAllFromHash(key);}// 向列表左侧推入值@GetMapping("/list/leftpush")public String leftPushToList(@RequestParam String key, @RequestParam String value) {redisService.pushToListLeft(key, value);return "值被推到列表的左侧";}// 向列表右侧推入值@GetMapping("/list/rightpush")public String rightPushToList(@RequestParam String key, @RequestParam String value) {redisService.pushToListRight(key, value);return "值被推到列表的右侧";}// 从列表左侧弹出值@GetMapping("/list/leftpop")public String leftPopFromList(@RequestParam String key) {return redisService.popFromListLeft(key);}// 从列表右侧弹出值@GetMapping("/list/rightpop")public String rightPopFromList(@RequestParam String key) {return redisService.popFromListRight(key);}// 获取列表中所有值@GetMapping("/list/getall")public List<Object> getAllFromList(@RequestParam String key) {return redisService.getList(key);}// Set操作@GetMapping("/set/add")public String addToSet(@RequestParam String key, @RequestParam String value) {redisService.addToSet(key, value);return "值已加入集合set";}@GetMapping("/set/members")public Set<Object> getSetMembers(@RequestParam String key) {return redisService.getSetMembers(key);}@GetMapping("/set/ismember")public boolean isMemberOfSet(@RequestParam String key, @RequestParam String value) {return redisService.isMemberOfSet(key, value);}@GetMapping("/set/remove")public String removeFromSet(@RequestParam String key, @RequestParam String value) {redisService.removeFromSet(key, value);return "值已从集合set移除";}// Sorted Set操作@GetMapping("/zset/add")public String addToSortedSet(@RequestParam String key, @RequestParam String value, @RequestParam double score) {redisService.addToSortedSet(key, value, score);return "值已加入有序集合sorted set";}@GetMapping("/zset/range")public Set<Object> getSortedSetRange(@RequestParam String key, @RequestParam long start, @RequestParam long end) {return redisService.getSortedSetRange(key, start, end);}@GetMapping("/zset/remove")public String removeFromSortedSet(@RequestParam String key, @RequestParam String value) {redisService.removeFromSortedSet(key, value);return "值已从有序集合sorted set移除";}// HyperLogLog操作@GetMapping("/hyperloglog/add")public String addToHyperLogLog(@RequestParam String key, @RequestParam String value) {redisService.addToHyperLogLog(key, value);return "Value added to HyperLogLog";}@GetMapping("/hyperloglog/count")public long countInHyperLogLog(@RequestParam String key) {return redisService.countInHyperLogLog(key);}// Bitmap操作@GetMapping("/bitmap/set")public String setBit(@RequestParam String key, @RequestParam long offset, @RequestParam boolean value) {redisService.setBit(key, offset, value);return "Bit set in bitmap";}@GetMapping("/bitmap/get")public boolean getBit(@RequestParam String key, @RequestParam long offset) {return redisService.getBit(key, offset);}// Geo操作//添加地理位置@GetMapping("/add-location")public String addLocation(@RequestParam String member, @RequestParam double longitude, @RequestParam double latitude) {redisService.addLocation(member, longitude, latitude);return "Location added.";}//查询附近的地点@GetMapping("/nearby")public List<GeoResult<RedisGeoCommands.GeoLocation<Object>>> getNearbyLocations(@RequestParam double longitude, @RequestParam double latitude, @RequestParam double radius) {return redisService.getNearbyLocations(longitude, latitude, radius);}//# 如果使用 Lettuce 作为客户端 lettuce//获取两地之间的距离@GetMapping("/distance")public Distance getDistance(@RequestParam String member1, @RequestParam String member2) {return redisService.getDistance(member1, member2);}
}

3. 测试操作

启动项目后，可以通过以下 URL 测试各种 Redis 数据类型的功能：

  • String操作：

    • 设置值: http://localhost:8080/set?key=myKey&value=myValue

    • 获取值: http://localhost:8080/get?key=myKey

  • List操作：

    • 向列表左侧推入值: http://localhost:8080/list/leftpush?key=myList&value=value1
    • 向列表右侧推入值: http://localhost:8080/list/rightpush?key=myList&value=value2
    • 从列表左侧弹出值: http://localhost:8080/list/leftpop?key=myList
    • 从列表右侧弹出值: http://localhost:8080/list/rightpop?key=myList
    • 获取列表中所有值: http://localhost:8080/list/getall?key=myList

  • Hash操作：

    • 保存哈希数据: http://localhost:8080/hash/set?key=user:1001&field=name&value=一周一志程序员

    • 获取哈希数据: http://localhost:8080/hash/get?key=user:1001&field=name

    • 删除哈希字段: http://localhost:8080/hash/delete?key=user:1001&field=name

    • 获取所有哈希数据: http://localhost:8080/hash/getall?key=user:1001

  • Set 操作:

    • 添加成员到集合: http://localhost:8080/set/add?key=mySet&value=value1
    • 获取集合中的所有成员: http://localhost:8080/set/members?key=mySet
    • 检查成员是否在集合中: http://localhost:8080/set/ismember?key=mySet&value=value1
    • 删除集合中的成员: http://localhost:8080/set/remove?key=mySet&value=value1

  • Sorted Set 操作:

    • 添加成员到有序集合: http://localhost:8080/zset/add?key=myZSet&value=value1&score=1.0
    • 获取有序集合中的成员范围: http://localhost:8080/zset/range?key=myZSet&start=0&end=-1
    • 删除有序集合中的成员: http://localhost:8080/zset/remove?key=myZSet&value=value1

  • HyperLogLog 操作:

    • 添加成员到 HyperLogLog: http://localhost:8080/hyperloglog/add?key=myHLL&value=value1
    • 获取 HyperLogLog 的基数估算: http://localhost:8080/hyperloglog/count?key=myHLL

  • Bitmap 操作:

    • 设置 Bitmap 中某个位的值: http://localhost:8080/bitmap/set?key=myBitmap&offset=7&value=true
    • 获取 Bitmap 中某个位的值: http://localhost:8080/bitmap/get?key=myBitmap&offset=7

  • Geospatial 操作:

    • 添加地理位置：http://localhost:8080/add-location?member=location1&longitude=13.361389&latitude=38.115556
    • 查询附近的地点：http://localhost:8080/nearby?longitude=13.361389&latitude=38.115556&radius=10
    • 获取两地之间的距离： http://localhost:8080/distance?member1=location1&member2=location2

4. 总结

通过这些步骤，我们在 Spring Boot 项目中成功实现了对 Redis 各种数据类型（String、List、Set、Sorted Set、Bitmap、HyperLogLog 等）的操作。可以处理和管理 Redis 中的各种复杂数据结构，适应不同的应用场景需求。汇总到此结束。关注我一起为Java程序员蓄能，努力为职业生涯续航！

这篇关于SpringBoot依赖之Spring Data Redis的功能抽离公共服务的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

springboot集成easypoi导出word换行处理过程

springboot集成easypoi导出word换行处理过程

《springboot集成easypoi导出word换行处理过程》SpringBoot集成Easypoi导出Word时,换行符n失效显示为空格,解决方法包括生成段落或替换模板中n为回车,同时需确... 目录项目场景问题描述解决方案第一种：生成段落的方式第二种：替换模板的情况，换行符替换成回车总结项目场景s
阅读更多...
SpringBoot集成redisson实现延时队列教程

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配
阅读更多...
SpringBoot中@Value注入静态变量方式

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php
阅读更多...
SpringBoot分段处理List集合多线程批量插入数据方式

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案：通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建
阅读更多...
线上Java OOM问题定位与解决方案超详细解析

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,：本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具
阅读更多...
基于 Cursor 开发 Spring Boot 项目详细攻略

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么？基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建
阅读更多...
Python使用FastAPI实现大文件分片上传与断点续传功能

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现（FastAPI）2.1 运行环境2.2 目录结构建议2.3 serv
阅读更多...
Spring Security简介、使用与最佳实践

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security？—— 核心思想二、如何在 Java 项目中使用？——
阅读更多...
SpringBoot+RustFS 实现文件切片极速上传的实例代码

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot？二、环境准备与部署2.1 安装 RustF
阅读更多...
springboot中使用okhttp3的小结

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2