如何初始化Lettuce Redis客戶端庫中的MapScanCursor？

Question

我正在嘗試使用Lettuce的同步命令來執行HSCAN。問題是我無法弄清楚初始化MapScanCursor的正確方法。我對構造函數沒有成功，並且MapScanCursor.INITIAL給出了類型ScanCursor（沒有運氣把它變成MapScanCursor）。

下面是一個例子：

RedisClient redisClient = RedisClient.create("redis://" + url + ":" + port); 
RedisHashCommands<String, String> redisCommands = redisClient.connect().sync(); 
List<String> fields = new LinkedList<>(); 

MapScanCursor<String, String> scanCursor = ? 

do { 
    scanCursor = redisCommands.hscan(key, scanCursor); 
    fields.addAll(scanCursor.getMap().keySet()); 
} while (!scanCursor.isFinished()); 

我應該如何初始化 「scanCursor」？

Answer 1

你有兩個選擇：

要回答你的問題，只有hscan(key)初始化scanCursor。

MapScanCursor<String, String> scanCursor = null; 

do { 
    if (scanCursor == null) { 
     scanCursor = redisCommands.hscan(key); 
    } else { 
     scanCursor = redisCommands.hscan(key, scanCursor); 
    } 
    fields.addAll(scanCursor.getMap().keySet()); 
} while (!scanCursor.isFinished()); 

或者，你可以使用ScanIterator（見生菜4.4），這是一個Iterator，涵蓋Redis的SCAN使用的複雜性：更新了do…while基於

ScanIterator<KeyValue<String, String>> iterator = ScanIterator.hscan(redisCommands, key); 

while (iterator.hasNext()) { 

    KeyValue<String, String> next = iterator.next(); 
    // … 
} 

更新

根據tffritchman的評論的方法。