redis学习 -- JedisPool&JedisSentinelsPool


  jedis连接池的使用:

  所需jar包:jedis使用了apache commons-pool2库,导入jedis时会自动导入common-pool2jar包

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.7.2</version>
</dependency>

  定义一个JedisAPI类,主要实现过程:

  >定义一个JedisAPI类的实例instance,目的是在程序运行时获取唯一实例,实现单例,以节省内存空间。

   private static final JedisAPI instance = new JedisAPI();
    //获取实例,用于实现单例模式
    public JedisAPI getInstance(){
        return instance;
    }

  >可能需要配置的一些属性:

private String host; private int port; private int DBNumber = 0;//获取host和port
    public JedisAPI setHostAndPort(String host, int port){ this.host = host; this.port = port; return this; } //设置db
    public JedisAPI setDBnumber(int DBNumber){ this.DBNumber = DBNumber; return this; }

  >定义连接池,定义一个init()方法,对instance进行初始化,初始化主要包括config的配置和连接池的创建:

   private static JedisPool pool = null;
public JedisAPI init(){ if(pool == null){ JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(8);//设置最大连接数,默认为8 config.setMaxIdle(8); //设置最大空闲连接数,默认为8 config.setMinIdle(0);//设置最小空闲连接数,默认为0 config.setMaxWaitMillis(1000);//设置连接时的最长等待时间,单位为毫秒,默认为-1,表示永不超时。 pool = new JedisPool(config, "127.0.0.1", 6379, 60000); } return this; }

  >接下来就可以用这个连接池操作redis数据库了:

    @SuppressWarnings("deprecation")
    public void setKey(){
        Jedis jedis = null; //定义一个jedis连接
        try {
            jedis = pool.getResource(); //从连接池获取资源,初始化jedis连接
            jedis.select(DBNumber);//选择db
       jedis.set("123", "1234"); //jedis对数据库的操作 } catch (Exception e) { pool.returnBrokenResource(jedis); //发生异常,将资源返还给连接池 e.getStackTrace(); }finally { pool.returnResource(jedis); //程序结束,将资源返还给连接池 } } @SuppressWarnings("deprecation") public String getKey(){ Jedis jedis = null; try { jedis = pool.getResource();
       jedis.select(DBNumber);//选择db
return jedis.get("123"); } catch (Exception e) { pool.returnBrokenResource(jedis); e.getStackTrace(); return null; }finally { pool.returnResource(jedis); } }

  调用JedisAPI:

    private static JedisAPI jedisAPI;

    jedisAPI = new JedisAPI().getInstance().setHostAndPort("127.0.0.1", 6381).setDBnumber(1).init();

    jedisAPI.setKey();

    jedisAPI.getKey();    

 

  JedisSentinelsPool的使用和JedisPool基本一致,需要配置一下sentinels集群地址即可。


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM