jedis操作redis

Author:SimpleWu

Jedis介绍

Jedis是Redis官方推荐的的Java客户端开发包。

官方：https://github.com/xetorthio/jedis

使用

导入依赖：

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

使用jedis链接redis非常简单：

//Jedis jedis = new Jedis(host, port)
Jedis jedis = new Jedis("127.0.0.1", 6379);
System.out.println("如果是pong爆炸就链接成功 ：" + jedis.ping());

如果redis设置了密码必须要授权：

jedis.auth("password");  //如果设置密码，要授权

key键api

String键api

Hash哈希api

@Test
    public void test2(){
        Map<String, String> map = new HashMap<>();
        map.put("name", "SimpleWu");
        map.put("email", "[email protected]");
        //同时将多个field-value对设置到哈希表key中
        jedis.hmset("info", map);
        //获取所有给定字段的值
        List<String> list = jedis.hmget("info", "email");
        for (String string : list) {
            System.out.println(string);
        }
        System.out.println("获取数量:" + jedis.hlen("info"));
        jedis.hdel("info", "name");
        System.out.println("获取数量:" + jedis.hlen("info"));
    }

list集合api

@Test
    public void test3(){
        //将一个或多个值插入到列表头部
        jedis.lpush("list", new String[]{"list1","list2","list3"});
        //通过索引获取列表中的元素
        System.out.println(jedis.lindex("list",1));
        //获取列表指定范围内的元素
        List<String> list = jedis.lrange("list", 0, 1);
        for (String string : list) {
            System.out.println(string);
        }
    }

Set集合的API

Zset集合的API

Jedis的事务

@Test
    public void test4(){
        //开启事务
        Transaction tx = jedis.multi();
        //添加指令到队列中
        tx.set("name", "SimpleWu");
        tx.set("email", "[email protected]");
        //执行指令
        List<Object> execs = tx.exec();
        for (Object object : execs) {
            System.out.println(object);
        }
        //取消指令
        //String discard = tx.discard();
        //System.out.println(discard);
        System.out.println(jedis.get("name"));
    }

Jedis的连接池

@Test
public void test5(){
  JedisPoolConfig poolConfig = new JedisPoolConfig();
  // 最大空闲连接数, 默认8个
  poolConfig.setMaxIdle(10);
  // 最小空闲连接数, 默认0
  poolConfig.setMinIdle(0);
  // 最大连接数, 默认8个
  poolConfig.setMaxTotal(100);
  // 获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),
  // 如果超时就抛异常,小于零:阻塞不确定的时间,
  // 默认-1
  poolConfig.setMaxWaitMillis(-1);
  // 在获取连接的时候检查有效性, 默认false
  poolConfig.setTestOnBorrow(false);
}