redis的scan使用詳解,結合spring使用詳解

Redis的SCAN命令是一種非阻塞的迭代器,用于逐步遍歷數據庫中的鍵,特別適合處理大數據庫。下面詳細介紹其使用方法及在Spring框架中的集成方式。

SCAN命令基礎

SCAN命令的基本語法:

SCAN cursor [MATCH pattern] [COUNT count]
  • cursor:迭代游標,初始為0,每次迭代返回新的游標值。
  • MATCH pattern:可選,用于過濾鍵的模式(如user:*)。
  • COUNT count:可選,提示每次迭代返回的鍵數量(默認10)。
示例:遍歷所有鍵
SCAN 0          # 第一次調用,返回新游標和部分鍵
SCAN 123        # 使用上次返回的游標繼續迭代,直到返回0

SCAN與KEYS的對比

特性SCANKEYS
阻塞性非阻塞,分批處理阻塞,一次性返回
數據一致性可能遺漏迭代中新增的鍵快照式遍歷,無遺漏
適用場景生產環境大數據量測試環境小數據量

在Spring中使用SCAN

在Spring中,可以通過RedisTemplateStringRedisTemplate結合ScanOptions實現SCAN功能。

依賴配置

確保pom.xml包含以下依賴:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
示例代碼

以下是一個使用StringRedisTemplate實現SCAN的Service:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.ScanOptions;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;import java.util.ArrayList;
import java.util.List;@Service
public class RedisScanService {@Autowiredprivate StringRedisTemplate redisTemplate;/*** 使用SCAN命令遍歷所有符合條件的鍵* @param pattern 鍵匹配模式,如 "user:*"* @return 符合條件的鍵列表*/public List<String> scanKeys(String pattern) {List<String> keys = new ArrayList<>();RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();// 設置ScanOptions,指定匹配模式和COUNT值ScanOptions options = ScanOptions.scanOptions().match(pattern).count(100)  // 每次迭代的建議數量.build();// 使用Cursor迭代try (Cursor<byte[]> cursor = connection.scan(options)) {while (cursor.hasNext()) {keys.add(new String(cursor.next()));}} catch (Exception e) {// 處理異常e.printStackTrace();} finally {// 關閉連接(try-with-resources已自動處理)}return keys;}
}

高級用法:分頁遍歷

如果需要實現分頁功能,可以封裝SCAN的游標管理:

public class RedisPagedScanner {private final StringRedisTemplate redisTemplate;private String cursor = "0";  // 初始游標public RedisPagedScanner(StringRedisTemplate redisTemplate) {this.redisTemplate = redisTemplate;}/*** 獲取下一頁的鍵* @param pattern 匹配模式* @param pageSize 每頁大小* @return 鍵列表及是否有下一頁*/public PageResult scanNextPage(String pattern, int pageSize) {List<String> keys = new ArrayList<>();boolean hasNext = false;RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();ScanOptions options = ScanOptions.scanOptions().match(pattern).count(pageSize).build();try (Cursor<byte[]> cursor = connection.scan(options)) {while (cursor.hasNext()) {keys.add(new String(cursor.next()));}// 更新游標狀態this.cursor = cursor.getCursorId();hasNext = !cursor.isClosed();} catch (Exception e) {e.printStackTrace();}return new PageResult(keys, hasNext);}public static class PageResult {private final List<String> keys;private final boolean hasNext;public PageResult(List<String> keys, boolean hasNext) {this.keys = keys;this.hasNext = hasNext;}// getters}
}

使用注意事項

  1. COUNT參數的意義

    • COUNT只是一個提示,實際返回的鍵數量可能多于或少于該值。
    • 對于哈希、集合等復雜數據結構,COUNT指的是元素而非鍵的數量。
  2. 性能考慮

    • 避免在MATCH中使用前置通配符(如*key),會導致全量掃描。
    • 合理設置COUNT值,過大可能導致單次操作耗時過長。
  3. 事務與管道

