2. 程式人生 > >jedispool 連 redis 高併發卡死

jedispool 連 redis 高併發卡死

阿新 • • 發佈：2019-01-22

java端在使用jedispool 連線redis的時候，在高併發的時候經常卡死，或報連線異常，JedisConnectionException，或者getResource 異常等各種問題

在使用jedispool 的時候一定要注意兩點

1。 在獲取 jedisPool和jedis的時候加上執行緒同步，保證不要建立過多的jedispool 和 jedis

2。 用完Jedis例項後需要返還給JedisPool

整理了一下redis工具類，通過大量測試和高併發測試的

import org.apache.log4j.Logger;import redis.clients.jedis.Jedis;import
redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;/** * Redis 工具類 * @author caspar * https://blog.csdn.net/tuposky */public class RedisUtil { protected static Logger logger = Logger.getLogger(RedisUtil.class); //Redis伺服器IP private static String ADDR_ARRAY = FileUtil.getPropertyValue
("/properties/redis.properties", "server"); //Redis的埠號 private static int PORT = FileUtil.getPropertyValueInt("/properties/redis.properties", "port"); //訪問密碼// private static String AUTH = FileUtil.getPropertyValue("/properties/redis.properties", "auth"); //可用連線例項的最大數目，預設值為8； //如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis例項，則此時pool的狀態為exhausted(耗盡)。
private static int MAX_ACTIVE = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_active");; //控制一個pool最多有多少個狀態為idle(空閒的)的jedis例項，預設值也是8。 private static int MAX_IDLE = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_idle");; //等待可用連線的最大時間，單位毫秒，預設值為-1，表示永不超時。如果超過等待時間，則直接丟擲JedisConnectionException； private static int MAX_WAIT = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_wait");; //超時時間 private static int TIMEOUT = FileUtil.getPropertyValueInt("/properties/redis.properties", "timeout");; //在borrow一個jedis例項時，是否提前進行validate操作；如果為true，則得到的jedis例項均是可用的； private static boolean TEST_ON_BORROW = FileUtil.getPropertyValueBoolean("/properties/redis.properties", "test_on_borrow");; private static JedisPool jedisPool = null; /** * redis過期時間,以秒為單位 */ public final static int EXRP_HOUR = 60*60; //一小時 public final static int EXRP_DAY = 60*60*24; //一天 public final static int EXRP_MONTH = 60*60*24*30; //一個月 /** * 初始化Redis連線池 */ private static void initialPool(){ try { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(MAX_ACTIVE); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT); } catch (Exception e) { logger.error("First create JedisPool error : "+e); try{ //如果第一個IP異常，則訪問第二個IP JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(MAX_ACTIVE); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[1], PORT, TIMEOUT); }catch(Exception e2){ logger.error("Second create JedisPool error : "+e2); } } } /** * 在多執行緒環境同步初始化 */ private static synchronized void poolInit() { if (jedisPool == null) { initialPool(); } } /** * 同步獲取Jedis例項 * @return Jedis */ public synchronized static Jedis getJedis() { if (jedisPool == null) { poolInit(); } Jedis jedis = null; try { if (jedisPool != null) { jedis = jedisPool.getResource(); } } catch (Exception e) { logger.error("Get jedis error : "+e); }finally{ returnResource(jedis); } return jedis; } /** * 釋放jedis資源 * @paramjedis */ public static void returnResource(final Jedis jedis) { if (jedis != null && jedisPool !=null) { jedisPool.returnResource(jedis); } } /** * 設定 String * @paramkey * @paramvalue */ public static void setString(String key ,String value){ try { value = StringUtil.isEmpty(value) ? "" : value; getJedis().set(key,value); } catch (Exception e) { logger.error("Set key error : "+e); } } /** * 設定 過期時間 * @paramkey * @paramseconds 以秒為單位 * @paramvalue */ public static void setString(String key ,int seconds,String value){ try { value = StringUtil.isEmpty(value) ? "" : value; getJedis().setex(key, seconds, value); } catch (Exception e) { logger.error("Set keyex error : "+e); } } /** * 獲取String值 * @paramkey * @return value */ public static String getString(String key){ if(getJedis() == null || !getJedis().exists(key)){ return null; } return getJedis().get(key); }}

