JedisPool踩坑记录

JedisPool踩坑记录报错信息:Exceptioninthread”main”redis.clients.jedis.exceptions.JedisExhaustedPoolException:Couldnotgetaresourcesincethepoolisexhausted在网上找了很久没有找到,现在看来提示已经讲的很明白了,Jedis池耗尽异常:由于池已耗尽,无法获取资源原因就是最大连接数不够使用,我在类中启动了60个并发线程,然而连接池最大连接数只有50,所以报错。packa

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

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

报错信息:Exception in thread “main” redis.clients.jedis.exceptions.JedisExhaustedPoolException: Could not get a resource since the pool is exhausted

在网上找了很久没有找到,现在看来提示已经讲的很明白了,Jedis池耗尽异常:由于池已耗尽,无法获取资源

原因就是最大连接数不够使用,我在类中启动了60个并发线程,然而连接池最大连接数只有50,所以报错。

package com.wang.distributedlock.utils;

import org.springframework.beans.factory.annotation.Value;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @author wzq
 * @date 2020/05/29/11:09
 */
public class JedisPoolUtil {

    @Value("${redis.host}")
    private static final String HOST = "127.0.0.1";

    @Value("${redis.port}")
    private static final int PORT = 6379;

    @Value("${redis.password}")
    private static final String PASSWORD = "123456";

    private static volatile JedisPool jedisPool = null;

    public static JedisPool getJedisPoolInstance() {
        if (jedisPool == null) {
            JedisPoolConfig poolConfig = new JedisPoolConfig();
            // 最大连接数
            poolConfig.setMaxTotal(50);
            // 最大空闲连接数
            poolConfig.setMaxIdle(30);

            poolConfig.setMinIdle(10);
            // 最大等待时间
            poolConfig.setMaxWaitMillis(20 * 1000);
            // 检查连接可用性, 确保获取的redis实例可用
            // 在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的
            poolConfig.setTestOnBorrow(false);
            poolConfig.setTestOnCreate(false);

            // 无密码构造
            //jedisPool = new JedisPool(poolConfig, HOST, PORT);
            // 有密码构造,需要设置密码,设置密码可以在获取到jedis对象后,jedis.auth("密码"),也可以在此时使用构造入参设置
            jedisPool = new JedisPool(poolConfig, HOST, PORT, 10 * 1000, PASSWORD);

        }
        return jedisPool;
    }

    public static Jedis getJedisInstance() {
        Jedis jedis = getJedisPoolInstance().getResource();
        //jedis.auth("123456");
        return jedis;
    }

    public static void release(Jedis jedis) {
        jedis.close();
    }

}

引用的类中

package com.wang.distributedlock.zk;

import com.wang.distributedlock.utils.JedisPoolUtil;
import com.wang.distributedlock.utils.RedisTool;
import redis.clients.jedis.Jedis;

import java.util.UUID;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author wzq
 * date: 2019/12/23 11:28
 * description:
 */
public class OrderService implements Runnable {

    private static CyclicBarrier cb = new CyclicBarrier(60);

    // 订单号生成类
    // 将orderNumGenerator或者count任意一处加上static,getNumber()加上同步锁,依然是线程安全的,因为使用的是同一个generator,而且加了锁是线程安全的
    // 效果等同于静态锁,很多OrderService实例共用一把锁
    private OrderNumGenerator orderNumGenerator = new OrderNumGenerator();

    // 实现方式1
    //private DistributeLock lock = new ZookeeperDistributeLock();

    // 实现方式2
    //private DistributeLock lock = new ZookeeperDistributeLock2();

    /**
     * 这么多OrderService实例共用一把锁,可以保证线程安全,但在集群部署多机模式下,
     * 即便每台机器一次有一个请求获得锁,机器足够多依然会导致并发问题
     */
    private static Lock rtLock = new ReentrantLock();

    //实现方式3,redis分布式锁
    //private Jedis jedis = RedisTool.getJedis();
    private Jedis jedis = JedisPoolUtil.getJedisInstance();

    public void run() {
        try {
            cb.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            e.printStackTrace();
        }
        getNumber();
    }

    public void getNumber() {
        String requestId = UUID.randomUUID().toString();
        try {
            //lock.getLock();

            //rtLock.lock();

            // Redis服务端单机部署,需要回调
            // redis锁使用此段生成订单代码
            /*if (RedisTool.tryGetDistributedLock(jedis, "lock", requestId, 2000)) {
                String number = orderNumGenerator.getNumber();
                System.out.println(Thread.currentThread().getName() + "-" + System.currentTimeMillis() + ",产生了订单:" + number);
            } else {
                this.getNumber();
            }*/

            // zookeeper锁或者不加锁使用此段生成代码订单
            String number = orderNumGenerator.getNumber();
            System.out.println(Thread.currentThread().getName() + "-" + System.currentTimeMillis() + ",产生了订单:" + number);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //lock.unlock();

            //rtLock.unlock();

            //Redis服务端单机部署,需要回调
            //RedisTool.releaseDistributedLock(jedis, "lock", requestId);
        }
    }

    public static void main(String[] args) {

        System.out.println("####生成了订单####");
        for (int i = 0; i < 60; i++) {
            new Thread(new OrderService()).start();
        }

    }

}

 

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

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

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

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

(0)


相关推荐

  • python中关于if-else使用性能的一点感悟

    python中关于if-else使用性能的一点感悟

    2021年11月19日
  • 几种常见的距离计算公式

    几种常见的距离计算公式在学习分类、聚类、预测、推荐算法的过程中常常会遇到比较两个或多个对象的相似性,而相似性的度量可以通过计算距离来实现。我们常用的距离计算公式是欧几里得距离公式,但是有时候这种计算方式会存在一些缺陷,那么就需要另外的计算方法去加以补充,本文将介绍几种在机器学习中常用的计算距离。在做很多研究问题时常常需要估算不同样本之间的相似性度量(SimilarityMeasurement),这时通常采用的方法就…

  • 微软邮箱设置smtp_邮件服务器怎么设置

    微软邮箱设置smtp_邮件服务器怎么设置配置SMTP服务器和自定义警报和反馈请求电子邮件09/01/2016本文内容AzureDevOpsServer2020|AzureDevOpsServer2019|TFS2018-TFS2013备注AzureDevOpsServer以前名为VisualStudioTeamFoundationServer。若要使用反馈请求和警报,你必须为Azure…

  • pycharmpip升级失败_如何更新pip版本

    pycharmpip升级失败_如何更新pip版本更新pip版本出错查看pip的版本时提示需要更新执行更新出错打开文件管理找到当前虚拟环境下的lib下的site-packages文件删除pip-18.0.dist-info文件然后回到命令行执行python-mpipinstall–index-urlhttps://pypi.douban.com/simple–upgradepip即可完成pip的更新…

    2022年10月29日
  • android listview清空数据[通俗易懂]

    android listview清空数据[通俗易懂]privateListViewlistview;  privateArrayList>data;  privateSimpleAdapteradapter;        if(data.size()>0){data.removeAll(data);adapter.notifyDataSetChanged();

  • Linux抓包工具[通俗易懂]

    Linux抓包工具[通俗易懂]字符界面的的抓包工具—-tcpdump可用选项-A以ASCII格式打印出所有分组,并将链路层的头最小化。-c在收到指定的数量的分组后,tcpdump就会停止。-C在将一个原始分组写入文件之前,检查文件当前的大小是否超过了参数file_size中指定的大小。如果超过了指定大小,则关闭当前文件,然后在打开一个新的文件。参数file_size的单位是兆字节(是1,000,000字节,而不是1,048,576字节)。-d将匹配信息包的代码以人们能够理解的汇编格式给出。-dd将

    2022年10月14日

发表回复

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

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