连接池帮助类:

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

import java.io.IOException;

import java.io.InputStream;

import java.util.Properties;

public class JedisPoolUtils {

private static JedisPool jedisPool;

static {

//1.获取配置资源

InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");

//2.加载资源

Properties pro =new Properties();

try {

pro.load(is);

} catch (IOException e) {

e.printStackTrace();

}

//3.创建连接池配置

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));

config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));

//4.创建连接池

jedisPool=new JedisPool(config,pro.getProperty("host"),Integer.parseInt(pro.getProperty("port"))

,Integer.parseInt(pro.getProperty("timeout")),pro.getProperty("password"));

}

public static Jedis getJedis(){

return jedisPool.getResource();

}

}

测试操作：

import cn.web.util.JedisPoolUtils;

import org.junit.Test;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

import java.util.List;

import java.util.Map;

import java.util.Set;

/*

* redis操作步骤：

* 1.导入Jedis包。

* 2.链接redis操作。

*

* jedis封装的操作和redis客户端操作方式是一样的

* */

public class JedisTest {

/*

* 连接测试

* */

@Test

public void test1(){

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

jedis.set("username","zhangs");

jedis.close();

}

/*

* 数据格式1：键值

* */

@Test

public void test2() throws InterruptedException {

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

//设置值，取值

jedis.set("auth","Hik1234");

String auth = jedis.get("auth");

System.out.println(auth);

//设置过期时间

jedis.setex("auth1",5,"Hik1234");

System.out.println(jedis.get("auth1"));

Thread.sleep(5000);

System.out.println(jedis.get("auth1"));

jedis.close();

}

/*

* hash:读写

* */

@Test

public void test3(){

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

//写入hash数据

jedis.hset("user", "zhangs", "20");

jedis.hset("user", "zhangs1", "21");

jedis.hset("user", "zhangs2", "22");

//读取单个数据

String hget = jedis.hget("user", "zhangs");

System.out.println(hget);

//读取全部数据

Map user = jedis.hgetAll("user");

Set strings = user.keySet();

for (String key :

strings) {

System.out.println(key+":"+user.get(key));

}

jedis.close();

}

/*

* list:数据结构

* */

@Test

public void test4(){

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

//左右压入数据

jedis.lpush("list","a");

jedis.lpush("list","b","c");

jedis.rpush("list","d","e");

//取出数据

List list = jedis.lrange("list", 0, -1);

System.out.println(list);

//弹出数据

jedis.lpop("list");

jedis.rpop("list");

System.out.println(jedis.lrange("list",0,-1));

jedis.close();

}

/*

* set:数据结构 不可重复集合

* */

@Test

public void test5(){

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

jedis.sadd("set","a","b","c");

Set set = jedis.smembers("set");

System.out.println(set);

jedis.close();

}

/*

* sortedset:自动排序集合 可以重复

* */

@Test

public void test6(){

Jedis jedis=new Jedis("127.0.0.1",6379);

jedis.auth("Hik1234");

jedis.zadd("sortset",9,"a");

jedis.zadd("sortset",5,"b");

jedis.zadd("sortset",8,"c");

Set sortset = jedis.zrange("sortset", 0, -1);

System.out.println(sortset);

jedis.close();

}

/*

连接池连接

*/

@Test

public void test7(){

JedisPoolConfig config=new JedisPoolConfig();

config.setMaxTotal(50);

config.setMaxIdle(10);

JedisPool jedisPool =new JedisPool(config,"127.0.0.1",6379,1000,"Hik1234");

Jedis resource = jedisPool.getResource();

resource.set("jedisPool","abc");

System.out.println(resource.get("jedisPool"));

resource.close();

}

/*

* 连接池连接

* */

@Test

public void test8(){

Jedis jedis = JedisPoolUtils.getJedis();

jedis.set("hello","world");

System.out.println(jedis.get("hello"));

jedis.close();

}

}

配置文件：jedis.properties

host=127.0.0.1

port=6379

maxTotal=50

maxIdle=10

timeout=1000

password=Hik1234