Jedis連接Redis三種方式


1、單機模式

private String addr="192.168.1.1";
private String port="6236";
private String key="key";
private Jedis jedis=new Jedis(addr,port);//Jedis獲取到的Redis數據在jedis里,jedis.set("a","b");//更改key為a的值jedis.hmset(key,hash);
System.out.println(jedis.get(key));
2、分片模式

GenericObjectPoolConfig config=new GenericObjectPoolConfig();
config.setMaxIdle(32);
config.setMinIdle(12);
config.setTestOnBorrow(true);
config.setTestOnReturn(rtrue);
config.setTestWhileIdle(true);
List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
for (int i = 0; i < shareds.size(); i++) {
shards.add(new JedisShardInfo("192.168.0.100", 6379, 200));
}
// 構造池
ShardedJedisPool shardedJedisPool= new ShardedJedisPool(config, shards);
ShardedJedis jedis=shardedJedisPool.getResource();
jedis.set("a","b");
jedis.hmset(key, hash);
3、集群模式(since 3.0)

String[] ADDRs = conf.getString("redisIP", "10.244.84.33").split(",");//conf是讀取的配置
String[] PORTs = conf.getString("redisPort", "6379").split(",");
for (int i = 0; i < length; i++) {
HostAndPort hostAndPort = new HostAndPort(ADDRs[i], Integer.parseInt(PORTs[i]));
haps.add(hostAndPort);
}
JedisCluster myJedisCluster = new JedisCluster(haps, TIMEOUT);
     Map<String, String> gather = new HashMap<>(); //Redis中的數據是<key,value>形式,也可以是其他類型的數據
gather =myJedisCluster.hgetAll(key) ;
4. JedisUtil

從jedis 3.0.1之后,jedis使用完畢后調用jedis.close()來歸還連接,其內部調用的仍然是return resource和returnBrokenResource

public class RedisUtils {
private JedisPool jedisPool;
static {

String configurationFileName = "xxx.properties";
Configuration conf = Configuration.getConfiguration(configurationFileName);
if (conf == null) {
System.out.println("reading " + configurationFileName + " is failed.");
System.exit(-1);
}
String[] ADDRs = conf.getString("redisIP", "10.100.56.33").split(",");
String[] PORTs = conf.getString("redisPort", "6379").split(",");

if (ADDRs.length == 0 || PORTs.length == 0) {
System.out.println("definition redisIP is not found in " + configurationFileName);
System.exit(-1);
}
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxIdle(MAX_IDLE);
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config, ADDRs[0], PORT, TIMEOUT);
}

public synchronized static Jedis getJedis() {
if (jedisPool != null) {
//獲取資源
Jedis resource = jedisPool.getResource();
return resource;
} else {
return null;
}
}

public static void returnJedis(Jedis jedis) {
if (jedis != null) {
//釋放資源
jedis.close(http://www.my516.com);

}
}
}
 
---------------------


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM