使用 Jedis 连接操作 Redis
使用 Jedis 连接操作 Redis
Redis 简介
Redis 是完全开源免费的，遵守BSD协议，是一个高性能的key-value数据库。
Redis 与其他 key - value 缓存产品有以下三个特点： Redis支持数据的持久化，可以将内存中的数据保持在磁盘中，重启的时候可以再次加载进行使用。 Redis不仅仅支持简单的key-value类型的数据，同时还提供list，set，zset，hash等数据结构的存储。 Redis支持数据的备份，即master-slave模式的数据备份。
Redis 优势
性能极高 – Redis能读的速度是110000次/s,写的速度是81000次/s 。 丰富的数据类型 – Redis支持二进制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 数据类型操作。 原子 – Redis的所有操作都是原子性的，同时Redis还支持对几个操作全并后的原子性执行。 丰富的特性 – Redis还支持 publish/subscribe, 通知, key 过期等等特性。
Redis与其他key-value存储有什么不同？
Redis有着更为复杂的数据结构并且提供对他们的原子性操作，这是一个不同于其他数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明，无需进行额外的抽象。 Redis运行在内存中但是可以持久化到磁盘，所以在对不同数据集进行高速读写时需要权衡内存，应为数据量不能大于硬件内存。在内存数据库方面的另一个优点是， 相比在磁盘上相同的复杂的数据结构，在内存中操作起来非常简单，这样Redis可以做很多内部复杂性很强的事情。 同时，在磁盘格式方面他们是紧凑的以追加的方式产生的，因为他们并不需要进行随机访问。
准备
环境安装
任选其一
CentOs7.3 搭建 Redis-4.0.1 Cluster 集群服务
测试用例
Github 代码
代码我已放到 Github ，CacheUtils.java 点击预览 CacheUtils.java
添加依赖
在项目中添加 jedis 依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>获取集群连接
private static JedisCluster jedisCluster = null;
static {
JedisPoolConfig config = new JedisPoolConfig();
//最大连接数, 默认8个
config.setMaxTotal(1000);
//大空闲连接数, 默认8个
config.setMaxIdle(10);
//获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1
config.setMaxWaitMillis(3000);
//--------以下配置默认就可以-----------
//最小空闲连接数, 默认0
config.setMinIdle(0);
//是否启用pool的jmx管理功能, 默认true
config.setJmxEnabled(true);
//是否启用后进先出, 默认true
config.setLifo(true);
//在获取连接的时候检查有效性, 默认false
config.setTestOnBorrow(false);
//在空闲时检查有效性, 默认false
config.setTestWhileIdle(false);
Set<HostAndPort> hps = new HashSet<HostAndPort>();
String redisClusterIp = "10.4.89.161:6379";
String[] ip = redisClusterIp.split(":");
int port = Integer.valueOf(ip[1]);
hps.add(new HostAndPort(ip[0], port));
jedisCluster = new JedisCluster(hps, config);
LOG.info("JedisPoolConfig:{}", JSONObject.toJSONString(config));
Map<String, JedisPool> nodes = jedisCluster.getClusterNodes();
LOG.info("Get the redis thread pool:{}", nodes.toString());
}获取单实例连接
private static Jedis jedis = null;
static {
JedisPoolConfig config = new JedisPoolConfig();
//最大连接数, 默认8个
config.setMaxTotal(1000);
//大空闲连接数, 默认8个
config.setMaxIdle(10);
//获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1
config.setMaxWaitMillis(3000);
//--------以下配置默认就可以-----------
//最小空闲连接数, 默认0
config.setMinIdle(0);
//是否启用pool的jmx管理功能, 默认true
config.setJmxEnabled(true);
//是否启用后进先出, 默认true
config.setLifo(true);
//在获取连接的时候检查有效性, 默认false
config.setTestOnBorrow(false);
//在空闲时检查有效性, 默认false
config.setTestWhileIdle(false);
JedisPool pool = new JedisPool(config, "127.0.0.1", 6379);
LOG.info("JedisPoolConfig:{}", JSONObject.toJSONString(config));
jedis = pool.getResource();
}Redis 工具类
请查看源码
代码我已放到 Github ，导入 ymq-redis 项目
github https://github.com/souyunku/ymq-example/tree/master/ymq-redis
package io.ymq.redis.jedis.utils.CacheUtils;单元测试
/**
* java JedisCluster 操作 redis 集群
*/
@Test
public void clusterTest() {
JedisClusterUtils.saveString("cluster-key", "www.ymq.io");
System.out.println(JedisClusterUtils.getString("cluster-key"));
}
/**
* java Jedis 操作 redis 单实例
*/
@Test
public void sentineTest() {
JedisSentinelUtils.saveString("sentine-key", "www.ymq.io");
System.out.println(JedisSentinelUtils.getString("sentine-key"));
}
/**
* cacheUtils 操作 redis 集群
*/
@Test
public void cacheUtilsTest() {
CacheUtils.saveString("cluster-key", "www.ymq.io");
System.out.println(CacheUtils.getString("cluster-key"));
}