    • SCAN是非原子操作,迭代過程中鍵可能被修改。
    • 如需原子性,可結合Redis管道(Pipeline)使用。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/diannao/88673.shtml
繁體地址,請注明出處:http://hk.pswp.cn/diannao/88673.shtml
英文地址,請注明出處:http://en.pswp.cn/diannao/88673.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Go 語言并發模式實踐

在 Go 語言并發編程中&#xff0c;合理的并發模式能顯著提升程序的可維護性和性能。本文將深入解析三種典型的并發模式實現&#xff0c;通過具體案例展示如何優雅地管理任務生命周期、資源池和工作 goroutine 池。 一、runner 模式&#xff1a;任務生命周期管理 在定時任務、…

【Java 開發日記】你會不會使用 SpringBoot 整合 Flowable 快速實現工作流呢?

目錄 1、流程引擎介紹 2、創建項目 3、畫流程圖 4、開發接口 4.1 Java 類梳理 ProcessDefinition ProcessInstance Activity Execution Task 4.2 查看流程圖 4.3 開啟一個流程 4.4 將請求提交給組長 4.5 組長審批 4.6 經理審批 4.7 拒絕流程 1、流程引擎介紹 …

面試150 分發糖果

思路 聯想貪心算法&#xff0c;遍歷兩次數組&#xff0c;一次是從左到右遍歷&#xff0c;只比較右邊孩子評分比左邊打的情況。第二次從右到左遍歷&#xff0c;只比較左邊孩子評分比右邊大的情況。最后求和即可 class Solution:def candy(self, ratings: List[int]) -> int…

csp基礎之進制轉換器

一、進制轉換要明白的基礎知識。。。 1、什么是進制&#xff1f; 進制也就是進位計數制&#xff0c;是人為定義的帶進位的計數方法。對于任何一種進制 X 進制&#xff0c;就表示每一位置上的數運算時都是逢 X 進一位。十進制是逢十進一&#xff0c;十六進制是逢十六進一&#…

Zephyr OS藍牙廣播(Advertising)功能實現

目錄 概述 1 Advertising功能介紹 1.1 實現原理 1.2 廣播類型 1.3 廣播數據格式 1.4 優化建議 1.5 常見問題和解決方法 2 Nordic 藍牙廣播&#xff08;Advertising&#xff09;功能實現 2.1 環境準備與SDK基礎 2.2 廣播功能實現 2.3 廣播優化與最佳實踐 3 實際應用案例…

服務器不支持PUT,DELETE 的解決方案

nginx 的更改&#xff1a; set $method $request_method; if ($http_X_HTTP_Method_Override ~* PUT|DELETE) { set $method $http_X_HTTP_Method_Override; } proxy_method $method; axios 的更改&#xff1a; const method config.me…

從0開始學習計算機視覺--Day04--線性分類

從宏觀來看&#xff0c;卷積網絡可以看做是由一個個不同的神經網絡組件組合而成&#xff0c;就像積木一樣通過不同類型的組件搭建形成&#xff0c;其中線性分類器是一個很重要的組件&#xff0c;在很多卷積網絡中都有用到&#xff0c;所以了解清楚它的工作原理對我們后續的學習…

基于ComfyUI與Wan2.1模型的本地化視頻生成環境搭建指南

文章目錄 前言1.軟件準備1.1 ComfyUI1.2 文本編碼器1.3 VAE1.4 視頻生成模型2.整合配置3. 本地運行測試4. 公網使用Wan2.1模型生成視頻4.1 創建遠程連接公網地址5. 固定遠程訪問公網地址總結前言 各位小伙伴們,今天我們將為您展示一套創新的人工智能應用方案!本次教程將指導…

Vue 2 項目中內嵌 md 文件

推薦方案&#xff1a;raw-loader marked 解析 Markdown 第一步&#xff1a;安裝依賴 npm install marked --save npm install raw-loader --save-dev第二步&#xff1a;配置 webpack 支持 .md 文件 打開 vue.config.js 或 webpack.config.js&#xff0c;添加以下配置&#…

Spring AI初識及簡單使用,快速上手。

Spring AI簡介 在當今這樣一個快速發展的技術時代&#xff0c;人工智能&#xff08;AI&#xff09;已經成為各行各業的一種標配。而作為一款主流的Java應用開發框架Spring&#xff0c;肯定會緊跟時代的潮流&#xff0c;所以&#xff0c;推出了Spring AI框架。 官網描述&#…

Flask中的render_template與make_response:生動解析與深度對比

文章目錄 Flask中的render_template與make_response&#xff1a;生動解析與深度對比一、&#x1f31f; 核心概念速覽二、&#xfffd; render_template - 網頁內容的主廚特點與內部機制適用場景高級用法示例 三、&#x1f381; make_response - 響應的包裝專家核心功能解析適用…

WordPress目錄說明

在WordPress建站過程中&#xff0c;理解服務器目錄結構是非常重要的。以下是一個基礎的WordPress服務器目錄指南&#xff1a; /wp-admin/ &#xff1a;這個目錄包含了WordPress網站的所有管理功能&#xff0c;包括用于處理網站后臺的所有PHP文件。 /wp-includes/ &#xff1a;…

HTTP面試題——緩存技術

目錄 HTTP緩存技術有哪些&#xff1f; 什么是強制緩存&#xff1f; 什么是協商緩存&#xff1f; HTTP緩存技術有哪些&#xff1f; 對于一些具有重復性的HTTP請求&#xff0c;比如每次請求得到的數據都是一樣的&#xff0c;我們可以把這對 請求-響應的數據都緩存在本地&#x…

virtual box 不能分配 USB設備 IFX DAS JDS TriBoard TC2X5 V2.0 [0700] 到虛擬電腦 win10

VirtualBox: Failed to attach the USB device to the virtual machine – Bytefreaks.net ISSUE&#xff1a; virtual box 不能分配 USB設備 IFX DAS JDS TriBoard TC2X5 V2.0 [0700] 到虛擬電腦 win10. USB device IFX DAS JDS TriBoard TC2X5 V2.0 with UUID {91680aeb-e1…

Deepoc大模型重構核工業智能基座:混合增強架構與安全增強決策技術?

面向復雜系統的高可靠AI賦能體系構建 Deepoc大模型通過多維度技術突破&#xff0c;顯著提升核工業知識處理與決策可靠性。經核能行業驗證&#xff0c;其生成內容可驗證性提升68%&#xff0c;關鍵參數失真率<0.3%&#xff0c;形成覆蓋核能全鏈條的定制化方案&#xff0c;使企…

第12章:冰箱里的CT掃描儀——計算機視覺如何洞穿食材的“生命密碼“

第11章:冰箱里的CT掃描儀——計算機視覺如何成為食材健康的"超級診斷官" “糟了!冰箱里草莓長出了白色絨毛,雞胸肉滲出了可疑的粉紅色液體!” 這揭示了廚房生存的更基本挑戰:如何像經驗豐富的主廚一樣,一眼洞穿食材的健康密碼? 本章將揭示計算機視覺技術如何賦…

虛幻基礎:窗口——重定向

能幫到你的話&#xff0c;就給個贊吧 &#x1f618; 文章目錄 重定向&#xff1a;給骨架添加兼容骨架。使得不同模型間復用動畫資源 重定向&#xff1a;給骨架添加兼容骨架。使得不同模型間復用動畫資源

CSS 逐幀動畫

CSS 逐幀動畫實現指南 逐幀動畫(frame-by-frame animation)是一種通過快速連續顯示一系列靜態圖像來創造運動效果的技術。以下是使用CSS實現逐幀動畫的幾種方法。 1. 使用 steps() 計時函數 這是實現逐幀動畫最常用的方法&#xff0c;通過animation-timing-function的steps(…

高版本IDEA如何開發低版本jdk項目

問題描述 我這個人比較喜歡新的東西&#xff0c;比如使用idea的時候&#xff0c;我就喜歡最新版本。 但是有個問題&#xff0c;最新版本的idea好像不支持jdk1.6&#xff0c;導致我無法去用新版本idea開發項目。 直到有一天&#xff0c;idea給了我一個提示如下&#xff0c;之…

Java設計模式->責任鏈模式的介紹

目錄 1、責任鏈模式概念 1.1、定義介紹 1.2、流程圖 1.3、優缺點 2、實現 3、應用場景 3.1、Springmvc流程 3.2、mybatis的執行流程 3.3、Spring的過濾器和攔截器 3.4、sentinel限流熔斷 3.5、aop的加載和使用 4、舉例 前言 是一種 行為型設計模式&#xff0c;它通…