Jedis学习

入门

• 导入jar包
  commons-pool2-2.3.jar
  jedis-2.7.0.jar
• 获取连接

Jedis jedis = new Jedis("localhost",6379); //空参默认 localhost 6379

• 操作

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

• 关闭连接

jedis.close();

各数据类型操作：

String

jedis.set("key","value")
jedis.get("key")

jedis.setex("key",second,"value")//存入键值对 指定秒数后删除

hash

jedis.hset("key","field","value")
jedis.hget("key","field")

//获取指定hash的所有数据
Map<String,String> map=jedis.hgetAll("key")

 // keyset
 Set<String> keySet = map.keySet();
 for (String key : keySet) {
     //获取value
     String value = map.get(key);
 }

list

// list 存储
jedis.lpush("key","value1","value2","value3");//从左边存
jedis.rpush("key","value1","value2","value3");//从右边存

// list 范围获取
List<String>  list = jedis.lrange("key", 0, -1);

// list 弹出
String element1 = jedis.lpop("key");
String element2 = jedis.rpop("key");

set

// set 存储
jedis.sadd("key","value1","value2","value3");

// set 获取
Set<String> myset = jedis.smembers("key");

shortset

// sortedset 存储 按照score从小到大排序
jedis.zadd("key",score1,"value1");
jedis.zadd("key",score2,"value2");
jedis.zadd("key",score3,"value3");

// sortedset 获取
Set<String> set = jedis.zrange("key", 0, -1);

Jedis连接池

JedisPool

1. 创建一个配置对象
2. 创建JedisPool连接池对象
3. 调用getResource()方法获取Jedis连接
4. 关闭连接

//创建一个配置对象
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(50);//最大允许连接数
config.setMaxIdle(10);//最大的空闲连接
//1.创建Jedis连接池对象
JedisPool jedisPool = new JedisPool(config,"localhost",6379);
//2.获取连接
Jedis jedis = jedisPool.getResource();
//3. 使用
jedis.set("key","value");
//4. 关闭 归还到连接池中
jedis.close();

连接池工具类（静态代码块加载Jedis连接池配置文件）

jedis.properties

host=127.0.0.1
    port=6379
    maxTotal=50
    maxIdle=10

工具类

private static JedisPool jedisPool;
    static{
        //读取配置文件
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
        //创建Properties对象
        Properties pro = new Properties();
        //关联文件
        try {
            pro.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //获取数据，设置到JedisPoolConfig中
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
        config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));=
        //初始化JedisPool
        jedisPool = new JedisPool(config,pro.getProperty("host"),Integer.parseInt(pro.getProperty("port")));
    }


    /**
     * 获取连接方法
     */
    public static Jedis getJedis(){
        return jedisPool.getResource();
    }