修改打包方式

648540858

2020-11-06 20f848bcecc884892dbd3a604879f597cf2681f5

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

@@ -1,13 +1,12 @@
package com.genersoft.iot.vmp.utils.redis;



import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.*;

import java.util.concurrent.TimeUnit;



import org.springframework.beans.factory.annotation.Autowired;

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

import org.springframework.dao.DataAccessException;

import org.springframework.data.redis.connection.RedisConnection;

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

import org.springframework.stereotype.Component;

import org.springframework.util.CollectionUtils;



@@ -389,6 +388,121 @@
            return 0;

        }

    }

//    ============================== ZSet ==============================



    /**

     * 添加一个元素, zset与set最大的区别就是每个元素都有一个score，因此有个排序的辅助功能;  zadd

     *

     * @param key

     * @param value

     * @param score

     */

    public void zAdd(String key, String value, double score) {

        redisTemplate.opsForZSet().add(key, value, score);

    }



    /**

     * 删除元素 zrem

     *

     * @param key

     * @param value

     */

    public void zRemove(String key, String value) {

        redisTemplate.opsForZSet().remove(key, value);

    }



    /**

     * score的增加or减少 zincrby

     *

     * @param key

     * @param value

     * @param score

     */

    public Double zIncrScore(String key, String value, double score) {

        return redisTemplate.opsForZSet().incrementScore(key, value, score);

    }



    /**

     * 查询value对应的score   zscore

     *

     * @param key

     * @param value

     * @return

     */

    public Double zScore(String key, String value) {

        return redisTemplate.opsForZSet().score(key, value);

    }



    /**

     * 判断value在zset中的排名  zrank

     *

     * @param key

     * @param value

     * @return

     */

    public Long zRank(String key, String value) {

        return redisTemplate.opsForZSet().rank(key, value);

    }



    /**

     * 返回集合的长度

     *

     * @param key

     * @return

     */

    public Long zSize(String key) {

        return redisTemplate.opsForZSet().zCard(key);

    }



    /**

     * 查询集合中指定顺序的值， 0 -1 表示获取全部的集合内容  zrange

     *

     * 返回有序的集合，score小的在前面

     *

     * @param key

     * @param start

     * @param end

     * @return

     */

    public Set<String> ZRange(String key, int start, int end) {

        return redisTemplate.opsForZSet().range(key, start, end);

    }

    /**

     * 查询集合中指定顺序的值和score，0, -1 表示获取全部的集合内容

     *

     * @param key

     * @param start

     * @param end

     * @return

     */

    public Set<ZSetOperations.TypedTuple<String>> zRangeWithScore(String key, int start, int end) {

        return redisTemplate.opsForZSet().rangeWithScores(key, start, end);

    }

    /**

     * 查询集合中指定顺序的值  zrevrange

     *

     * 返回有序的集合中，score大的在前面

     *

     * @param key

     * @param start

     * @param end

     * @return

     */

    public Set<String> zRevRange(String key, int start, int end) {

        return redisTemplate.opsForZSet().reverseRange(key, start, end);

    }

    /**

     * 根据score的值，来获取满足条件的集合  zrangebyscore

     *

     * @param key

     * @param min

     * @param max

     * @return

     */

    public Set<String> zSortRange(String key, int min, int max) {

        return redisTemplate.opsForZSet().rangeByScore(key, min, max);

    }





//    ============================== List ==============================



@@ -545,7 +659,7 @@
            return 0;

        }

    }

    


    /**

     * 模糊查询

     * @param key 键

@@ -553,11 +667,67 @@
     */

    public List<Object> keys(String key) {

        try {

           Set<String> set = redisTemplate.keys(key);

            Set<String> set = redisTemplate.keys(key);

            return new ArrayList<>(set);

        } catch (Exception e) {

            e.printStackTrace();

            return null;

        }

    }





    /**

     * 模糊查询

     * @param query 查询参数

     * @return

     */

//    public List<Object> scan(String query) {

//        List<Object> result = new ArrayList<>();

//        try {

//            Cursor<Map.Entry<Object,Object>> cursor = redisTemplate.opsForHash().scan("field",

//                    ScanOptions.scanOptions().match(query).count(1000).build());

//            while (cursor.hasNext()) {

//                Map.Entry<Object,Object> entry = cursor.next();

//                result.add(entry.getKey());

//                Object key = entry.getKey();

//                Object valueSet = entry.getValue();

//            }

//            //关闭cursor

//            cursor.close();

//        } catch (Exception e) {

//            e.printStackTrace();

//        }

//        return result;

//    }



    /**

     * 模糊查询

     * @param query 查询参数

     * @return

     */

    public List<Object> scan(String query) {

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

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

            Cursor<byte[]> cursor = connection.scan(new ScanOptions.ScanOptionsBuilder().match(query).count(1000).build());

            while (cursor.hasNext()) {

                keysTmp.add(new String(cursor.next()));

            }

            return keysTmp;

        });

//        Set<String> keys = (Set<String>) redisTemplate.execute(new RedisCallback<Set<String>>(){

//

//            @Override

//            public Set<String> doInRedis(RedisConnection connection) throws DataAccessException {

//                Set<String> keysTmp = new HashSet<>();

//                Cursor<byte[]> cursor = connection.scan(new ScanOptions.ScanOptionsBuilder().match(query).count(1000).build());

//                while (cursor.hasNext()) {

//                    keysTmp.add(new String(cursor.next()));

//                }

//            return keysTmp;

//            }

//        });



        return new ArrayList<>(keys);

    }



}