|
| 1 | +package xyz.yudong520.manageadmin.core.redis; |
| 2 | + |
| 3 | +//import redis.clients.jedis.Jedis; |
| 4 | +//import redis.clients.jedis.JedisPool; |
| 5 | +//import redis.clients.jedis.JedisPoolConfig; |
| 6 | +// |
| 7 | +//import java.util.Map; |
| 8 | +//import java.util.Set; |
| 9 | + |
| 10 | +/** |
| 11 | + * 简单作用描述 |
| 12 | + * |
| 13 | + * @ProjectName: springcloudproject |
| 14 | + * @Package: com.yudong.shiro_test.redis |
| 15 | + * @Description: |
| 16 | + * @Author: yudong |
| 17 | + * @CreateDate: 2018/8/23 9:30 |
| 18 | + * @UpdateUser: yudong |
| 19 | + * @UpdateDate: 2018/8/23 9:30 |
| 20 | + * @UpdateRemark: |
| 21 | + * @Version: 1.0 |
| 22 | + * Copyright: Copyright (c) 2018 |
| 23 | + */ |
| 24 | +public class RedisDb { |
| 25 | +// |
| 26 | +// private static JedisPool jedisPool; |
| 27 | +// // session 在redis过期时间是30分钟30*60 |
| 28 | +// private static int expireTime = 1800; |
| 29 | +// // 计数器的过期时间默认2天 |
| 30 | +// private static int countExpireTime = 2*24*3600; |
| 31 | +// private static String password = "ladlee123"; |
| 32 | +// private static String redisIp = "47.92.1.158"; |
| 33 | +// private static int redisPort = 6379; |
| 34 | +// private static int maxActive = 200; |
| 35 | +// private static int maxIdle = 200; |
| 36 | +// private static long maxWait = 5000; |
| 37 | +// |
| 38 | +// static { |
| 39 | +// initPool(); |
| 40 | +// } |
| 41 | +// // 初始化连接池 |
| 42 | +// public static void initPool(){ |
| 43 | +// JedisPoolConfig config = new JedisPoolConfig(); |
| 44 | +// config.setMaxTotal(maxActive); |
| 45 | +// config.setMaxIdle(maxIdle); |
| 46 | +// config.setMaxWaitMillis(maxWait); |
| 47 | +// config.setTestOnBorrow(false); |
| 48 | +// |
| 49 | +// jedisPool = new JedisPool(config, redisIp, redisPort, 10000, password); |
| 50 | +// } |
| 51 | +// // 从连接池获取redis连接 |
| 52 | +// public static Jedis getJedis(){ |
| 53 | +// Jedis jedis = null; |
| 54 | +// try{ |
| 55 | +// jedis = jedisPool.getResource(); |
| 56 | +//// jedis.auth(password); |
| 57 | +// } catch(Exception e){ |
| 58 | +// e.printStackTrace(); |
| 59 | +//// ExceptionCapture.logError(e); |
| 60 | +// } |
| 61 | +// |
| 62 | +// return jedis; |
| 63 | +// } |
| 64 | +// // 回收redis连接 |
| 65 | +// public static void recycleJedis(Jedis jedis){ |
| 66 | +// if(jedis != null){ |
| 67 | +// try{ |
| 68 | +// jedis.close(); |
| 69 | +// } catch(Exception e){ |
| 70 | +// e.printStackTrace(); |
| 71 | +//// ExceptionCapture.logError(e); |
| 72 | +// } |
| 73 | +// } |
| 74 | +// } |
| 75 | +// // 保存字符串数据 |
| 76 | +// public static void setString(String key, String value){ |
| 77 | +// Jedis jedis = getJedis(); |
| 78 | +// if(jedis != null){ |
| 79 | +// try{ |
| 80 | +//// jedis.set(key, value); |
| 81 | +// jedis.setex(key,expireTime ,value); |
| 82 | +// } catch(Exception e){ |
| 83 | +// e.printStackTrace(); |
| 84 | +//// ExceptionCapture.logError(e); |
| 85 | +// } finally{ |
| 86 | +// recycleJedis(jedis); |
| 87 | +// } |
| 88 | +// } |
| 89 | +// |
| 90 | +// } |
| 91 | +// // 获取字符串类型的数据 |
| 92 | +// public static String getString(String key){ |
| 93 | +// Jedis jedis = getJedis(); |
| 94 | +// String result = ""; |
| 95 | +// if(jedis != null){ |
| 96 | +// try{ |
| 97 | +// result = jedis.get(key); |
| 98 | +// }catch(Exception e){ |
| 99 | +// e.printStackTrace(); |
| 100 | +//// ExceptionCapture.logError(e); |
| 101 | +// } finally{ |
| 102 | +// recycleJedis(jedis); |
| 103 | +// } |
| 104 | +// } |
| 105 | +// |
| 106 | +// return result; |
| 107 | +// } |
| 108 | +// // 删除字符串数据 |
| 109 | +// public static void delString(String key){ |
| 110 | +// Jedis jedis = getJedis(); |
| 111 | +// if(jedis != null){ |
| 112 | +// try{ |
| 113 | +// jedis.del(key); |
| 114 | +// }catch(Exception e){ |
| 115 | +// e.printStackTrace(); |
| 116 | +//// ExceptionCapture.logError(e); |
| 117 | +// } finally{ |
| 118 | +// recycleJedis(jedis); |
| 119 | +// } |
| 120 | +// } |
| 121 | +// } |
| 122 | +// // 保存byte类型数据 |
| 123 | +// public static void setObject(byte[] key, byte[] value){ |
| 124 | +// Jedis jedis = getJedis(); |
| 125 | +// String result = ""; |
| 126 | +// if(jedis != null){ |
| 127 | +// try{ |
| 128 | +// if(!jedis.exists(key)){ |
| 129 | +// jedis.set(key, value); |
| 130 | +// } |
| 131 | +// // redis中session过期时间 |
| 132 | +// jedis.expire(key, expireTime); |
| 133 | +// } catch(Exception e){ |
| 134 | +// e.printStackTrace(); |
| 135 | +//// ExceptionCapture.logError(e); |
| 136 | +// } finally{ |
| 137 | +// recycleJedis(jedis); |
| 138 | +// } |
| 139 | +// } |
| 140 | +// } |
| 141 | +// // 获取byte类型数据 |
| 142 | +// public static byte[] getObject(byte[] key){ |
| 143 | +// Jedis jedis = getJedis(); |
| 144 | +// byte[] bytes = null; |
| 145 | +// if(jedis != null){ |
| 146 | +// try{ |
| 147 | +// bytes = jedis.get(key);; |
| 148 | +// }catch(Exception e){ |
| 149 | +// e.printStackTrace(); |
| 150 | +//// ExceptionCapture.logError(e); |
| 151 | +// } finally{ |
| 152 | +// recycleJedis(jedis); |
| 153 | +// } |
| 154 | +// } |
| 155 | +// return bytes; |
| 156 | +// |
| 157 | +// } |
| 158 | +// |
| 159 | +// // 更新byte类型的数据，主要更新过期时间 |
| 160 | +// public static void updateObject(byte[] key){ |
| 161 | +// Jedis jedis = getJedis(); |
| 162 | +// if(jedis != null){ |
| 163 | +// try{ |
| 164 | +// // redis中session过期时间 |
| 165 | +// jedis.expire(key, expireTime); |
| 166 | +// }catch(Exception e){ |
| 167 | +// e.printStackTrace(); |
| 168 | +//// ExceptionCapture.logError(e); |
| 169 | +// } finally{ |
| 170 | +// recycleJedis(jedis); |
| 171 | +// } |
| 172 | +// } |
| 173 | +// |
| 174 | +// } |
| 175 | +// |
| 176 | +// // key对应的整数value加1 |
| 177 | +// public static void inc(String key){ |
| 178 | +// Jedis jedis = getJedis(); |
| 179 | +// if(jedis != null){ |
| 180 | +// try{ |
| 181 | +// if(!jedis.exists(key)){ |
| 182 | +// jedis.set(key, "1"); |
| 183 | +// jedis.expire(key, countExpireTime); |
| 184 | +// } else { |
| 185 | +// // 加1 |
| 186 | +// jedis.incr(key); |
| 187 | +// } |
| 188 | +// }catch(Exception e){ |
| 189 | +// e.printStackTrace(); |
| 190 | +//// ExceptionCapture.logError(e); |
| 191 | +// } finally{ |
| 192 | +// recycleJedis(jedis); |
| 193 | +// } |
| 194 | +// } |
| 195 | +// } |
| 196 | +// |
| 197 | +// // 获取所有keys |
| 198 | +// public static Set<String> getAllKeys(String pattern){ |
| 199 | +// Jedis jedis = getJedis(); |
| 200 | +// if(jedis != null){ |
| 201 | +// try{ |
| 202 | +// return jedis.keys(pattern); |
| 203 | +// }catch(Exception e){ |
| 204 | +// e.printStackTrace(); |
| 205 | +//// ExceptionCapture.logError(e); |
| 206 | +// } finally{ |
| 207 | +// recycleJedis(jedis); |
| 208 | +// } |
| 209 | +// } |
| 210 | +// return null; |
| 211 | +// } |
| 212 | +// |
| 213 | +// |
| 214 | +// public static void setHashObject(byte[] key,Map<byte[],byte[]> value){ |
| 215 | +// Jedis jedis = getJedis(); |
| 216 | +// if(jedis != null){ |
| 217 | +// try{ |
| 218 | +// jedis.hmset(key,value); |
| 219 | +// } catch(Exception e){ |
| 220 | +// e.printStackTrace(); |
| 221 | +//// ExceptionCapture.logError(e); |
| 222 | +// } finally{ |
| 223 | +// recycleJedis(jedis); |
| 224 | +// } |
| 225 | +// } |
| 226 | +// } |
| 227 | +} |
0 commit comments