一。添加依賴
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.6.0</version>
</dependency>
二。例子:
1.創建Jedis對象操作redis
Jedis jedis = new Jedis("127.0.0.1", 6379);
// 向redis中添加數據
jedis.set("mytest", "123bin");
// 從redis中讀取數據
String value = jedis.get("mytest");
// 關閉連接
jedis.close();
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
// 設置最大連接數
jedisPoolConfig.setMaxTotal(50);
JedisPool jedisPool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379);
Jedis jedis = jedisPool.getResource();
System.out.println(jedis.get("mytest"));
jedisPool.returnResource(jedis);
jedisPool.close();//注意:實際使用中。不能關閉連接池,否則執行完一次,連接池就不能使用了
// 構建連接池配置信息
JedisPoolConfig poolConfig = new JedisPoolConfig();
// 設置最大連接數
poolConfig.setMaxTotal(50);
// 定義集群信息
List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
shards.add(new JedisShardInfo("127.0.0.1", 6379));
shards.add(new JedisShardInfo("192.168.0.5", 6379));
// 定義集群連接池
ShardedJedisPool shardedJedisPool = new ShardedJedisPool(poolConfig, shards);
ShardedJedis shardedJedis = null;
try {
// 從連接池中獲取到jedis分片對象
shardedJedis = shardedJedisPool.getResource();
// for (int i = 0; i < 100; i++) {
// shardedJedis.set("key_" + i, "value_" + i);
// }
System.out.println(shardedJedis.get("key_49"));
System.out.println(shardedJedis.get("key_7"));
} catch (Exception e) {
e.printStackTrace();
} finally {
if (null != shardedJedis) {
// 關閉,檢測連接是否有效,有效則放回到連接池中,無效則重置狀態
shardedJedis.close();
}
}
// 關閉連接池
shardedJedisPool.close();