0
点赞
收藏
分享

微信扫一扫

一些常用的 redis 的操作配置(对String、hash)

小亦同学321 2022-08-31 阅读 231

import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
* 配置一些常用的 redis 的操作
*/
public class RedisClient {

private Logger log = LogManager.getLogger(RedisClient.class);

private JedisPool jedisPool;


public void set(String key, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.set(key, value);
}catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public String get(String key) {

Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.get(key);
} catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public void hset(String key, String field, String value){
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.hset(key, field, value);
}catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public String hget(String key, String field) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.hget(key, field);
} catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public void hmset(String key, Map<String, String> hash){
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.hmset(key, hash);
}catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public List<String> hmget(String key, String... fields) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.hmget(key, fields);
} catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
if(null != jedis){
jedis.close();
}
}
}

public Long del(String key) {

Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.del(key);
} catch (Exception e){
log.error(e.getMessage(),e);
throw e;
}finally {
jedis.close();
}

}


public JedisPool getJedisPool() {
return jedisPool;
}

public void setJedisPool(JedisPool jedisPool) {
this.jedisPool = jedisPool;
}
}

举报

相关推荐

0 条评论