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

2024-08-27 05:28

本文主要是介绍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)

我们可以在 RedisServiceRedisController 中实现对 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

相关文章

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》:本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景:为什么我的接口突然报错了?二、为什么会发生这个错误?1. Java 数据类型的“容量”限制

Java对象转换的实现方式汇总

《Java对象转换的实现方式汇总》:本文主要介绍Java对象转换的多种实现方式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java对象转换的多种实现方式1. 手动映射(Manual Mapping)2. Builder模式3. 工具类辅助映

SpringBoot请求参数接收控制指南分享

《SpringBoot请求参数接收控制指南分享》:本文主要介绍SpringBoot请求参数接收控制指南,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Spring Boot 请求参数接收控制指南1. 概述2. 有注解时参数接收方式对比3. 无注解时接收参数默认位置

Python的time模块一些常用功能(各种与时间相关的函数)

《Python的time模块一些常用功能(各种与时间相关的函数)》Python的time模块提供了各种与时间相关的函数,包括获取当前时间、处理时间间隔、执行时间测量等,:本文主要介绍Python的... 目录1. 获取当前时间2. 时间格式化3. 延时执行4. 时间戳运算5. 计算代码执行时间6. 转换为指

SpringBoot基于配置实现短信服务策略的动态切换

《SpringBoot基于配置实现短信服务策略的动态切换》这篇文章主要为大家详细介绍了SpringBoot在接入多个短信服务商(如阿里云、腾讯云、华为云)后,如何根据配置或环境切换使用不同的服务商,需... 目录目标功能示例配置(application.yml)配置类绑定短信发送策略接口示例:阿里云 & 腾

SpringBoot项目中报错The field screenShot exceeds its maximum permitted size of 1048576 bytes.的问题及解决

《SpringBoot项目中报错ThefieldscreenShotexceedsitsmaximumpermittedsizeof1048576bytes.的问题及解决》这篇文章... 目录项目场景问题描述原因分析解决方案总结项目场景javascript提示:项目相关背景:项目场景:基于Spring

Spring Boot 整合 SSE的高级实践(Server-Sent Events)

《SpringBoot整合SSE的高级实践(Server-SentEvents)》SSE(Server-SentEvents)是一种基于HTTP协议的单向通信机制,允许服务器向浏览器持续发送实... 目录1、简述2、Spring Boot 中的SSE实现2.1 添加依赖2.2 实现后端接口2.3 配置超时时

Spring Boot读取配置文件的五种方式小结

《SpringBoot读取配置文件的五种方式小结》SpringBoot提供了灵活多样的方式来读取配置文件,这篇文章为大家介绍了5种常见的读取方式,文中的示例代码简洁易懂,大家可以根据自己的需要进... 目录1. 配置文件位置与加载顺序2. 读取配置文件的方式汇总方式一:使用 @Value 注解读取配置方式二

一文详解Java异常处理你都了解哪些知识

《一文详解Java异常处理你都了解哪些知识》:本文主要介绍Java异常处理的相关资料,包括异常的分类、捕获和处理异常的语法、常见的异常类型以及自定义异常的实现,文中通过代码介绍的非常详细,需要的朋... 目录前言一、什么是异常二、异常的分类2.1 受检异常2.2 非受检异常三、异常处理的语法3.1 try-