redis队列 Redis存储/取尽值，获取最新值

 /**
     * 取尽存储的值，获取最新值
     *
     * @param key
     * @return
     */
    @Override
    public String popData(String key) {
        List<String> list = new ArrayList<>();
        String popDataKey = RedisKeyPrefix.getPopDataKey(key);
        // 同步锁
        boolean lockStatus = redistemplate.opsForValue().setIfAbsent(popDataKey, 1, 5, TimeUnit.SECONDS);
        if (!lockStatus) {
            return null;
        }
        while (redistemplate.hasKey(key)) {
            Object data = redistemplate.opsForList().leftPop(key);
            if (data != null) {
                list.add(data.toString());
            }
        }
        redistemplate.delete(popDataKey);
        if (CollectionUtils.isEmpty(list)) {
            return null;
        }
        return list.get(list.size() - 1);
    }

 

 

 // 存储值
public void pushData(String key, String value) {
        redistemplate.opsForList().rightPush(key, value);
    }

 

 // 取尽存储的值
public List<String> popAllData(String key) {
        List<String> list = new ArrayList<>();
        while (redistemplate.hasKey(key)) {
            Object data = redistemplate.opsForList().leftPop(key);
            if (data != null) {
                list.add(data.toString());
            }
        }
        return list;
    }

 

// CURD

    /**
     * 新增或更新
     *
     * @param key
     * @param value
     */
    public void setorUpdateData(String key, String value) {
        redistemplate.opsForValue().set(key, value);
    }


    /**
     * 获取值
     *
     * @param key
     * @return
     */
    public String getData(String key) {
        return (String) redistemplate.opsForValue().get(key);
    }

    /**
     * 批量删除
     *
     * @param key 前缀
     */
    public void deleteData(String key) {
        redistemplate.delete(redistemplate.keys(key + "*"));

    }