其中 jedis官方現在最高版本為2.9.0 而jedis.close()取代pool.returnResource(Jedis)方法將3.0版本開始，所以暫時只能使用後者。

//官方重寫了close。 try { jedis = pool.getResource(); } finally { if (jedis != null) { jedis.close(); } }

相關推薦

jedispool 連 redis 高併發卡死

java端在使用jedispool 連線redis的時候，在高併發的時候經常卡死，或報連線異常，JedisConnectionException，或者getResource 異常等各種問題在使用jedispool 的時候一定要注意兩點1。 在獲取 jedisPool和jedi

redis高併發秒殺測試

專案原始碼：https://pan.baidu.com/s/1KfTRyghgUqvkpBCHN6xJwg 準備 使用docker-compose命令啟動redis伺服器（可以用其他方式啟動） idea啟動測試專案 jmeter測試指令碼 高併發秒殺-重現

spring cache redis 高併發下返回null

在使用springdata操作快取中，當訪問量比較大時，有可能返回null導致資料不準確，發生機率在0.01%或以下，雖然已經低於壓測標準，但是還是會影響部分使用者，經過一番篩查，發現原因如下： RedisCache 類中 有get方法，存在明顯的邏輯錯誤 “先判斷是否存在，再去get”，程

Redis(高併發，高可用（叢集），高資料)快取資料的流程

為什麼要用redis：現在我們資料每次都是從資料庫讀取，這樣當網站訪問量達到高峰時段，對資料庫壓力很大，並且影響執 行效率。我們需要將這部分廣告資料快取起來。 1.查詢的時候走快取,增刪改的時候同步更新快取 2.查詢的時候:先查redis，根據key去查 1>.如果redis有，直接返

[Redis] - 高併發下Redis快取穿透解決

高併發情況下,可能都要訪問資料庫,因為同時訪問的方法,這時需要加入同步鎖,當其中一個快取獲取後,其它的就要通過快取獲取資料. 方法一: 在方法上加上同步鎖 synchronized //加同步鎖,解決高併發下快取穿透 @Test public synchronized void

Redis高併發可能產生的問題即個人見解解決方案

1、  如果redis宕機了，或者連結不上，怎麼辦？解決方法：    ①配置主從複製，配置哨兵模式（相當於古代門派的長老級別可以選擇掌門人的權利），一旦發現主機宕機，讓下一個從機當做主機。    ②如果最壞的情況，只能關閉Redis連線，去往資料庫連線。但由於資料量大，這樣S

redis學習系列--Redis 高併發下的，快取穿透問題解決方案

下面這段程式碼 如果1W個人同時訪問的話,  從redis 拿 allUser 時， userList為空時，那麼1W個人都要進入if判斷語句，查詢資料庫，資料庫壓力承受不住 package com.

線上Redis高併發效能調優實踐

專案背景 　　最近，做一個按優先順序和時間先後排隊的需求。用 Redis 的 sorted set 做排隊佇列。 　　主要使用的 Redis 命令有， zadd, zcount, zscore, zrange 等。 　　測試完畢後，發到線上，發現有大量介面請求返回超時熔斷（超時時間為3s）。 　　Error日

VC中間件數據庫連接正常，啟動服務時卡死

金笛短信常見問題及解決辦法金笛VC中間件測試數據庫連接都正常，但是啟動服務卡死，無法完成短信發送，參考以下解決辦法：1、打開C盤根目錄刪除三個日誌表2、關閉VC中間件服務並重啟第一步：打開Windows任務管理器，關掉VC中間件主程序XTTSmsService.exe *32，如圖：第二步：打開“開始”——“

