REDISUTILS说明

/**

 * 演示Jedis连接池

 * 客户端

 */

public class Demo01 {

public static void main(String[] args) {

//NO1)创建Jedis连接池配置对象，类似到c3p0-config.xml文件

JedisPoolConfig config = new JedisPoolConfig();

//NO2)创建Jedis连接池

//设置连接池最多存入10个Jedis对象

config.setMaxTotal(10);

//从连接池中取出Jedis对象最多等2秒

config.setMaxWaitMillis(2000);

//NO3)从Jedis连接池中取出一个Jedis对象

JedisPool pool = new JedisPool(config,“127.0.0.1”,6379);

//NO4)使用Jedis对象操作Redis数据库

Jedis jedis = pool.getResource();

//选择15号数据库

jedis.select(15);

//根据key找value

String username = jedis.get(“username”);

//如果value找到了

if(username != null){

//删除该key

jedis.del(“username”);

}

//NO5)将Jedis对象还回给Jedis连接池

jedis.close();

}

}

/**

 * 演示通过JedisUtils来获取,操作,关闭Jedis对象

 * 客户端

 */

public class Demo01 {

public static void main(String[] args) throws Exception{

//获取Jedis对象

Jedis jedis = JedisUtil.getJedis();

//使用Jedis对象操作Redis数据库

jedis.set(“address”,“长沙”);

//关闭Jedis对象

JedisUtil.close(jedis);

}

}

 

package com.itheima.redis.util;

 

import java.util.ResourceBundle;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

 

/**

 * Jedis工具类

 */

public final class JedisUtil {

private static JedisPool pool;

private static String maxTotal;

private static String maxWaitMillis;

private static String host;

private static String port;

/**

 * 读取src/jedis.properties属性文件中的内容

 */

static{

//ResourceBundle专用于去类路径下找*.properties文件，所以扩展名properties可以不写

//建议项目中的配置文件放在src目录下

ResourceBundle rb = ResourceBundle.getBundle(“jedis”);

//根据key找value

maxTotal = rb.getString(“maxTotal”);

maxWaitMillis = rb.getString(“maxWaitMillis”);

host = rb.getString(“host”);

port = rb.getString(“port”);

}

/**

 * 创建连接池对象

 */

static{

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxTotal(Integer.parseInt(maxTotal));

config.setMaxWaitMillis(Integer.parseInt(maxWaitMillis));

pool = new JedisPool(config,host,Integer.parseInt(port));

}

private JedisUtil(){

}

/**

 * 获取Jedis对象

 */

public static Jedis getJedis() throws Exception{

//如果连接池非空

if(pool != null){

//从连接池中获取Jedis对象

return pool.getResource();

}else{

//return null;

//抛异常

throw new Exception(“Jedis不能为空”);

}

}

/**

 * 关闭Jedis对象

 */

public static void close(Jedis jedis) {

if(jedis != null){

jedis.close();

}

}

}