首页 > 其他分享 >886~888 Jedis操作set&sortedset,连接池,连接池工具类

886~888 Jedis操作set&sortedset,连接池,连接池工具类

时间:2023-02-25 10:01:07浏览次数:50  
标签:set 886 JedisPool Jedis new jedis config 连接池

4) 集合类型 set  : 不允许重复元素

  sadd

  smembers:获取所有元素

  //1. 获取连接

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

  //2. 操作

  // set 存储

  jedis.sadd("myset","java","php","c++");

  // set 获取

  Set<String> myset = jedis.smembers("myset");

  System.out.println(myset);

  //3. 关闭连接

  jedis.close();

5) 有序集合类型 sortedset:不允许重复元素,且元素有顺序

  zadd

  zrange

  //1. 获取连接

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

  //2. 操作

  // sortedset 存储

  jedis.zadd("mysortedset",3,"亚瑟");

  jedis.zadd("mysortedset",30,"后裔");

  jedis.zadd("mysortedset",55,"孙悟空");

  // sortedset 获

  Set<String> mysortedset = jedis.zrange("mysortedset", 0, -1);

  System.out.println(mysortedset);

  //3. 关闭连接

  jedis.close();

jedis连接池: JedisPool

  使用:

    1. 创建JedisPool连接池对象

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

      //0.创建一个配置对象

        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("hehe","heihei");

        //4. 关闭 归还到连接池中

        jedis.close();

连接池工具类

  public class JedisPoolUtils {

    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();

    }

  }

标签:set,886,JedisPool,Jedis,new,jedis,config,连接池
From: https://www.cnblogs.com/agzq/p/17153818.html

相关文章