Alawn/springboot-payment
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

merge

Browse Source
This commit is contained in:
xiangwb
2017-11-03 15:41:52 +08:00
commit 79549977df
58 changed files with 4342 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
boot-service/src/main/java/com/xwbing/redis/RedisService.java
+384
View File
@@ -0,0 +1,384 @@
package com.xwbing.redis;
/**
* 说明: 封装redis 缓存服务器服务接口
* 项目名称: sbdemo
* 创建时间: 2017/5/5 16:44
* 作者: xiangwb
*/
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.PropertySource;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import java.util.List;
import java.util.Map;
import java.util.Set;
@Component
@PropertySource("classpath:redis.properties")
public class RedisService {
@Autowired
private JedisPool jedisPool;
@Value("${redisCode}")
private String redisCode;
private RedisService() {
}
/**
* 获取一个jedis 客户端
*
* @return
*/
private Jedis getJedis() {
return jedisPool.getResource();
}
/**
* 释放Jedis资源
*
* @param jedis
*/
private void returnJedies(Jedis jedis) {
if (null != jedis) {
jedis.close();
}
}
////////////////////////////////////////string////////////////////////////////////////
/**
* 添加key value
*
* @param key
* @param value
*/
public void set(String key, String value) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
jedis.set(key, value);
} finally {
returnJedies(jedis);
}
}
/**
* 添加key value 并且设置存活时间
*
* @param key
* @param value
* @param liveTime
*/
public void set(String key, String value, int liveTime) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
jedis.setex(key, liveTime, value);
} finally {
returnJedies(jedis);
}
}
/**
* 获取redis value (String)
*
* @param key
* @return
*/
public String get(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
String value = jedis.get(key);
return value;
} finally {
returnJedies(jedis);
}
}
/**
* 通过正则匹配keys
*
* @param pattern
* @return
*/
public Set<String> keys(String pattern) {
Jedis jedis = null;
try {
jedis = getJedis();
return jedis.keys(pattern);
} finally {
returnJedies(jedis);
}
}
////////////////////////////////////////list////////////////////////////////////////
/**
* 添加数据到list
*
* @param list
* @param values
*/
public void lpush(String list, String... values) {
Jedis jedis = null;
try {
jedis = getJedis();
list = redisCode + list;
jedis.lpush(list, values);
} finally {
returnJedies(jedis);
}
}
/**
* 获取list
*
* @param key
* @return
*/
public List<String> lrange(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
return jedis.lrange(key, 0, -1);
} finally {
returnJedies(jedis);
}
}
////////////////////////////////////////map////////////////////////////////////////
/**
* 存map
*
* @param key
* @param hash
* @return
*/
public String hmset(String key, Map<String, String> hash) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
return jedis.hmset(key, hash);
} finally {
returnJedies(jedis);
}
}
/**
* 获取map
*
* @param map
* @return
*/
public Map<String, String> hgetAll(String map) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
return jedis.hgetAll(map);
} finally {
returnJedies(jedis);
}
}
/**
* 添加数据到指定map
*
* @param map
* @param key
* @param value
*/
public void hset(String map, String key, String value) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
jedis.hset(key, map, value);
} finally {
returnJedies(jedis);
}
}
/**
* 获取指定map的值
*
* @param map
* @param key
* @return
*/
public String hget(String map, String key) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
return jedis.hget(key, map);
} finally {
returnJedies(jedis);
}
}
/**
* 删除指定map的值
*
* @param map
* @param key
*/
public void hdel(String map, String key) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
jedis.hdel(key, map);
} finally {
returnJedies(jedis);
}
}
/**
* 获取指定map中所有的keys
*
* @param map
*/
public Set<String> hkeys(String map) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
return jedis.hkeys(map);
} finally {
returnJedies(jedis);
}
}
/**
* 获取指定map中所有的values
*
* @param map
*/
public List<String> hvals(String map) {
Jedis jedis = null;
try {
jedis = getJedis();
map = redisCode + map;
return jedis.hvals(map);
} finally {
returnJedies(jedis);
}
}
///////////////////////////////////public/////////////////////////////////////////////////
/**
* 通过key删除
*
* @param key
*/
public void del(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
jedis.del(key);
} finally {
returnJedies(jedis);
}
}
/**
* 初始化的时候删除
*
* @param key
*/
public void delInit(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
jedis.del(key);
} finally {
returnJedies(jedis);
}
}
/**
* 检查key是否已经存在
*
* @param key
* @return
*/
public boolean exists(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
key = redisCode + key;
return jedis.exists(key);
} finally {
returnJedies(jedis);
}
}
/**
* 刷新缓存
*/
public void flushAll() {
Jedis jedis = null;
try {
jedis = getJedis();
jedis.flushAll();
} finally {
returnJedies(jedis);
}
}
/**
* 清空redis 所有数据
*
* @return
*/
public String flushDB() {
Jedis jedis = null;
try {
jedis = getJedis();
return jedis.flushDB();
} finally {
returnJedies(jedis);
}
}
/**
* 查看redis里有多少数据
*/
public long dbSize() {
Jedis jedis = null;
try {
jedis = getJedis();
return jedis.dbSize();
} finally {
returnJedies(jedis);
}
}
/**
* 检查是否连接成功
*
* @return
*/
public String ping() {
Jedis jedis = null;
try {
jedis = getJedis();
return jedis.ping();
} finally {
returnJedies(jedis);
}
}
}