美文网首页
【Redis缓存】- Java客户端Jedis

【Redis缓存】- Java客户端Jedis

作者: 丛鹏 | 来源:发表于2019-12-31 09:46 被阅读0次

    一、概述

    Java 客户端 Jedis 是一款 java 操作 Redis 数据库的工具,类似于 JDBC,也就是通过 Java 代码来操作数据库。使用步骤如下:

    导入 jar 包:commons-pool2-2.3.jar、jedis-2.7.0.jar

    获取jar包链接:https://pan.baidu.com/s/1ONkaNFEy6uocm7Aghe80rg   提取码:plgt

    使用:

    获取连接

    操作数据

    关闭连接

    接下来就以 Redis 的五种数据结构来说明 Jedis 的基本使用

    二、Jedis 操作 Redis 中的数据结构

    1、字符串类型 string

    获取连接:Jedis jedis = new Jedis("localhost",6379);

    操作数据:

    jedis.set("name","oneStar");       //存储

    jedis.get("name");       //获取

    jedis.setex("name",20,"twoStar");      //将 name:twoStar 键值对存入redis,并且20秒后自动删除该键值对

    关闭连接:jedis.close();

    注:可以使用 setex() 方法存储可以指定过期时间的 key value

    2、哈希类型 hash

    获取连接:Jedis jedis = new Jedis();       //如果使用空参构造,默认值 "localhost",6379端口

    操作数据:

    jedis.hset("user","name","oneStar");     //存储

    jedis.hget("user","name");      //获取

    Map<String, String> user = jedis.hgetAll("user");     // 获取hash的所有map中的数据

    关闭连接:jedis.close();

    3、列表类型 list

    获取连接:Jedis jedis = new Jedis();       //如果使用空参构造,默认值 "localhost",6379端口

    操作数据:

    jedis.lpush("mylist","a","b","c");        //从左边存

    jedis.rpush("mylist","a","b","c");        //从右边存

    jedis.lrange("mylist", 0, -1);        //范围获取

    jedis.lpop("mylist");        //从左边弹出

    jedis.rpop("mylist");       //从右边弹出

    关闭连接:jedis.close();

    4、集合类型 set

    获取连接:Jedis jedis = new Jedis();       //如果使用空参构造,默认值 "localhost",6379端口

    操作数据:

    sadd("myset","a","b","c");       //存储

    jedis.smembers("myset");      //获取

    关闭连接:jedis.close();

    5、有序集合类型 sortedset

    获取连接:Jedis jedis = new Jedis();       //如果使用空参构造,默认值 "localhost",6379端口

    操作数据:

    jedis.zadd("mysortedset",18,"oneStar");       //存储

    jedis.zrange("mysortedset", 0, -1);       //获取

    关闭连接:jedis.close();

    三、Jedis 连接池 JedisPool

    JedisPool 连接池和 JDBC 连接池是类似的,在实际开发中,“获得连接”和“释放资源”是非常消耗系统资源的两个过程,为了解决此类性能问题,通常会采用连接池技术,来共享连接,这样既不用每次都获取连接、释放连接了。和 JDBC 不同的是 JDBC 使用的是第三方提供的接口,而 jedis 则是自带了连接池,叫 JedisPool

    1、JedisPool 的使用

    创建 JedisPool 连接池对象

    创建配置对象:new JedisPoolConfig();

    创建Jedis连接池对象:new JedisPool(config,"localhost",6379);

    调用方法 getResource()方法获取Jedis连接

    获取连接:jedisPool.getResource();

    使用:jedis.set("name","oneStar");

    2、JedisPool 连接池工具

    在 JedisPool 的使用中,会进行相应的配置,而配置不方便修改,增加了代码的耦合度,为了降低耦合度,可以将一些配置抽取到配置文件里面,要修改配置的时候直接修改配置文件即可,不需要修改代码。

    【1】首先先要在 src 目录下创建配置文件并写入相关配置:jedis.properties

    【2】编写Jedis工具类

    静态代码块加载配置文件,配置连接池的参数

    提供获取连接的方法

    package cn.star;

    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;

    /**

    * 〈一句话功能简述〉<br>

    * 〈Jedis工具类〉

    *

    * @author OneStar

    * @create 2019/11/26

    * @since 1.0.0

    */

    public class JedisPoolUtil {

        private static JedisPool jedisPool;

        static {

            //读取配置文件

            InputStream is = JedisPoolUtil.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 getJedisPool(){

            return jedisPool.getResource();

        }

    }

    【3】编写测试类

    @Test

    public void testJedisPoolUtil(){

        //1.通过连接池工具获取

        Jedis jedis = JedisPoolUtil.getJedisPool();

        //2.使用

        jedis.set("name","LSTAR");    //存储

        String name = jedis.get("name");    //获取

        System.out.println(name);

        //3.关闭连接(归还连接池)

        jedis.close();

    }

    相关文章

      网友评论

          本文标题:【Redis缓存】- Java客户端Jedis

          本文链接:https://www.haomeiwen.com/subject/ewfboctx.html