scan 0 MATCH * COUNT 100 f2f3c387b9fab0e67af02039****************

package com.example.service.impl;

public class RedisServiceImpl implements RedisService {
    // scanの最大再試行回数
    private static final int MAX_RETRIES = 3;
    private final RedisConnectionFactory connectionFactory;

    @Override
    public void scanKeys(String pattern, int count) {
        try (Jedis jedis = connectionFactory.getConnection()) {
            int retryCount = 0;
            boolean scanCompleted = false;
            // scanプロセスのエラーをキャッチし、エラー発生時は0から再スキャンします。
            while (!scanCompleted && retryCount <= MAX_RETRIES) {
                String cursor = ScanParams.SCAN_POINTER_START;
                ScanParams scanParams = new ScanParams();
                scanParams.count(count);
                scanParams.match(pattern);
                try {
                    while (true) {
                        ScanResult<String> scanResult = jedis.scan(cursor, scanParams);
                        List<String> keys = scanResult.getResult();
                        if (!keys.isEmpty()) {
                            processKeysWithBusinessLogic(keys); // 業務処理
                        }
                        cursor = scanResult.getCursor();
                        // カーソルが「0」のときにスキャンが完了します。
                        if (cursor.equals(ScanParams.SCAN_POINTER_START)) {
                            scanCompleted = true;
                            break;
                        }
                    }
                } catch (Exception e) {
                    retryCount++;
                    // 最大再試行回数を超えたため、再試行を終了します。
                    if (retryCount > MAX_RETRIES) {
                        throw new RuntimeException("最大再試行回数に達したため、スキャンに失敗しました", e);
                    }
                }
            }
        }
    }
}