基於jedis執行緒池搭建單節點或叢集連線完整程式碼

<dependency>
     <groupId>redis.clients</groupId>
   <artifactId>jedis</artifactId>
   <version>2.9.0</version>
</dependency>

1：properties配置檔案

###########

redis.model=single
redis.url=10.128.90.60:6377
redis.testOnBorrow=true
redis.testOnReturn=true
redis.maxTotal=400
redis.maxIdle=5
redis.jmxEnable=true
redis.timeout=3000
redis.masterName=mymaster
redis.password=ustc

###########

2：jedis資訊類

-----------------------------------------------------------

package com.gccloud.www.OCTP.support.jedis;

public class JedisConfig {

public static final String SINGLE_MODEL = "single";
public static final String SENTINEL_MODEL = "sentinel";

private String model;
private String url;
private boolean testOnBorrow;
private boolean testOnReturn;
private int maxTotal;
private int maxIdle;
private boolean jmxEnable;
private int timeout;
private String masterName;
private String password;

     public static String getSingleModel() {
return SINGLE_MODEL;
}
public static String getSentinelModel() {
return SENTINEL_MODEL;
}

       //省略get、set方法

-----------------------------------------------------------

3:  jedisConfig的bean配置

*************************************

<bean id="jedisConfig" class="com.gccloud.www.OCTP.support.jedis.JedisConfig">
<!-- redis連線型別，single單節點，sentinel哨兵 模式 -->
<property name="model" value="${redis.model}" />
<!-- redis連線資訊，ip:port -->
<property name="url" value="${redis.url}" />
<!-- 檢測開關 -->
<property name="testOnBorrow" value="${redis.testOnBorrow}" />
<!-- 檢測開關 -->
<property name="testOnReturn" value="${redis.testOnReturn}" />
<!-- 最大連線數 -->
<property name="maxTotal" value="${redis.maxTotal}" />
<!-- 最大空閒 -->
<property name="maxIdle" value="${redis.maxIdle}" />
<!-- 最大連線數 -->
<property name="jmxEnable" value="${redis.jmxEnable}" />
<!-- 讀取超時時間 -->
<property name="timeout" value="${redis.timeout}" />
<!-- masterName，哨兵模式需要配置 -->
<property name="masterName" value="${redis.masterName}" />
<!-- 密碼 -->
<property name="password" value="${redis.password}" />
</bean>

*************************************

4：工廠類 JedisPoolFactory

*************************************

package com.gccloud.www.OCTP.support.jedis;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.Jedis;
import com.gccloud.www.OCTP.support.jedis.client.JedisSentinelFacotry;
import com.gccloud.www.OCTP.support.jedis.client.JedisSingleFactory;

public abstract class JedisPoolFactory {

private JedisConfig jedisConf;
private static final Logger LOGGER = LoggerFactory.getLogger(JedisPoolFactory.class);
/**
* 工廠方法
* @param jedisConf
* @return
*/
public static JedisPoolFactory getRedisFactory(JedisConfig jedisConf){

LOGGER.info("準備載入jedis物件，{}",jedisConf);

if(JedisConfig.SINGLE_MODEL.equals(jedisConf.getModel())){

LOGGER.info("載入單節點jedis物件！");

return new JedisSingleFactory(jedisConf);

}else if (JedisConfig.SENTINEL_MODEL.equals(jedisConf.getModel())){

LOGGER.info("載入哨兵模式jedis物件！");

return new JedisSentinelFacotry(jedisConf);

}else{
LOGGER.info("jedis模式未知，無法載入！");
throw new RuntimeException("jedis模式未知，無法載入！" + jedisConf);
}

}

/**
* 獲取jedis連線例項
* @return
*/
public abstract Jedis getJedis();

/**
* 歸還例項
* @param jedis
*/
public abstract void closeJedis(Jedis jedis);

}

*************************************

5-1：Sentinel模式

*************************************

import java.util.HashSet;
import java.util.Set;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisSentinelPool;
import com.gccloud.www.OCTP.support.jedis.JedisPoolFactory;
import com.gccloud.www.OCTP.support.jedis.JedisConfig;

/**
 * Sentinel模式的jedis連線
 * @author feng
 *
 */
public class JedisSentinelFacotry extends JedisPoolFactory{

private JedisConfig jedisConf;
private JedisSentinelPool jSentinelPool;
private final static Logger LOGGER = LoggerFactory.getLogger(JedisSentinelFacotry.class);

public JedisSentinelFacotry(JedisConfig jedisConf){
this.jedisConf  = jedisConf;
initPool();
}

/**
* 初始化連線池
*/
private void initPool(){

LOGGER.info("初始化 redis Sentinel連線池！ redisSentinelUrl={}",jedisConf.getUrl());

String[] urls = jedisConf.getUrl().split(",");
Set<String> urlset = new HashSet<String>();
CollectionUtils.addAll(urlset, urls);
GenericObjectPoolConfig gPoolConfig=new GenericObjectPoolConfig();
if(jedisConf.getMaxTotal() !=0 ){
gPoolConfig.setMaxTotal(jedisConf.getMaxTotal());
}
if(jedisConf.getMaxIdle() !=0){
gPoolConfig.setMaxIdle(jedisConf.getMaxIdle());
}
gPoolConfig.setJmxEnabled(jedisConf.isJmxEnable());
gPoolConfig.setTestOnBorrow(jedisConf.isTestOnBorrow());
gPoolConfig.setTestOnReturn(jedisConf.isTestOnReturn());

if(jedisConf.getPassword() != null && jedisConf.getPassword().trim().length() > 0){
jSentinelPool = new JedisSentinelPool(jedisConf.getMasterName(), urlset, gPoolConfig, jedisConf.getTimeout(), jedisConf.getPassword());
}else{
jSentinelPool = new JedisSentinelPool(jedisConf.getMasterName(), urlset, gPoolConfig, jedisConf.getTimeout());
}

LOGGER.info("jedis Sentinel連線池初始化完成！");
}


/**
* 獲取jedis連線
* @return
*/
public synchronized Jedis getJedis(){

Jedis jedis  = null;
int count =0;
do{  
            try{   
                jedis = jSentinelPool.getResource();  
            } catch (Exception e) {  
            LOGGER.error("get redis failed!", e);
            e.printStackTrace();
                 // 銷燬物件    
            jSentinelPool.returnBrokenResource(jedis);    
            }  
            count++;  
        }while(jedis==null && count<3 );  
        return jedis;

}

/**
* 歸還連線
* @param jedis
* @param redisUrl
*/
public synchronized void closeJedis(Jedis jedis) { 

        if(jedis != null) {  
            try {
            jSentinelPool.returnResource(jedis);
} catch (Exception e) {
LOGGER.error("return redis failed!", e);
jSentinelPool.returnBrokenResource(jedis);
}  
        }  
    }
}

************************************

5-2：single模式

***********************************

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.Protocol;


import com.gccloud.www.OCTP.support.jedis.JedisPoolFactory;
import com.gccloud.www.OCTP.support.jedis.JedisConfig;
public class JedisSingleFactory extends JedisPoolFactory{

private JedisConfig jedisConf;
private JedisPool jedisPool;

private static final Logger LOGGER = LoggerFactory.getLogger(JedisSingleFactory.class);

public JedisSingleFactory(JedisConfig jedisConf){
this.jedisConf = jedisConf;
initPool();

}

private void initPool() {
// TODO Auto-generated method stub

LOGGER.info("初始化 redis single連線池！ single={}",jedisConf);

String jedisUrl = jedisConf.getUrl();
String[] ipAndPort = jedisUrl.split(":");
if(ipAndPort == null || ipAndPort.length !=2){
LOGGER.error("jedis single初始化失敗，ip埠配置異常！");
throw new RuntimeException("jedis single初始化失敗，ip埠配置異常！");
}
JedisPoolConfig gPoolConfig=new JedisPoolConfig();
if(jedisConf.getMaxIdle() != 0){

gPoolConfig.setMaxIdle(jedisConf.getMaxIdle());
}
if(jedisConf.getMaxTotal()!=0){

gPoolConfig.setMaxTotal(jedisConf.getMaxTotal());
}
gPoolConfig.setJmxEnabled(jedisConf.isJmxEnable());
gPoolConfig.setTestOnBorrow(jedisConf.isTestOnBorrow());
gPoolConfig.setTestOnReturn(jedisConf.isTestOnReturn());

if(jedisConf.getPassword() != null && jedisConf.getPassword().trim().length() > 0){
jedisPool = new JedisPool(gPoolConfig, ipAndPort[0], Integer.valueOf(ipAndPort[1]), jedisConf.getTimeout(), jedisConf.getPassword(), Protocol.DEFAULT_DATABASE);
}else{
jedisPool =  new JedisPool(gPoolConfig, ipAndPort[0], Integer.valueOf(ipAndPort[1]), jedisConf.getTimeout());
}

LOGGER.info("jedis single連線池初始化完成！");
}

/**
* 獲取jedis連線
* @return
*/
public synchronized Jedis getJedis(){
Jedis jedis  = null;
int count =0;
do{  
            try{   
            LOGGER.debug("redis當前執行緒池活動數量：{},空閒數量{},等待數量{}",jedisPool.getNumActive(),jedisPool.getNumIdle());
           
                jedis = jedisPool.getResource();  
            } catch (Exception e) {  
            LOGGER.error("get redis failed!", e);
            e.printStackTrace();
                 // 銷燬物件    
            jedisPool.returnBrokenResource(jedis);    
            }  
            count++;  
        }while(jedis==null && count<3 );  
        return jedis;
}

/**
* 歸還連線
* @param jedis
* @param redisUrl
*/
public synchronized void closeJedis(Jedis jedis) { 
        if(jedis != null) {  
            try {
            jedisPool.returnResource(jedis);
} catch (Exception e) {
LOGGER.error("return redis failed!", e);
jedisPool.returnBrokenResource(jedis);
}  
        }  
    }
}

***********************************

6：main測試

***********************************

public static void main(String[] args) {

AbstractApplicationContext applicationContext = new ClassPathXmlApplicationContext("ApplicationContext.xml");
        JedisConfig jedisConf =  (JedisConfig)applicationContext.getBean("jedisConfig");
        JedisPoolFactory jedisPoolFactory = JedisPoolFactory.getRedisFactory(jedisConf);
        Jedis jedis=jedisPoolFactory.getJedis();

        jedis.set("username", "zzh");
        System.out.println(jedis.get("username"));

       System.out.println(jedis.dbSize());
       jedis.close(); 

}

*********************************

附加：jedis 事務操作 

   Transaction tran = jedis.multi(); 

   tran.del();

   tran.rpush();