jedis:连接池(JedisPool)使用示例

Jedis实例不是线程安全的,所以不可以多个线程共用一个Jedis实例,但是创建太多的实现也不好因为这意味着会建立很多sokcet连接。 JedisPool是一个线程安全的网络连接池。可以用JedisPool创建一些可靠Jedis实例,可以从池中获取Jedis实例,使用完后再把Jedis实例还回JedisPool。这种方式可以避免创建大量socket连接并且会实现高效的性能.

JedisPool初始化

        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        // 设置最大10个连接
        jedisPoolConfig.setMaxTotal(10);
        pool = new JedisPool(jedisPoolConfig, "localhost");

使用JedisPool

1.JedisPool#getResource()方法从连接池中取得一个Jedis实例, 2.使用Jedis实例进行正常的数据操作 3.Jedis实例使用完后要把它再放回连接池。

资源释放

关于如何将使用完后的Jedis实例还回连接池,网上看到的大部分文章都是建议用JedisPool#returnResource方法,这些文章大多是3,4年前的文章

jedis官网:https://github.com/xetorthio/jedis

而当我使用jedis时,jedis的最新版本已经到了2.9(我使用的是2.8.2)。 在jedis2.8.2中已经将JedisPool#returnResource方法废弃了,并明确说明这个方法的功能由Jedis.close()方法代替。

void redis.clients.jedis.JedisPool.returnResource(Jedis resource)
@Override
@Deprecated
不推荐. starting from Jedis 3.0 this method will not be exposed. Resource cleanup should be done using @see redis.clients.jedis.Jedis.close()
本文作者注:从Jedis 3.0开始这个方法将不再暴露给外部(public),资源清除应该调用用Jedis.close()方法
覆盖: Pool 中的 returnResource(...)
参数:resource 

如果进一步查看Jedis#close()方法的源码,会发现,close()方法最终依然是调用 JedisPool#returnResource方法。 可以看到,当使用JedisPool时,close方法并没有真的执行client.close方法,只是将它还给JedisPool连接池,以供下次使用。

  @Override
  public void close() {
    if (dataSource != null) {
      // dataSource 即为 JedisPool实例,
      if (client.isBroken()) {
        // 调用 JedisPool#returnBrokenResource方法
        this.dataSource.returnBrokenResource(this);
      } else {
      // 调用 JedisPool#returnResource 方法
        this.dataSource.returnResource(this);
      }
    } else {
      client.close();
    }
  }

所以正确使用并释放连接池资源的方式如下:

        Jedis jedis = null;
        try{
            // 从连接池获取一个Jedis实例
            jedis = pool.getResource();
            //设置 redis 字符串数据 SET 10km blog.csdn.net/10km
            jedis.set("10km", "blog.csdn.net/10km");
            // 获取存储的数据并输出
            System.out.println("redis 存储的字符串为: "+ jedis.get("10km"));           
        }finally{
            if(null != jedis)
                jedis.close(); // 释放资源还给连接池
        }

完整Junit测试代码

package net.gdface.facelog;

import java.util.List;

import org.junit.After;
import org.junit.Before;
import org.junit.FixMethodOrder;
import org.junit.Test;
import org.junit.runners.MethodSorters;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
public class TestRedis {
    private JedisPool pool;
    /**
     * 初始化连接池
     */
    @Before
    public void init() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(10);
        pool = new JedisPool(jedisPoolConfig, "localhost");
        System.out.println("连接池初始化成功");
    }
    @Test
    public void testPing(){
        // Jedis 实现了java.lang.AutoCloseable接口,所以这里可以用java 1.7 try-with-resources语法自动完成close
        try(Jedis jedis = pool.getResource()){
            //查看服务是否运行 PING
            System.out.println("服务正在运行: "+jedis.ping());
        }
    }
    @Test
    public void testString(){
        try(Jedis jedis = pool.getResource()){
            //设置 redis 字符串数据 SET 10km blog.csdn.net/10km
            jedis.set("10km", "blog.csdn.net/10km");
            // 获取存储的数据并输出
            System.out.println("redis 存储的字符串为: "+ jedis.get("10km"));           
        }
    }
    @Test
    public void testList() {
        try (Jedis jedis = pool.getResource()) {
            // 选择数据库:  SELECT 2
            jedis.select(2);
            // 存储数据到列表中
            // LPUSH 
            jedis.lpush("phone_list", "Apple");
            jedis.lpush("phone_list", "Huawei");
            jedis.lpush("phone_list", "XiaoMi");

            // 获取存储的数据并输出: LRANGE phone_list 0 2
            List<String> list = jedis.lrange("phone_list", 0, 2);
            for (int i = 0; i < list.size(); i++) {
                System.out.println("phone_list 列表项为: " + list.get(i));
            }
        }
    }
    /**
     * 程序关闭时,需要调用关闭方法
     */
    @After
    public void end(){      
        if(null != pool){
            pool.destroy();
            System.out.println("连接池关闭");
        }

    }
}

