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

package com.example.service.impl;

public class RedisServiceImpl implements RedisService {
    // Maximum number of scan retries
    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;
            // Catch errors during the scan process. If an error occurs, restart the scan from 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); // Business processing
                        }
                        cursor = scanResult.getCursor();
                        // The scan is complete when the cursor is "0".
                        if (cursor.equals(ScanParams.SCAN_POINTER_START)) {
                            scanCompleted = true;
                            break;
                        }
                    }
                } catch (Exception e) {
                    retryCount++;
                    // The maximum number of retries is exceeded, and the retry is terminated.
                    if (retryCount > MAX_RETRIES) {
                        throw new RuntimeException("Maximum retry count reached, scan failed", e);
                    }
                }
            }
        }
    }
}