Idea和redis的坑
生活随笔
收集整理的這篇文章主要介紹了
Idea和redis的坑
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
坑1:直接在Idea里面,建TestNG的Test類時(shí),里面的多線程代碼,一直會(huì)提示報(bào)錯(cuò),沒有任何提示,直接就test任務(wù)結(jié)束。解決方案:使用main建入口的方式進(jìn)行測(cè)試,千萬不要使用testng的@Test注解這種方式進(jìn)行測(cè)試。原因,估計(jì)是多線程引起的。怎么弄還不明白,只能換成main方法里面去執(zhí)行多線程。坑2:多線程并發(fā)會(huì)造成沖突,會(huì)報(bào)各種錯(cuò)。解決方法:使用JRedisPool建立線程池。而且在操作時(shí),使用synchronized把操作方法進(jìn)行封裝。否則依然會(huì)報(bào)錯(cuò)。坑3: 超出線程池容量。1000個(gè)線程,會(huì)報(bào)大量的錯(cuò)。 解決方法: JedisPoolConfig里面設(shè)置 //Redis服務(wù)器IPprivate static String ADDR_ARRAY = "127.0.0.1";//Redis的端口號(hào)private static int PORT = 6379;//訪問密碼private static String AUTH = "";//可用連接實(shí)例的最大數(shù)目,默認(rèn)值為8;//如果賦值為-1,則表示不限制;如果pool已經(jīng)分配了maxActive個(gè)jedis實(shí)例,則此時(shí)pool的狀態(tài)為exhausted(耗盡)。private static int MAX_ACTIVE = 500;//控制一個(gè)pool最多有多少個(gè)狀態(tài)為idle(空閑的)的jedis實(shí)例,默認(rèn)值也是8。private static int MAX_IDLE = 100;//等待可用連接的最大時(shí)間,單位毫秒,默認(rèn)值為-1,表示永不超時(shí)。如果超過等待時(shí)間,則直接拋出JedisConnectionException;private static int MAX_WAIT = 10 * 1000;private static int TIMEOUT = 10 * 1000;//超時(shí)時(shí)間//在borrow一個(gè)jedis實(shí)例時(shí),是否提前進(jìn)行validate操作;如果為true,則得到的jedis實(shí)例均是可用的;private static boolean TEST_ON_BORROW = true;private static JedisPool jedisPool = null;/*** 初始化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);//使用時(shí)進(jìn)行掃描,確保都可用config.setTestWhileIdle(true);//Idle時(shí)進(jìn)行連接掃描config.setTestOnReturn(true);//還回線程池時(shí)進(jìn)行掃描
//
表示idle object evitor兩次掃描之間要sleep的毫秒數(shù)
// config.setTimeBetweenEvictionRunsMillis(30000);
//
表示idle object evitor每次掃描的最多的對(duì)象數(shù)
// config.setNumTestsPerEvictionRun(10);
//
表示一個(gè)對(duì)象至少停留在idle狀態(tài)的最短時(shí)間,然后才能被idle object evitor掃描并驅(qū)逐;這一項(xiàng)只有在timeBetweenEvictionRunsMillis大于0時(shí)才有意義
// config.setMinEvictableIdleTimeMillis(60000);if (StringUtils.isNotBlank(AUTH)) {jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT, AUTH);} else {jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT);}} catch (Exception e) {logger.error("First create JedisPool error : " + e);try {//如果第一個(gè)IP異常,則訪問第二個(gè)IPJedisPoolConfig 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, AUTH);} catch (Exception e2) {logger.error("Second create JedisPool error : " + e2);}}}/*** 在多線程環(huán)境同步初始化*/private static synchronized void poolInit() {if (jedisPool == null) {initialPool();}}/*** 同步獲取Jedis實(shí)例** @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.getMessage(), e);} finally {returnResource(jedis);//歸還到Redis池里面}return jedis;}/*** 釋放jedis資源** @param jedis*/public static void returnResource(final Jedis jedis) {if (jedis != null && jedisPool != null) {jedisPool.returnResource(jedis);}}/*** 關(guān)閉連接池*/public static void closePool() {if (jedisPool != null) {jedisPool.close();}}/*** 設(shè)置 String** @param key* @param value*/public synchronized static void setString(String key, String value) {try {value = StringUtils.isEmpty(value) ? "" : value;getJedis().set(key, value);} catch (Exception e) {logger.error("Set key error : " + e);}}/*** 設(shè)置 過期時(shí)間** @param key* @param seconds 以秒為單位* @param value*/public synchronized static void setString(String key, int seconds, String value) {try {value = StringUtils.isEmpty(value) ? "" : value;getJedis().setex(key, seconds, value);} catch (Exception e) {logger.error("Set keyex error : " + e);}}/*** 獲取String值** @param key* @return value*/public synchronized static String getString(String key) {if (getJedis() == null || !getJedis().exists(key)) {return null;}return getJedis().get(key);}}
轉(zhuǎn)載于:https://www.cnblogs.com/albertzhangyu/p/9767823.html
總結(jié)
以上是生活随笔為你收集整理的Idea和redis的坑的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 数据库(表)导入导出备份
- 下一篇: Tensorflow取消占用全部GPU