//package com.ruoyi.doublePrevention.config.redis;
|
//
|
//
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.data.redis.connection.RedisClusterConnection;
|
//import org.springframework.data.redis.connection.RedisClusterNode;
|
//import org.springframework.data.redis.connection.RedisConnection;
|
//import org.springframework.data.redis.connection.RedisConnectionFactory;
|
//import org.springframework.data.redis.connection.jedis.JedisClusterConnection;
|
//import org.springframework.data.redis.connection.jedis.JedisConnection;
|
//import org.springframework.data.redis.core.*;
|
//import org.springframework.stereotype.Repository;
|
//
|
//import javax.annotation.PostConstruct;
|
//import javax.annotation.Resource;
|
//import java.io.Serializable;
|
//import java.util.HashSet;
|
//import java.util.Iterator;
|
//import java.util.List;
|
//import java.util.Set;
|
//import java.util.concurrent.TimeUnit;
|
//
|
///**
|
//* @Description: redis工具类
|
//*/
|
//
|
//@Repository("configRedisRepository")
|
//@SuppressWarnings(value = { "unchecked", "rawtypes" })
|
//public class RedisUtils {
|
//
|
//
|
// @Resource
|
// private RedisTemplate redisTemplate;
|
// /**
|
// * logger
|
// */
|
// private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
//
|
//
|
// @PostConstruct
|
// public void initRepository(){
|
// try {
|
// this.set("test:module:Web", "testConnection", 60L, TimeUnit.SECONDS);
|
// logger.info("[ModuleRedis][Web] is connected");
|
// } catch (Exception e) {
|
// logger.error("[ModuleRedis][Web] connected failed!!");
|
// }
|
// }
|
//
|
// /**
|
// * 写入缓存
|
// * @param key
|
// * @param value
|
// * @return
|
// */
|
// public boolean set(final String key, Object value) {
|
// boolean result = false;
|
// try {
|
// ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
|
// operations.set(key, value);
|
// result = true;
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// return result;
|
// }
|
// /**
|
// * 写入缓存设置时效时间
|
// * @param key
|
// * @param value
|
// * @return
|
// */
|
// public boolean set(final String key, Object value, Long expireTime ,TimeUnit timeUnit) {
|
// boolean result = false;
|
// try {
|
// ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
|
// operations.set(key, value);
|
// redisTemplate.expire(key, expireTime, timeUnit);
|
// result = true;
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// return result;
|
// }
|
// /**
|
// * 批量删除对应的value
|
// * @param keys
|
// */
|
// public void remove(final String... keys) {
|
// for (String key : keys) {
|
// remove(key);
|
// }
|
// }
|
// /**
|
// * 批量删除key
|
// * @param pattern
|
// */
|
// public void removePattern(final String pattern) {
|
// Set<Serializable> keys = redisTemplate.keys(pattern);
|
// if (keys.size() > 0){
|
// redisTemplate.delete(keys);
|
// }
|
// }
|
// /**
|
// * 删除对应的value
|
// * @param key
|
// */
|
// public void remove(final String key) {
|
// if (exists(key)) {
|
// redisTemplate.delete(key);
|
// }
|
// }
|
// /**
|
// * 判断缓存中是否有对应的value
|
// * @param key
|
// * @return
|
// */
|
// public boolean exists(final String key) {
|
// return redisTemplate.hasKey(key);
|
// }
|
// /**
|
// * 读取缓存
|
// * @param key
|
// * @return
|
// */
|
// public Object get(final String key) {
|
// Object result = null;
|
// ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
|
// result = operations.get(key);
|
// return result;
|
// }
|
// /**
|
// * 哈希 添加
|
// * @param key
|
// * @param hashKey
|
// * @param value
|
// */
|
// public void hmSet(String key, Object hashKey, Object value){
|
// HashOperations<String, Object, Object> hash = redisTemplate.opsForHash();
|
// hash.put(key,hashKey,value);
|
// }
|
// /**
|
// * 哈希获取数据
|
// * @param key
|
// * @param hashKey
|
// * @return
|
// */
|
// public Object hmGet(String key, Object hashKey){
|
// HashOperations<String, Object, Object> hash = redisTemplate.opsForHash();
|
// return hash.get(key,hashKey);
|
// }
|
// /**
|
// * 列表添加
|
// * @param k
|
// * @param v
|
// */
|
// public void lPush(String k,Object v){
|
// ListOperations<String, Object> list = redisTemplate.opsForList();
|
// list.rightPush(k,v);
|
// }
|
// /**
|
// * 列表获取
|
// * @param k
|
// * @param l
|
// * @param l1
|
// * @return
|
// */
|
// public List<Object> lRange(String k, long l, long l1){
|
// ListOperations<String, Object> list = redisTemplate.opsForList();
|
// return list.range(k,l,l1);
|
// }
|
// /**
|
// * 集合添加
|
// * @param key
|
// * @param value
|
// */
|
// public void add(String key,Object value){
|
// SetOperations<String, Object> set = redisTemplate.opsForSet();
|
// set.add(key,value);
|
// }
|
// /**
|
// * 集合获取
|
// * @param key
|
// * @return
|
// */
|
// public Set<Object> setMembers(String key){
|
// SetOperations<String, Object> set = redisTemplate.opsForSet();
|
// return set.members(key);
|
// }
|
// /**
|
// * 有序集合添加
|
// * @param key
|
// * @param value
|
// * @param scoure
|
// */
|
// public void zAdd(String key,Object value,double scoure){
|
// ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
|
// zset.add(key,value,scoure);
|
// }
|
// /**
|
// * 有序集合获取
|
// * @param key
|
// * @param scoure
|
// * @param scoure1
|
// * @return
|
// */
|
// public Set<Object> rangeByScore(String key,double scoure,double scoure1){
|
// ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
|
// return zset.rangeByScore(key, scoure, scoure1);
|
// }
|
//
|
// /**
|
// * @Description: 获取过期时间 返回 秒
|
// */
|
//
|
// public Long getExpireTime(String key) {
|
// return redisTemplate.getExpire(key, TimeUnit.SECONDS);
|
// }
|
//
|
//
|
// /**
|
// * @Description: 重置key 的 过期时间
|
// */
|
// public void resetKeyExpireTime(String key, Long seconds) {
|
// redisTemplate.expire(key, seconds, TimeUnit.SECONDS);
|
// }
|
//
|
// public Set<String> scanMatch(String matchKey) {
|
// Set<String> keys = new HashSet();
|
// RedisConnectionFactory connectionFactory = redisTemplate.getConnectionFactory();
|
// RedisConnection redisConnection = connectionFactory.getConnection();
|
// Cursor<byte[]> scan = null;
|
// if(redisConnection instanceof JedisClusterConnection){
|
// RedisClusterConnection clusterConnection = connectionFactory.getClusterConnection();
|
// Iterable<RedisClusterNode> redisClusterNodes = clusterConnection.clusterGetNodes();
|
// Iterator<RedisClusterNode> iterator = redisClusterNodes.iterator();
|
// while (iterator.hasNext()) {
|
// RedisClusterNode next = iterator.next();
|
// scan = clusterConnection.scan(next, ScanOptions.scanOptions().match(matchKey).count(Integer.MAX_VALUE).build());
|
// while (scan.hasNext()) {
|
// keys.add(new String(scan.next()));
|
// }
|
// scan.close();
|
// }
|
// return keys;
|
// }
|
// if(redisConnection instanceof JedisConnection){
|
// scan = redisConnection.scan(ScanOptions.scanOptions().match(matchKey).count(Integer.MAX_VALUE).build());
|
// while (scan.hasNext()){
|
// //找到一次就添加一次
|
// keys.add(new String(scan.next()));
|
// }
|
// scan.close();
|
// return keys;
|
// }
|
//
|
// return keys;
|
//}
|
//
|
//}
|
