如何在Jedis中使用SCAN命令

Question

我使用redis和jedis已经有一段时间了,到目前为止从未需要SCAN命令.但是现在我需要使用SCAN命令,特别是hscan.我理解它在redis级别上是如何工作的,但jedis Java包装器方面让我感到困惑.有ScanResults和ScanParameter类流动,我没有明确的如何正确使用它们的概念.此功能的文档不存在或至少很难找到.任何人都可以指出在哪里找到如何使用hscan使用jedis迭代哈希的正确例子？

很抱歉没有代码,但到目前为止我所尝试的内容毫无意义.

Answer 1

在回答自己问题的良好传统中,我发现了以下内容:

String key = "THEKEY";
ScanParams scanParams = new ScanParams().count(100);
String cur = redis.clients.jedis.ScanParams.SCAN_POINTER_START; 
boolean cycleIsFinished = false;
while(!cycleIsFinished) {
  ScanResult<Entry<String, String>> scanResult = 
        jedis.hscan(key, cur, scanParams);
  List<Entry<String, String>> result = scanResult.getResult();

  //do whatever with the key-value pairs in result

  cur = scanResult.getStringCursor();
  if (cur.equals("0")) {
    cycleIsFinished = true;
  }                 
}

重要的是cur是一个String变量,"0"如果扫描完成则是.

在ScanParams的帮助下,我能够定义从散列中获取的每个块的大致大小.近似,因为哈希可能在扫描期间发生变化,因此可能是循环中元素返回两次.

Answer 2

我不喜欢标志变量

Jedis jedis = new Jedis("localhost");

ScanParams scanParams = new ScanParams().count(10).match("*");
String cur = SCAN_POINTER_START;
do {
    ScanResult<String> scanResult = jedis.scan(cur, scanParams);

    // work with result
    scanResult.getResult().stream().forEach(System.out::println);
    cur = scanResult.getStringCursor();
} while (!cur.equals(SCAN_POINTER_START));