Jedis在实现上是直接连接的redis server,如果在多线程环境下是非线程安全的,这个时候只有使用连接池,为每个Jedis实例增加物理连接
Lettuce的连接是基于Netty的,连接实例(StatefulRedisConnection)可以在多个线程间并发访问,应为StatefulRedisConnection是线程安全的,所以一个连接实例(StatefulRedisConnection)就可以满足多线程环境下的并发访问,当然这个也是可伸缩的设计,一个连接实例不够的情况也可以按需增加连接实例。
lettuce主要利用netty实现与redis的同步和异步通信。
先导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--lettuce pool連接池-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
配置RedisConfig
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.io.Serializable;
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory connectionFactory) {
RedisTemplate<String, Serializable> redisTemplate = new RedisTemplate<>();
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setConnectionFactory(connectionFactory);
//redisTemplate.setConnectionFactory(new JedisConnectionFactory());
return redisTemplate;
}
}
application.xml配置
# Redis数据库索引(默认为0)
spring.redis.database=0
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码(默认为空)
spring.redis.password=
# 连接池最大连接数(使用负值表示没有限制)
spring.redis.lettuce.pool.max-active=200
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.lettuce.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.lettuce.pool.max-idle=10
# 连接池中的最小空闲连接
spring.redis.lettuce.pool.min-idle=0
# 连接超时时间(毫秒)
spring.redis.timeout=1000
测试
import com.example.redis.pojo.User;
import com.example.redis.util.JedisUtil;
import com.example.redis.util.SerializeUtil;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.test.context.junit4.SpringRunner;
import redis.clients.jedis.JedisPool;
import java.io.IOException;
@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisApplicationTests {
@Autowired
private RedisTemplate redisTemplate;
/**
* 測試redisTemplate
*/
@Test
public void contextLoads() {
User user = new User(1L, "666先生的救贖", "000000001", "123456");
ValueOperations<String, User> operations = redisTemplate.opsForValue();
operations.set("maxinhai", user);
Boolean exists = redisTemplate.hasKey("maxinhai");
System.out.println("redis是否在存在相應的key: " + exists);
User user1 = (User)redisTemplate.opsForValue().get("maxinhai");
System.out.println(user1);
}
}
####华丽分割===
导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
redisConfig配置类
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
@Configuration
@Slf4j
public class JedisConfig {
@Value("${spring.redis.host}")
private String host;
@Value("${spring.redis.port}")
private int port;
@Value("${spring.redis.timeout}")
private int timeout;
@Value("${spring.redis.jedis.pool.max-idle}")
private int maxIdle;
@Value("${spring.redis.jedis.pool.max-wait}")
private long maxWaitMillis;
@Value("${spring.redis.password}")
private String password;
@Value("${spring.redis.block-when-exhausted}")
private boolean blockWhenExhausted;
@Bean
public JedisPool redisPoolFactory() throws Exception{
log.info("JedisPool注入成功!!");
log.info("redis地址:" + host + ":" + port);
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
// 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true
jedisPoolConfig.setBlockWhenExhausted(blockWhenExhausted);
// 是否启用pool的jmx管理功能, 默认true
jedisPoolConfig.setJmxEnabled(true);
/**
* 這裏password參數填null,不然會報錯(jedis連接數據庫沒設置密碼填null,填其他回報這個錯):
* Caused by: redis.clients.jedis.exceptions.JedisDataException: ERR Client sent AUTH, but no password is set
*/
JedisPool jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, null);
return jedisPool;
}
}
序列化配置类serializeConfig
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.io.*;
@Component
@Slf4j
public class SerializeUtil {
// 序列化
public static byte[] serialize(Object object) {
ObjectOutputStream oos = null;
ByteArrayOutputStream baos = null;
byte[] bytes = null;
try {
baos = new ByteArrayOutputStream();
oos = new ObjectOutputStream(baos);
oos.writeObject(object);
bytes = baos.toByteArray();
} catch (Exception e) {
System.err.println("序列化失败" + e.getMessage());
}
return bytes;
}
// 反序列化
public static Object deserialize(byte[] bytes) throws IOException, ClassNotFoundException {
ByteArrayInputStream bais = null;
ObjectInputStream ois = null;
try {
bais = new ByteArrayInputStream(bytes);
ois = new ObjectInputStream(bais);
} catch (Exception e) {
System.err.println("反序列化失败" + e.getMessage());
}
return ois.readObject();
}
}
来个 工具类
package com.example.redis.util;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.BinaryClient.LIST_POSITION;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.SortingParams;
@Component
@Slf4j
public class JedisUtil {
@Autowired
private JedisPool jedisPool;
/**
* 通过key获取储存在redis中的value
* 并释放连接
* @param key
* @param indexdb 选择redis库 0-15
* @return 成功返回value 失败返回null
*/
public String get(String key,int indexdb) {
Jedis jedis = null;
String value = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
value = jedis.get(key);
log.info(value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return value;
}
/**
* 通过key获取储存在redis中的value
* 并释放连接
* @param key
* @param indexdb 选择redis库 0-15
* @return 成功返回value 失败返回null
*/
public byte[] get(byte[] key,int indexdb) {
Jedis jedis = null;
byte[] value = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
value = jedis.get(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return value;
}
/**
* 向redis存入key和value,并释放连接资源
* 如果key已经存在 则覆盖
* @param key
* @param value
* @param indexdb 选择redis库 0-15
* @return 成功 返回OK 失败返回 0
*/
public String set(String key, String value,int indexdb) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.set(key, value);
} catch (Exception e) {
log.error(e.getMessage());
return "0";
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 向redis存入key和value,并释放连接资源
* 如果key已经存在 则覆盖
* @param key
* @param value
* @param indexdb 选择redis库 0-15
* @return 成功 返回OK 失败返回 0
*/
public String set(byte[] key, byte[] value,int indexdb) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.set(key, value);
} catch (Exception e) {
log.error(e.getMessage());
return "0";
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 删除指定的key,也可以传入一个包含key的数组
* @param keys 一个key 也可以使 string 数组
* @return 返回删除成功的个数
*/
public Long del(String... keys) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.del(keys);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 删除指定的key,也可以传入一个包含key的数组
* @param indexdb 选择redis库 0-15
* @param keys 一个key 也可以使 string 数组
* @return 返回删除成功的个数
*/
public Long del(int indexdb,String... keys) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.del(keys);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 删除指定的key,也可以传入一个包含key的数组
* @param indexdb 选择redis库 0-15
* @param keys 一个key 也可以使 string 数组
* @return 返回删除成功的个数
*/
public Long del(int indexdb,byte[]... keys) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.del(keys);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 通过key向指定的value值追加值
* @param key
* @param str
* @return 成功返回 添加后value的长度 失败 返回 添加的 value 的长度 异常返回0L
*/
public Long append(String key, String str) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.append(key, str);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* 判断key是否存在
* @param key
* @return true OR false
*/
public Boolean exists(String key) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.exists(key);
} catch (Exception e) {
log.error(e.getMessage());
return false;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* 清空当前数据库中的所有 key,此命令从不失败。
* @return 总是返回 OK
*/
public String flushDB() {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.flushDB();
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* 为给定 key 设置生存时间,当 key 过期时(生存时间为 0 ),它会被自动删除。
* @param key
* @param value
* 过期时间,单位:秒
* @return 成功返回1 如果存在 和 发生异常 返回 0
*/
public Long expire(String key, int value, int indexdb) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.expire(key, value);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 以秒为单位,返回给定 key 的剩余生存时间
* </p>
*
* @param key
* @return 当 key 不存在时,返回 -2 。当 key 存在但没有设置剩余生存时间时,返回 -1 。否则,以秒为单位,返回 key
* 的剩余生存时间。 发生异常 返回 0
*/
public Long ttl(String key,int indexdb) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
return jedis.ttl(key);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 移除给定 key 的生存时间,将这个 key 从『易失的』(带生存时间 key )转换成『持久的』(一个不带生存时间、永不过期的 key )
* </p>
*
* @param key
* @return 当生存时间移除成功时,返回 1 .如果 key 不存在或 key 没有设置生存时间,返回 0 , 发生异常 返回 -1
*/
public Long persist(String key) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.persist(key);
} catch (Exception e) {
log.error(e.getMessage());
return -1L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 新增key,并将 key 的生存时间 (以秒为单位)
* </p>
*
* @param key
* @param seconds
* 生存时间 单位:秒
* @param value
* @return 设置成功时返回 OK 。当 seconds 参数不合法时,返回一个错误。
*/
public String setex(String key, int seconds, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.setex(key, seconds, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 设置key value,如果key已经存在则返回0,nx==> not exist
* </p>
*
* @param key
* @param value
* @return 成功返回1 如果存在 和 发生异常 返回 0
*/
public Long setnx(String key, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.setnx(key, value);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 将给定 key 的值设为 value ,并返回 key 的旧值(old value)。
* </p>
* <p>
* 当 key 存在但不是字符串类型时,返回一个错误。
* </p>
*
* @param key
* @param value
* @return 返回给定 key 的旧值。当 key 没有旧值时,也即是, key 不存在时,返回 nil
*/
public String getSet(String key, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.getSet(key, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 设置key value并制定这个键值的有效期
* </p>
*
* @param key
* @param value
* @param seconds
* 单位:秒
* @return 成功返回OK 失败和异常返回null
*/
public String setex(String key, String value, int seconds) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.setex(key, seconds, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key 和offset 从指定的位置开始将原先value替换
* </p>
* <p>
* 下标从0开始,offset表示从offset下标开始替换
* </p>
* <p>
* 如果替换的字符串长度过小则会这样
* </p>
* <p>
* example:
* </p>
* <p>
* value : [email protected]
* </p>
* <p>
* str : abc
* </p>
* <P>
* 从下标7开始替换 则结果为
* </p>
* <p>
* RES : bigsea.abc.cn
* </p>
*
* @param key
* @param str
* @param offset
* 下标位置
* @return 返回替换后 value 的长度
*/
public Long setrange(String key, String str, int offset) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.setrange(key, offset, str);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 通过批量的key获取批量的value
* </p>
*
* @param keys
* string数组 也可以是一个key
* @return 成功返回value的集合, 失败返回null的集合 ,异常返回空
*/
public List<String> mget(String... keys) {
Jedis jedis = null;
List<String> values = null;
try {
jedis = jedisPool.getResource();
values = jedis.mget(keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return values;
}
/**
* <p>
* 批量的设置key:value,可以一个
* </p>
* <p>
* example:
* </p>
* <p>
* obj.mset(new String[]{"key2","value1","key2","value2"})
* </p>
*
* @param keysvalues
* @return 成功返回OK 失败 异常 返回 null
*
*/
public String mset(String... keysvalues) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.mset(keysvalues);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 批量的设置key:value,可以一个,如果key已经存在则会失败,操作会回滚
* </p>
* <p>
* example:
* </p>
* <p>
* obj.msetnx(new String[]{"key2","value1","key2","value2"})
* </p>
*
* @param keysvalues
* @return 成功返回1 失败返回0
*/
public Long msetnx(String... keysvalues) {
Jedis jedis = null;
Long res = 0L;
try {
jedis = jedisPool.getResource();
res = jedis.msetnx(keysvalues);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 设置key的值,并返回一个旧值
* </p>
*
* @param key
* @param value
* @return 旧值 如果key不存在 则返回null
*/
public String getset(String key, String value) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.getSet(key, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过下标 和key 获取指定下标位置的 value
* </p>
*
* @param key
* @param startOffset
* 开始位置 从0 开始 负数表示从右边开始截取
* @param endOffset
* @return 如果没有返回null
*/
public String getrange(String key, int startOffset, int endOffset) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.getrange(key, startOffset, endOffset);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key 对value进行加值+1操作,当value不是int类型时会返回错误,当key不存在是则value为1
* </p>
*
* @param key
* @return 加值后的结果
*/
public Long incr(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.incr(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key给指定的value加值,如果key不存在,则这是value为该值
* </p>
*
* @param key
* @param integer
* @return
*/
public Long incrBy(String key, Long integer) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.incrBy(key, integer);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 对key的值做减减操作,如果key不存在,则设置key为-1
* </p>
*
* @param key
* @return
*/
public Long decr(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.decr(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 减去指定的值
* </p>
*
* @param key
* @param integer
* @return
*/
public Long decrBy(String key, Long integer) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.decrBy(key, integer);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取value值的长度
* </p>
*
* @param key
* @return 失败返回null
*/
public Long serlen(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.strlen(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key给field设置指定的值,如果key不存在,则先创建
* </p>
*
* @param key
* @param field
* 字段
* @param value
* @return 如果存在返回0 异常返回null
*/
public Long hset(String key, String field, String value) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hset(key, field, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key给field设置指定的值,如果key不存在则先创建,如果field已经存在,返回0
* </p>
*
* @param key
* @param field
* @param value
* @return
*/
public Long hsetnx(String key, String field, String value) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hsetnx(key, field, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key同时设置 hash的多个field
* </p>
*
* @param key
* @param hash
* @return 返回OK 异常返回null
*/
public String hmset(String key, Map<String, String> hash, int indexdb) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.hmset(key, hash);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key 和 field 获取指定的 value
* </p>
*
* @param key
* @param field
* @return 没有返回null
*/
public String hget(String key, String field) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hget(key, field);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key 和 fields 获取指定的value 如果没有对应的value则返回null
* </p>
*
* @param key
* @param fields
* 可以使 一个String 也可以是 String数组
* @return
*/
public List<String> hmget(String key, int indexdb, String... fields) {
Jedis jedis = null;
List<String> res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.hmget(key, fields);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key给指定的field的value加上给定的值
* </p>
*
* @param key
* @param field
* @param value
* @return
*/
public Long hincrby(String key, String field, Long value) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hincrBy(key, field, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key和field判断是否有指定的value存在
* </p>
*
* @param key
* @param field
* @return
*/
public Boolean hexists(String key, String field) {
Jedis jedis = null;
Boolean res = false;
try {
jedis = jedisPool.getResource();
res = jedis.hexists(key, field);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回field的数量
* </p>
*
* @param key
* @return
*/
public Long hlen(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hlen(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key 删除指定的 field
* </p>
*
* @param key
* @param fields
* 可以是 一个 field 也可以是 一个数组
* @return
*/
public Long hdel(String key, String... fields) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hdel(key, fields);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回所有的field
* </p>
*
* @param key
* @return
*/
public Set<String> hkeys(String key) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hkeys(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回所有和key有关的value
* </p>
*
* @param key
* @return
*/
public List<String> hvals(String key) {
Jedis jedis = null;
List<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.hvals(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取所有的field和value
* </p>
*
* @param key
* @return
*/
public Map<String, String> hgetall(String key, int indexdb) {
Jedis jedis = null;
Map<String, String> res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.hgetAll(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key向list头部添加字符串
* </p>
*
* @param key
* @param strs
* 可以使一个string 也可以使string数组
* @return 返回list的value个数
*/
public Long lpush(int indexdb, String key, String... strs) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.lpush(key, strs);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key向list尾部添加字符串
* </p>
*
* @param key
* @param strs
* 可以使一个string 也可以使string数组
* @return 返回list的value个数
*/
public Long rpush(String key, String... strs) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.rpush(key, strs);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key在list指定的位置之前或者之后 添加字符串元素
* </p>
*
* @param key
* @param where
* LIST_POSITION枚举类型
* @param pivot
* list里面的value
* @param value
* 添加的value
* @return
*/
public Long linsert(String key, LIST_POSITION where, String pivot,
String value) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.linsert(key, where, pivot, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key设置list指定下标位置的value
* </p>
* <p>
* 如果下标超过list里面value的个数则报错
* </p>
*
* @param key
* @param index
* 从0开始
* @param value
* @return 成功返回OK
*/
public String lset(String key, Long index, String value) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.lset(key, index, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key从对应的list中删除指定的count个 和 value相同的元素
* </p>
*
* @param key
* @param count
* 当count为0时删除全部
* @param value
* @return 返回被删除的个数
*/
public Long lrem(String key, long count, String value) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.lrem(key, count, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key保留list中从strat下标开始到end下标结束的value值
* </p>
*
* @param key
* @param start
* @param end
* @return 成功返回OK
*/
public String ltrim(String key, long start, long end) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.ltrim(key, start, end);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key从list的头部删除一个value,并返回该value
* </p>
*
* @param key
* @return
*/
synchronized public String lpop(String key) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.lpop(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key从list尾部删除一个value,并返回该元素
* </p>
*
* @param key
* @return
*/
synchronized public String rpop(String key, int indexdb) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.rpop(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key从一个list的尾部删除一个value并添加到另一个list的头部,并返回该value
* </p>
* <p>
* 如果第一个list为空或者不存在则返回null
* </p>
*
* @param srckey
* @param dstkey
* @return
*/
public String rpoplpush(String srckey, String dstkey, int indexdb) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.rpoplpush(srckey, dstkey);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取list中指定下标位置的value
* </p>
*
* @param key
* @param index
* @return 如果没有返回null
*/
public String lindex(String key, long index) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.lindex(key, index);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回list的长度
* </p>
*
* @param key
* @return
*/
public Long llen(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.llen(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取list指定下标位置的value
* </p>
* <p>
* 如果start 为 0 end 为 -1 则返回全部的list中的value
* </p>
*
* @param key
* @param start
* @param end
* @return
*/
public List<String> lrange(String key, long start, long end, int indexdb) {
Jedis jedis = null;
List<String> res = null;
try {
jedis = jedisPool.getResource();
jedis.select(indexdb);
res = jedis.lrange(key, start, end);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 将列表 key 下标为 index 的元素的值设置为 value
* </p>
*
* @param key
* @param index
* @param value
* @return 操作成功返回 ok ,否则返回错误信息
*/
public String lset(String key, long index, String value) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.lset(key, index, value);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 返回给定排序后的结果
* </p>
*
* @param key
* @param sortingParameters
* @return 返回列表形式的排序结果
*/
public List<String> sort(String key, SortingParams sortingParameters) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.sort(key, sortingParameters);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 返回排序后的结果,排序默认以数字作为对象,值被解释为双精度浮点数,然后进行比较。
* </p>
*
* @param key
* @return 返回列表形式的排序结果
*/
public List<String> sort(String key) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.sort(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 通过key向指定的set中添加value
* </p>
*
* @param key
* @param members
* 可以是一个String 也可以是一个String数组
* @return 添加成功的个数
*/
public Long sadd(String key, String... members) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sadd(key, members);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key删除set中对应的value值
* </p>
*
* @param key
* @param members
* 可以是一个String 也可以是一个String数组
* @return 删除的个数
*/
public Long srem(String key, String... members) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.srem(key, members);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key随机删除一个set中的value并返回该值
* </p>
*
* @param key
* @return
*/
public String spop(String key) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.spop(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取set中的差集
* </p>
* <p>
* 以第一个set为标准
* </p>
*
* @param keys
* 可以使一个string 则返回set中所有的value 也可以是string数组
* @return
*/
public Set<String> sdiff(String... keys) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sdiff(keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取set中的差集并存入到另一个key中
* </p>
* <p>
* 以第一个set为标准
* </p>
*
* @param dstkey
* 差集存入的key
* @param keys
* 可以使一个string 则返回set中所有的value 也可以是string数组
* @return
*/
public Long sdiffstore(String dstkey, String... keys) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sdiffstore(dstkey, keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取指定set中的交集
* </p>
*
* @param keys
* 可以使一个string 也可以是一个string数组
* @return
*/
public Set<String> sinter(String... keys) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sinter(keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取指定set中的交集 并将结果存入新的set中
* </p>
*
* @param dstkey
* @param keys
* 可以使一个string 也可以是一个string数组
* @return
*/
public Long sinterstore(String dstkey, String... keys) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sinterstore(dstkey, keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回所有set的并集
* </p>
*
* @param keys
* 可以使一个string 也可以是一个string数组
* @return
*/
public Set<String> sunion(String... keys) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sunion(keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回所有set的并集,并存入到新的set中
* </p>
*
* @param dstkey
* @param keys
* 可以使一个string 也可以是一个string数组
* @return
*/
public Long sunionstore(String dstkey, String... keys) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sunionstore(dstkey, keys);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key将set中的value移除并添加到第二个set中
* </p>
*
* @param srckey
* 需要移除的
* @param dstkey
* 添加的
* @param member
* set中的value
* @return
*/
public Long smove(String srckey, String dstkey, String member) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.smove(srckey, dstkey, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取set中value的个数
* </p>
*
* @param key
* @return
*/
public Long scard(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.scard(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key判断value是否是set中的元素
* </p>
*
* @param key
* @param member
* @return
*/
public Boolean sismember(String key, String member) {
Jedis jedis = null;
Boolean res = null;
try {
jedis = jedisPool.getResource();
res = jedis.sismember(key, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取set中随机的value,不删除元素
* </p>
*
* @param key
* @return
*/
public String srandmember(String key) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.srandmember(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取set中所有的value
* </p>
*
* @param key
* @return
*/
public Set<String> smembers(String key) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.smembers(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key向zset中添加value,score,其中score就是用来排序的
* </p>
* <p>
* 如果该value已经存在则根据score更新元素
* </p>
*
* @param key
* @param score
* @param member
* @return
*/
public Long zadd(String key, double score, String member) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zadd(key, score, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 返回有序集 key 中,指定区间内的成员。min=0,max=-1代表所有元素
* </p>
*
* @param key
* @param min
* @param max
* @return 指定区间内的有序集成员的列表。
*/
public Set<String> zrange(String key, long min, long max) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.zrange(key, min, max);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return null;
}
/**
* <p>
* 统计有序集 key 中,值在 min 和 max 之间的成员的数量
* </p>
*
* @param key
* @param min
* @param max
* @return 值在 min 和 max 之间的成员的数量。异常返回0
*/
public Long zcount(String key, double min, double max) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.zcount(key, min, max);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 为哈希表 key 中的域 field 的值加上增量 increment 。增量也可以为负数,相当于对给定域进行减法操作。 如果 key
* 不存在,一个新的哈希表被创建并执行 HINCRBY 命令。如果域 field 不存在,那么在执行命令前,域的值被初始化为 0 。
* 对一个储存字符串值的域 field 执行 HINCRBY 命令将造成一个错误。本操作的值被限制在 64 位(bit)有符号数字表示之内。
* </p>
* <p>
* 将名称为key的hash中field的value增加integer
* </p>
*
* @param key
* @param value
* @param increment
* @return 执行 HINCRBY 命令之后,哈希表 key 中域 field的值。异常返回0
*/
public Long hincrBy(String key, String value, long increment) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
return jedis.hincrBy(key, value, increment);
} catch (Exception e) {
log.error(e.getMessage());
return 0L;
} finally {
returnResource(jedisPool, jedis);
}
}
/**
* <p>
* 通过key删除在zset中指定的value
* </p>
*
* @param key
* @param members
* 可以使一个string 也可以是一个string数组
* @return
*/
public Long zrem(String key, String... members) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrem(key, members);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key增加该zset中value的score的值
* </p>
*
* @param key
* @param score
* @param member
* @return
*/
public Double zincrby(String key, double score, String member) {
Jedis jedis = null;
Double res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zincrby(key, score, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回zset中value的排名
* </p>
* <p>
* 下标从小到大排序
* </p>
*
* @param key
* @param member
* @return
*/
public Long zrank(String key, String member) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrank(key, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回zset中value的排名
* </p>
* <p>
* 下标从大到小排序
* </p>
*
* @param key
* @param member
* @return
*/
public Long zrevrank(String key, String member) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrevrank(key, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key将获取score从start到end中zset的value
* </p>
* <p>
* socre从大到小排序
* </p>
* <p>
* 当start为0 end为-1时返回全部
* </p>
*
* @param key
* @param start
* @param end
* @return
*/
public Set<String> zrevrange(String key, long start, long end) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrevrange(key, start, end);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回指定score内zset中的value
* </p>
*
* @param key
* @param max
* @param min
* @return
*/
public Set<String> zrangebyscore(String key, String max, String min) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrevrangeByScore(key, max, min);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回指定score内zset中的value
* </p>
*
* @param key
* @param max
* @param min
* @return
*/
public Set<String> zrangeByScore(String key, double max, double min) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zrevrangeByScore(key, max, min);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 返回指定区间内zset中value的数量
* </p>
*
* @param key
* @param min
* @param max
* @return
*/
public Long zcount(String key, String min, String max) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zcount(key, min, max);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key返回zset中的value个数
* </p>
*
* @param key
* @return
*/
public Long zcard(String key) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zcard(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key获取zset中value的score值
* </p>
*
* @param key
* @param member
* @return
*/
public Double zscore(String key, String member) {
Jedis jedis = null;
Double res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zscore(key, member);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key删除给定区间内的元素
* </p>
*
* @param key
* @param start
* @param end
* @return
*/
public Long zremrangeByRank(String key, long start, long end) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zremrangeByRank(key, start, end);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 通过key删除指定score内的元素
* </p>
*
* @param key
* @param start
* @param end
* @return
*/
public Long zremrangeByScore(String key, double start, double end) {
Jedis jedis = null;
Long res = null;
try {
jedis = jedisPool.getResource();
res = jedis.zremrangeByScore(key, start, end);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* <p>
* 返回满足pattern表达式的所有key
* </p>
* <p>
* keys(*)
* </p>
* <p>
* 返回所有的key
* </p>
*
* @param pattern
* @return
*/
public Set<String> keys(String pattern) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
res = jedis.keys(pattern);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
public Set<String> keysBySelect(String pattern,int database) {
Jedis jedis = null;
Set<String> res = null;
try {
jedis = jedisPool.getResource();
jedis.select(database);
res = jedis.keys(pattern);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* 通过key判断值得类型
* @param key
* @return
*/
public String type(String key) {
Jedis jedis = null;
String res = null;
try {
jedis = jedisPool.getResource();
res = jedis.type(key);
} catch (Exception e) {
log.error(e.getMessage());
} finally {
returnResource(jedisPool, jedis);
}
return res;
}
/**
* 序列化对象
* @param obj
* @return
* 对象需实现Serializable接口
*/
public static byte[] ObjTOSerialize(Object obj) {
ObjectOutputStream oos = null;
ByteArrayOutputStream byteOut = null;
try {
byteOut = new ByteArrayOutputStream();
oos = new ObjectOutputStream(byteOut);
oos.writeObject(obj);
byte[] bytes = byteOut.toByteArray();
return bytes;
} catch (Exception e) {
}
return null;
}
/**
* 反序列化对象
* @param bytes
* @return
* 对象需实现Serializable接口
*/
public static Object unserialize(byte[] bytes) {
ByteArrayInputStream bais = null;
try {
//反序列化
bais = new ByteArrayInputStream(bytes);
ObjectInputStream ois = new ObjectInputStream(bais);
return ois.readObject();
} catch (Exception e) {
}
return null;
}
/**
* 返还到连接池
*
* @param jedisPool
* @param jedis
*/
public static void returnResource(JedisPool jedisPool, Jedis jedis) {
if (jedis != null) {
jedisPool.returnResource(jedis);
}
}
}
application.xml配置
# Redis数据库索引(默认为0)
spring.redis.database=0
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码(默认为空)
spring.redis.password=
# 连接超时时间(毫秒)
spring.redis.timeout=1000
# 连接池最大连接数(使用负值表示没有限制)
spring.redis.jedis.pool.max-active=200
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.jedis.pool.max-wait=1000
# 连接池中的最大空闲连接
spring.redis.jedis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.jedis.pool.min-idle=0
# 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true
spring.redis.block-when-exhausted=true
测试
import com.example.redis.pojo.User;
import com.example.redis.util.JedisUtil;
import com.example.redis.util.SerializeUtil;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.test.context.junit4.SpringRunner;
import redis.clients.jedis.JedisPool;
import java.io.IOException;
@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisApplicationTests {
@Autowired
private JedisUtil redisUtil;
@Autowired
private SerializeUtil serializeUtil;
@Autowired
private JedisPool jedisPool;
/**
* 測試jedis連接池
*/
@Test
public void testJedis() {
User user = new User(1L, "問女何所思", "000000002", "123456");
User user1 = new User(1L, "問女何所憶", "000000003", "123456");
String set = redisUtil.set("qq".getBytes(), serializeUtil.serialize(user), 0);
//jedisPool.getResource().set("qq".getBytes(), serializeUtil.serialize(user));
String set1 = redisUtil.set("weixin".getBytes(), serializeUtil.serialize(user1), 0);
//jedisPool.getResource().set("weixin".getBytes(), serializeUtil.serialize(user1));
byte[] bytes = redisUtil.get("qq".getBytes(), 0);
System.out.println("redis存放結果: " + bytes);
byte[] bytes1 = redisUtil.get("weixin".getBytes(), 0);
System.out.println("redis存放結果: " + bytes1);
try {
User user2 = (User)serializeUtil.deserialize(bytes);
System.out.println(user2);
User user3 = (User)serializeUtil.deserialize(bytes1);
System.out.println(user3);
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}
文章浏览阅读331次。第一部分:准备工作1 安装虚拟机2 安装centos73 安装JDK以上三步是准备工作,至此已经完成一台已安装JDK的主机第二部分:准备3台虚拟机以下所有工作最好都在root权限下操作1 克隆上面已经有一台虚拟机了,现在对master进行克隆,克隆出另外2台子机;1.1 进行克隆21.2 下一步1.3 下一步1.4 下一步1.5 根据子机需要,命名和安装路径1.6 ..._创建一个hadoop项目
文章浏览阅读1.7k次。心脏滴血漏洞HeartBleed CVE-2014-0160 是由heartbeat功能引入的,本文从深入码层面的分析该漏洞产生的原因_heartbleed代码分析
文章浏览阅读1.4k次。前言ofd是国家文档标准,其对标的文档格式是pdf。ofd文档是容器格式文件,ofd其实就是压缩包。将ofd文件后缀改为.zip,解压后可看到文件包含的内容。ofd文件分析工具下载:点我下载。ofd文件解压后,可以看到如下内容: 对于xml文件,可以用文本工具查看。但是对于印章文件(Seal.esl)、签名文件(SignedValue.dat)就无法查看其内容了。本人开发一款ofd内容查看器,..._signedvalue.dat
文章浏览阅读1.8w次,点赞29次,收藏313次。整体系统设计本设计主要是对ADC和DAC的使用,主要实现功能流程为:首先通过串口向FPGA发送控制信号,控制DAC芯片tlv5618进行DA装换,转换的数据存在ROM中,转换开始时读取ROM中数据进行读取转换。其次用按键控制adc128s052进行模数转换100次,模数转换数据存储到FIFO中,再从FIFO中读取数据通过串口输出显示在pc上。其整体系统框图如下:图1:FPGA数据采集系统框图从图中可以看出,该系统主要包括9个模块:串口接收模块、按键消抖模块、按键控制模块、ROM模块、D.._基于fpga的信息采集
文章浏览阅读2.5w次。1.背景错误信息:-- [http-nio-9904-exec-5] o.s.c.n.z.filters.post.SendErrorFilter : Error during filteringcom.netflix.zuul.exception.ZuulException: Forwarding error at org.springframework.cloud..._com.netflix.zuul.exception.zuulexception
文章浏览阅读358次。1.介绍图的相关概念 图是由顶点的有穷非空集和一个描述顶点之间关系-边(或者弧)的集合组成。通常,图中的数据元素被称为顶点,顶点间的关系用边表示,图通常用字母G表示,图的顶点通常用字母V表示,所以图可以定义为: G=(V,E)其中,V(G)是图中顶点的有穷非空集合,E(G)是V(G)中顶点的边的有穷集合1.1 无向图:图中任意两个顶点构成的边是没有方向的1.2 有向图:图中..._给定一个邻接矩阵未必能够造出一个图
文章浏览阅读321次。(十二)、WDS服务器安装通过前面的测试我们会发现,每次安装的时候需要加域光盘映像,这是一个比较麻烦的事情,试想一个上万个的公司,你天天带着一个光盘与光驱去给别人装系统,这将是一个多么痛苦的事情啊,有什么方法可以解决这个问题了?答案是肯定的,下面我们就来简单说一下。WDS服务器,它是Windows自带的一个免费的基于系统本身角色的一个功能,它主要提供一种简单、安全的通过网络快速、远程将Window..._doc server2012上通过wds+mdt无人值守部署win11系统.doc
文章浏览阅读219次。python–xlrd/xlwt/xlutilsxlrd只能读取,不能改,支持 xlsx和xls 格式xlwt只能改,不能读xlwt只能保存为.xls格式xlutils能将xlrd.Book转为xlwt.Workbook,从而得以在现有xls的基础上修改数据,并创建一个新的xls,实现修改xlrd打开文件import xlrdexcel=xlrd.open_workbook('E:/test.xlsx') 返回值为xlrd.book.Book对象,不能修改获取sheett_xlutils模块可以读xlsx吗
文章浏览阅读8.2w次,点赞267次,收藏656次。运行Selenium出现'WebDriver' object has no attribute 'find_element_by_id'或AttributeError: 'WebDriver' object has no attribute 'find_element_by_xpath'等定位元素代码错误,是因为selenium更新到了新的版本,以前的一些语法经过改动。..............._unresolved attribute reference 'find_element_by_id' for class 'webdriver
文章浏览阅读198次。一:模态窗口//父页面JSwindow.showModalDialog(ifrmehref, window, 'dialogWidth:550px;dialogHeight:150px;help:no;resizable:no;status:no');//子页面获取父页面DOM对象//window.showModalDialog的DOM对象var v=parentWin..._jquery获取父window下的dom对象
文章浏览阅读1.7w次,点赞15次,收藏129次。算法(algorithm)是解决一系列问题的清晰指令,也就是,能对一定规范的输入,在有限的时间内获得所要求的输出。 简单来说,算法就是解决一个问题的具体方法和步骤。算法是程序的灵 魂。二、算法的特征1.可行性 算法中执行的任何计算步骤都可以分解为基本可执行的操作步,即每个计算步都可以在有限时间里完成(也称之为有效性) 算法的每一步都要有确切的意义,不能有二义性。例如“增加x的值”,并没有说增加多少,计算机就无法执行明确的运算。 _算法
文章浏览阅读1.5k次,点赞18次,收藏26次。网络安全的标准和规范是网络安全领域的重要组成部分。它们为网络安全提供了技术依据,规定了网络安全的技术要求和操作方式,帮助我们构建安全的网络环境。下面,我们将详细介绍一些主要的网络安全标准和规范,以及它们在实际操作中的应用。_网络安全标准规范