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

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

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

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • pycharm的控制台主题,Pycharm控制台

    pycharm的控制台主题,Pycharm控制台本篇文章帮大家学习Pycharm控制台,包含了Pycharm控制台使用方法、操作技巧、实例演示和注意事项,有一定的学习价值,大家可以用来参考。PyCharm有一个完整的代码完整的python控制台,可以在选项菜单:工具(Tools)->运行Python控制台(RunPythonConsole)中找到。使用上一章中的代码,如下所示-message=’GIEWIVrGMTLIVrH…

  • Linux系统 ISO下载

    Linux系统 ISO下载Ubuntu14.04.1LTS桌面版本可以从此下载:Intel&AMD/兼容PC 64位 点此下载Intel&AMD/兼容PC32位 点此下载服务器版本可以从此下载:Intel&AMD/兼容PC 64位 点此下载Intel&AMD/兼容PC32位 点此下载14.10桌面版本可以从此下载:Intel&

  • C++——string字符串类具体用法

    C++——string字符串类具体用法引言:C++ 大大增强了对字符串的支持,除了可以使用C风格的字符串,还可以使用内置的 string 类。string 类处理起字符串来会方便很多,完全可以代替C语言中的字符数组或字符串指针。string 是 C++ 中常用的一个类,它非常重要,我们有必要在此单独讲解一下。定义使用 string 类需要包含头文件,下面的例子介绍了几种定义 string 变量(对象)的方法:#include…

  • java二维数组初始化(动态,静态)

    java二维数组初始化(动态,静态)int[][] a=new  int[][]{{1,2},{3,4},{5,6,7,8,9},{}};      System.out.println(a.length);//4,表示数组的行数      System.out.println(a[0].length);//2,表示对应行的长度      System.out.println(a[1].length);//2      System…

  • webgame开发中常用的一些类

    webgame开发中常用的一些类这个只是自己在开发游戏过程中所总结出来的,仅供参考。1、加载队列QueueLoader,游戏一定是有很多的资源需要加载,这个类可以让资源以顺序进行加载;2、ZIP解压工具类nochump类,这里有之前写过的例子–>使用as工具包解压zip文件。这里还有另外一个Zip处理类ZipArchive3、声音管理类SoundManager,游戏一般都有很多音乐需要管理:…

  • mybatis返回两个字段数据_java接口接收json数据

    mybatis返回两个字段数据_java接口接收json数据pg数据库中某字段类型为jsonJava实体中对应类型是jsonObject privateJSONObjectinfo;在mybatis的xml中,常规无法直接进行映射,需要自己写一个TypeHandler,自定义一个JSONTypeHandlerPg类具体代码:packagecom.geovis.common.config;importjava.sql.Callable…

发表回复

您的电子邮箱地址不会被公开。

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