package com.bond.match.utils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import redis.clients.jedis.BinaryClient;
import redis.clients.jedis.BinaryClient;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* Created with IntelliJ IDEA.
* User: 胡霞潮
* Date: 2017/12/25 0025
* Time: 10:46
* To change this template use File | Settings | File Templates.
*/
@SuppressWarnings("unchecked")
@Component
public class RedisUtils {
@Autowired
private JedisPool jedisPool;
public boolean exists(String key){
boolean value=false;
Jedis jedis=null;
try{
jedis=jedisPool.getResource();
value=jedis.exists(key);
}catch (Exception e){
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
}finally {
close(jedis);
}
return value;
}
/**
* 获取数据
* @param key
* @return
*/
public String get(String key){
String value=null;
Jedis jedis=null;
try{
jedis=jedisPool.getResource();
value=jedis.get(key);
}catch (Exception e){
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
}finally {
close(jedis);
}
return value;
}
public void del(String key) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.del(key);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
public void set(String key, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.set(key, value);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
public void set(String key, String value, int time) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.set(key, value);
jedis.expire(key, time);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
public void hset(String key, String field, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.hset(key, field, value);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
/**
* 获取数据
*
* @param key
* @return
*/
public String hget(String key, String field) {
String value = null;
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
value = jedis.hget(key, field);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
return value;
}
public void hdel(String key, String field) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.hdel(key, field);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
/**
* 存储REDIS队列 顺序存储
* @param key reids键名
* @param value 键值
*/
public void lpush(String key, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.lpush(key, value);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
}
/**
* 移除队列中出现第一个数据
* @param key
* @param value
* @return
*/
public long lrem(String key, String value){
Jedis jedis = null;
long l =0 ;
try{
jedis = jedisPool.getResource();
l = jedis.lrem(key,1,value);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
return l;
}
/**
* 存储REDIS队列 反向存储
* @param key reids键名
* @param value 键值
*/
public long rpush(String key, String value) {
Jedis jedis = null;
long flage=0;
try {
jedis = jedisPool.getResource();
flage = jedis.rpush(key, value);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
return flage;
}
/**
* 存储REDIS队列 反向存储
* @param key reids键名
* @param value 键值
*/
public long rpush(String key, String value,int seconds) {
Jedis jedis = null;
long flage=0;
try {
jedis = jedisPool.getResource();
flage = jedis.rpush(key, value);
jedis.expire(key, seconds);
} catch (Exception e) {
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
return flage;
}
/**
* 在列表的元素前或者后插入元素，返回List的长度
* @param key
* @param where LIST_POSITION LIST_POSITION.BEFORE之前添加；LIST_POSITION.AFTER之后添加
* @param pivot 以该元素作为参照物，是在它之前，还是之后
* @param value
* @return Long
*/
public long linsert(String key, BinaryClient.LIST_POSITION where, String pivot, String value){
Jedis jedis = null;
long flage=0;
try {
jedis = jedisPool.getResource();
flage = jedis.linsert(key, where, pivot, value);
} catch (Exception e) {
flage = -1;
//释放redis对象
jedisPool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//返还到连接池
close(jedis);
}
return flage;
}
/**
* 将一个或多个值插入到已存在的列表头部，当成功时，返回List的长度；当不成功（即key不存在时，返回0）
* @param key
* @param value String
* @return Long
*/
public long lpushx(String key, String value){
Jedis jedis = null;