解決終端SSH連接服務器一段時間不操作之後卡死的問題

解決方法 服務器 一段 使用 config 方法 color 重啟 ive 　　卡死是因為LIUNX安全設置問題，在一段時間內沒有使用數據的情況下會自動斷開，解決方法就是讓本地或者服務器隔一段時間發送一個請求給對方即可 　　在本地打開配置文件（不建議在server端設置）

Redis搭建高併發叢集-----Redis Cluster

伺服器：CentOS7 是偽分散式，一臺虛擬機器建立6個redis例項 1、安裝需要的依賴包 [[email protected] ~]# yum install gcc gcc-c++ kernel-devel automake autoconf libtool make

高併發搶紅包案列以及使用鎖，版本號，redis快取解決，專案可執行，詳細註釋(三)

1redis搶紅包實現 在redis中首先設定紅包的數量和金額，使用者搶到紅包之後，在redis中計算紅包數量-1，儲存使用者的資訊，直到紅包被搶完。再將使用者資訊批量儲存到資料庫中。由於redis的計算是原子性的，所以不會出現資料錯誤，可以理解成atomic系列 具體的環境搭建請檢視

高併發搶紅包案列以及使用鎖，版本號，redis快取解決，專案可執行，詳細註釋(二)

1 悲觀鎖 <!-- 查詢紅包具體資訊 --> <select id="getRedPacketForUpdate" parameterType="int"     resultType="test814RedPacket.pojo.Red

高併發搶紅包案列以及使用鎖，版本號，redis快取解決，專案可執行，詳細註釋(一)

 1.問題描述 簡單來說就是當大量資料來訪問資料庫的時候，可能導致資料不一致。如下： 發一個2000元的大紅包，總共2000個小紅包，每個一元，但是有30000個人去搶，紅包少一個就減一，插入搶紅包使用者資訊，結果看圖：  stock表示餘留的紅包數，結果是負一

Redis鎖機制處理高併發

文章正文   這裡我們主要利用Redis的setnx的命令來處理高併發。 setnx 有兩個引數。第一個引數表示鍵。第二個引數表示值。如果當前鍵不存在，那麼會插入當前鍵，將第二個引數做為值。返回 1。如果當前鍵存在，那麼會返回0。 建立庫存表 CREATE T

Redis的快取高併發處理

Springboot 整合Redis，快取過期之後，如果多個執行緒同時請求對某個資料的訪問，會同時去到資料庫，導致資料庫瞬間負荷增高。 解決辦法： ①Spring4.3為@Cacheable註解提供了一個新的引數“sync”（boolean型別，預設為false），當設定它為true時，

高併發下防止商品超賣的Redis實現

@RestController @RequestMapping("/rushbuy") @Slf4j public class RushbuyController { @Autowired private RedisTemplate redisTemplate; //釋出

多執行緒，高併發的情況下操作redis當中的資料，如何加鎖？

多個執行緒同時去操作Redis當中的資料，假如不加鎖的情況下，會出現資料重複的問題。假如需要每次都只有一條執行緒去操作Redis當中的資料，需要給操作加上鎖。     但是去網上一搜，網上給Redis加鎖的機制都是利用Redis的setnx自身的方法去加鎖，但是這樣

redis下高併發投票設計

最近閒來無事，研究了下redis，看過書籍之後，為了理解的更透徹，就實踐寫一個例子。 先說寫投票吧，具體的流程是使用者可以發起投票，發起成功後，其他使用者可以投票，首頁顯示話題標題，票數和時間等資訊。 我使用的redis設計了五個表一個是文章表，儲存話題的相關資訊，一個評分表，一個話題被投票

Redis 計數器 高併發的應用

 計數器的基本使用 /** * redis計數器 * @param key 鍵 * @return */ public Long test(String key){ //key為key，delta為遞增數目，返回值