参考资料

《Java中使用Jedis操作Redis》 《JedisPool介绍》

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏菩提树下的杨过

Flash/Flex学习笔记(35):如何正确监听Stage对象的事件

如果想在一个自定义类中注册对stage对象的监听事件,然后在另一个文档类中使用该类的实例(或在fla的时间轴上使用该类的实例),你会很郁闷的发现:在构造函数中始...

1865
来自专栏丑胖侠

《Drools7.0.0.Final规则引擎教程》番外实例篇——FactHandler使用案例

背景 在使用具体的业务使用中,我们经常会通代码对Fact对象进行操作,Drools为我们提供了FactHandler来获取对象的句柄,通过此返回值可以对Work...

2065
来自专栏数据和云

性能优化:Cache Buffer Chain Latch等待事件

彭小波 ACOUG核心成员,Oracle用户组年轻专家。擅长Oracle数据库架构规划、SQL,OWI方面的优化。曾服务于各大企业数据库的维护以及系统开发,目...

2813
来自专栏difcareer的技术笔记

Android Linker学习笔记[转]

Linker是Android系统动态库so的加载器/链接器,要想轻松地理解Android linker的运行机制,我们需要先熟悉ELF的文件结构,再了解ELF文...

1514
来自专栏hbbliyong

WPF备忘录(3)如何从 Datagrid 中获得单元格的内容与 使用值转换器进行绑定数据的转换IValueConverter

一、如何从 Datagrid 中获得单元格的内容    DataGrid 属于一种 ItemsControl, 因此,它有 Items 属性并且用ItemCon...

3217
来自专栏码洞

知道Python语言的Google Fire项目么,我将它移植到了Java上

最近尝试了Python语言的开源命令行便捷工具库Google Fire,它是用来加速用户编写命令行程序的一个小工具库,该工具使用非常方便,节省了编写命令行程序繁...

692
来自专栏Danny的专栏

【MyBatis框架点滴】——MyBatis开发DAO的两种方法:原始DAO开发方法和Mapper代理方法

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/huyuyang6688/article/...

633
来自专栏java达人

MapperScannerConfigurer处理过程源码分析

作者:format 来源: http://fangjian0423.github.io/(点击文末阅读原文前往) 前言 本文将分析mybatis与spring...

2338
来自专栏SeanCheney的专栏

《Pandas Cookbook》第08章 数据清理1. 用stack清理变量值作为列名2. 用melt清理变量值作为列名3. 同时stack多组变量4. 反转stacked数据5. 分组聚合后uns

第01章 Pandas基础 第02章 DataFrame运算 第03章 数据分析入门 第04章 选取数据子集 第05章 布尔索引 第06章 索引对齐 ...

692
来自专栏王二麻子IT技术交流园地

《SpringMVC从入门到放肆》五、SpringMVC配置式开发(处理器适配器)

上一篇我们大致讲解了处理器映射器的处理流程以及跟了一下源码的执行流程。今天我们来了解一下处理器适配器。 一、适配器模式 ? 在阎宏博士的《JAVA与模式》一书中...

33211

扫码关注云+社区