jedis连接池配置_为什么要用连接池

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

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

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介绍》

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/197450.html原文链接:https://javaforall.net

(0)
上一篇 2025年9月3日 下午5:43
下一篇 2025年9月3日 下午6:22


相关推荐

  • git的版本回退教程(带你一步一步操作)

    git的版本回退教程(带你一步一步操作)nbsp nbsp 在之前的文章中我们已经学会了如何使用 git 提交文件 下载更新文件 那么在 git 中如何进行版本回退呐 nbsp 首先 在本地建立一个 git 项目 并且与远程服务端 github 上的项目进行关联 如果这一步骤有问题的童靴 请参考我的上一篇文章 害羞 nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp 1 第一次建立 git 项目 提交到远程分支 并且记录为第一个版本 nbsp nbsp

    2026年3月18日
    1
  • 百度文心ERNIE-4.5开源测评:架构解析与性能全对比

    百度文心ERNIE-4.5开源测评:架构解析与性能全对比

    2026年3月12日
    3
  • mount 命令详解

    mount 命令详解mount 命令详解 nbsp nbsp nbsp 在 windows 操作系统中 挂载通常是指给磁盘分区 包括被虚拟出来的磁盘分区 分配一个盘符 这个操作可以通过 计算机管理 中的 磁盘管理 来进行 第三方软件 如磁盘分区管理软件 虚拟磁盘软件等 通常也附带挂载功能 nbsp nbsp nbsp 在 linux 操作系统中 挂载是一个非常重要的功能 使用非常频繁 它指将一个设备 通常是存储设备 挂接到一个已存在的目录上 这个目录可以不为空

    2026年3月19日
    1
  • fastjson map转jsonobject_fastjson中Map与JSONObject互换,List与JOSNArray互换的实现「建议收藏」

    fastjson map转jsonobject_fastjson中Map与JSONObject互换,List与JOSNArray互换的实现「建议收藏」fastjson中Map与JSONObject互换,List与JOSNArray互换的实现1、//将map转换成jsonObjectJSONObjectitemJSONObj=JSONObject.parseObject(JSON.toJSONString(itemMap));将Map类型的itemInfo转换成json,再经JSONObject转换实现。2、//将jsonObj转换成Map…

    2022年10月5日
    4
  • 安卓中activity的生命周期_activity生命周期方法

    安卓中activity的生命周期_activity生命周期方法当Activity处于Android应用中运行时,它的活动状态由Android以Activity栈的形式管理。当前活动的Activity位于栈顶。随着不同应用的运行,每个Activity都有可能从活动状态转入非活动状态,也可能从非活动状态转入活动状态。

    2022年8月16日
    9
  • Java线程池参数配置

    Java线程池参数配置在线程池的实际使用中,参数的配置总让人难以把握。在网上搜了一下,主要有以下的方案。跟大家分享。1.基本概念1.1ThreadPoolExecutor的重要参数corePoolSize:核心线程数核心线程会一直存活,及时没有任务需要执行 当线程数小于核心线程数时,即使有线程空闲,线程池也会优先创建新线程处理 设置allowCoreThreadTimeout=true(默认false)时,核心线程会超时关闭queueCapacity:任务队列容量(阻塞队列)当核心线程数达到最大时,

    2022年5月23日
    74

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号