Merge branch '648540858:wvp-28181-2.0' into wvp-28181-2.0

xu-bin-bin

2023-10-24 ae9976bb3a59cc3d9952dda6d9388bb412baa158

 src/main/java/com/genersoft/iot/vmp/utils/redis/RedisUtil.java

old mode 100644
new mode 100755
@@ -1,46 +1,47 @@
package com.genersoft.iot.vmp.utils.redis;



import org.springframework.data.redis.core.Cursor;

import org.springframework.data.redis.core.RedisCallback;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.ScanOptions;



import java.util.ArrayList;

import java.util.HashSet;

import java.util.List;

import java.util.Set;



/**

 * Redis工具类

 *

 * @author swwheihei

 * @date 2020年5月6日 下午8:27:29

 */

@SuppressWarnings(value = {"rawtypes", "unchecked"})

public class RedisUtil {



    /**

     * 模糊查询

     *

     * @param query 查询参数

     * @return

     */

    public static List<Object> scan(RedisTemplate redisTemplate, String query) {



        Set<String> resultKeys = (Set<String>) redisTemplate.execute((RedisCallback<Set<String>>) connection -> {

            ScanOptions scanOptions = ScanOptions.scanOptions().match("*" + query + "*").count(1000).build();

            Cursor<byte[]> scan = connection.scan(scanOptions);

            Set<String> keys = new HashSet<>();

            while (scan.hasNext()) {

                byte[] next = scan.next();

                keys.add(new String(next));

            }

            return keys;

        });



        return new ArrayList<>(resultKeys);

    }

}







package com.genersoft.iot.vmp.utils.redis;

import com.google.common.collect.Lists;
import org.springframework.data.redis.core.Cursor;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ScanOptions;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

/**
 * Redis工具类
 *
 * @author swwheihei
 * @date 2020年5月6日 下午8:27:29
 */
@SuppressWarnings(value = {"rawtypes", "unchecked"})
public class RedisUtil {

    /**
     * 模糊查询
     *
     * @param query 查询参数
     * @return
     */
    public static List<Object> scan(RedisTemplate redisTemplate, String query) {

        Set<String> resultKeys = (Set<String>) redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
            ScanOptions scanOptions = ScanOptions.scanOptions().match("*" + query + "*").count(1000).build();
            Cursor<byte[]> scan = connection.scan(scanOptions);
            Set<String> keys = new HashSet<>();
            while (scan.hasNext()) {
                byte[] next = scan.next();
                keys.add(new String(next));
            }
            return keys;
        });

        return Lists.newArrayList(resultKeys);
    }
}