<codis><jodis>

Overview

• For codis and jodis.

Codis

• TBD...

Jodis

• Java client for codis.
• Jodis is a java client for codis based on Jedis and Curator.

Features

• Use a round robin policy to balance load to multiple codis proxies.
• Detect proxy online and offline automatically.

Usage

• pom.xml
  

  <!-- jodis -->
  		<dependency>
  			<groupId>io.codis.jodis</groupId>
  			<artifactId>jodis</artifactId>
  			<version>0.4.0</version>
  		</dependency>
  		<dependency>
  			<groupId>org.apache.curator</groupId>
  			<artifactId>curator-client</artifactId>
  			<version>3.1.0</version>
  		</dependency>
  		<dependency>
  			<groupId>org.apache.curator</groupId>
  			<artifactId>curator-recipes</artifactId>
  			<version>3.1.0</version>
  		</dependency>

• java
  

  jedisPool = RoundRobinJedisPool.create()
                          .curatorClient(CODIS_ZK_QUORUM, 30000).zkProxyDir(CODIS_ZK_PROXY_DIR).build();
  Jedis jedis = jedisPool.getResource();
  // then do something with jedis

Jedis

• 使用池可以减少系统在使用所需对象时创建对象的开销，从而提高系统性能和效率。

Usage

• conf
  

  #*****************jedis连接参数设置*********************#
  
  #redis服务器ip #   
  
  redis.ip=
  
  #redis服务器端口号#  
  
  redis.port=
  #************************jedis池参数设置*******************#  
  
  #jedis的最大分配对象#  
  
  jedis.pool.maxActive=3000
  
  #jedis最大保存idel状态对象数 #  
  
  jedis.pool.maxIdle=1000
  
  #jedis池没有对象返回时，最大等待时间 #  
  
  jedis.pool.maxWait=1500
  
  #jedis调用borrowObject方法时，是否进行有效检查#  
  
  jedis.pool.testOnBorrow=true
  
  #jedis调用returnObject方法时，是否进行有效检查 #  
  
  jedis.pool.testOnReturn=true

• java
  

  private static JedisPool pool;
  // static code to init pool conf
  static {
    try {
      Properties props = new Properties();
      props.load(MyJedisPool.class.getClassLoader().getResourceAsStream("redis.properties"));
      // create jedis pool conf instance
      JedisPoolConfig config = new JedisPoolConfig();
      
      // set confs for pool
      config.setMaxActive(Integer.valueOf(props.getProperty("jedis.pool.maxActive")));    
  
               config.setMaxIdle(Integer.valueOf(props.getProperty("jedis.pool.maxIdle")));    
  
               config.setMaxWait(Long.valueOf(props.getProperty("jedis.pool.maxWait")));    
  
               config.setTestOnBorrow(Boolean.valueOf(props.getProperty("jedis.pool.testOnBorrow")));    
  
               config.setTestOnReturn(Boolean.valueOf(props.getProperty("jedis.pool.testOnReturn")));  
      
      // create jedis pool according to confs
      pool = new JedisPool(config, props.getProperty("redis.ip"), Integer.valueOf(props.getProperty("redis.port")));
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  
  // get jedis object
  public static Jedis getJedisObject() {
    return pool.getResource();
   
  }
  
  // return jedis object
  public static void recyleJedisObject(Jedis jedis) {
    pool.returnResource(jedis);
  }
  
  // test jedis pool
  public static void main(String[] args) {
    Jedis jedis = getJedisObject();
    // oper on the jedis object
    recyleJedisObject(jedis);
  }