国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數(shù)據(jù)庫 > Redis > 正文

Redis連接超時(shí)異常的處理方法

2020-10-28 21:27:41
字體:
供稿:網(wǎng)友

0、問題描述

使用Jedis連接redis進(jìn)行數(shù)據(jù)查詢操作,正常的代碼運(yùn)行沒有問題,但是時(shí)不時(shí)會報(bào)出如下錯(cuò)誤:

Exception in thread "main" redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketTimeoutException: Read timed out
 at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:202)
 at redis.clients.util.RedisInputStream.read(RedisInputStream.java:181)
 at redis.clients.jedis.Protocol.processBulkReply(Protocol.java:181)
 at redis.clients.jedis.Protocol.process(Protocol.java:155)
 at redis.clients.jedis.Protocol.processMultiBulkReply(Protocol.java:206)
 at redis.clients.jedis.Protocol.process(Protocol.java:157)
 at redis.clients.jedis.Protocol.processMultiBulkReply(Protocol.java:206)
 at redis.clients.jedis.Protocol.process(Protocol.java:157)
 at redis.clients.jedis.Protocol.read(Protocol.java:215)
 at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340)
 at redis.clients.jedis.Connection.getRawObjectMultiBulkReply(Connection.java:285)
 at redis.clients.jedis.Connection.getObjectMultiBulkReply(Connection.java:291)
 at redis.clients.jedis.BinaryJedis.hscan(BinaryJedis.java:3390)
 at com.ict.mcg.filter.DuplicateClueFilterV2.hscan(DuplicateClueFilterV2.java:867)
 at com.ict.mcg.filter.DuplicateClueFilterV2.collectRecentCluekeywords(DuplicateClueFilterV2.java:487)
 at com.ict.mcg.main.GetCluesMain.run_online(GetCluesMain.java:208)
 at com.ict.mcg.main.GetCluesMain.main(GetCluesMain.java:1685)
Caused by: java.net.SocketTimeoutException: Read timed out
 at java.net.SocketInputStream.socketRead0(Native Method)
 at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
 at java.net.SocketInputStream.read(SocketInputStream.java:171)
 at java.net.SocketInputStream.read(SocketInputStream.java:141)
 at java.net.SocketInputStream.read(SocketInputStream.java:127)
 at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:196)
 ... 16 more

究其原因,可以定位為java.net.SocketTimeoutException: Read timed out,即網(wǎng)絡(luò)連接異常;

1、 可能的原因

1.1 服務(wù)器資源包括內(nèi)存、磁盤、cpu等利用率高

經(jīng)過查看redis部署機(jī)器的狀態(tài)信息,發(fā)現(xiàn)整體機(jī)器運(yùn)行狀態(tài)良好

1.2 服務(wù)器設(shè)置防火墻,導(dǎo)致連接失敗

因?yàn)檎5拇a流程都可以跑通,所以防火墻設(shè)置沒有問題;

1.3 redis配置文件bind監(jiān)聽host配置不當(dāng)

redis的配置文件中bind對應(yīng)host的配置如下:

# By default Redis listens for connections from all the network interfaces# available on the server. It is possible to listen to just one or multiple# interfaces using the "bind" configuration directive, followed by one or# more IP addresses.## Examples:## bind 192.168.1.100 10.0.0.1# bind 127.0.0.1

默認(rèn)的bind綁定的host為0.0.0.0,即可以監(jiān)聽每一個(gè)可用的網(wǎng)絡(luò)接口;相當(dāng)于配置為:

bind 0.0.0.0

我們的配置文件也配置正常,而且正常的代碼流程運(yùn)行正常,也可以佐證這一點(diǎn);

1.4 Jedis使用配置問題

目前Jedis的連接池配置如下:

private static JedisPool getPool() {    if (pool == null) {      JedisPoolConfig config = new JedisPoolConfig();      //控制一個(gè)pool可分配多少個(gè)jedis實(shí)例,通過pool.getResource()來獲取;      //如果賦值為-1,則表示不限制;如果pool已經(jīng)分配了maxActive個(gè)jedis實(shí)例,則此時(shí)pool的狀態(tài)為exhausted(耗盡)。      config.setMaxActive(10);      //控制一個(gè)pool最多有多少個(gè)狀態(tài)為idle(空閑的)的jedis實(shí)例。      config.setMaxIdle(2);      //表示當(dāng)borrow(引入)一個(gè)jedis實(shí)例時(shí),最大的等待時(shí)間,如果超過等待時(shí)間,則直接拋出JedisConnectionException;      config.setMaxWait(1000 * 200000);      //在borrow一個(gè)jedis實(shí)例時(shí),是否提前進(jìn)行validate操作;如果為true,則得到的jedis實(shí)例均是可用的;      config.setTestOnBorrow(true);      config.setTestOnReturn(true);      //目前redis只有一個(gè)服務(wù)器      pool = new JedisPool(config, "localhost", 6379);    }    return pool;  }  private static Jedis getJedis() {    Jedis jedis = null;    int count = 0;    do {      try {        pool = getPool();        jedis = pool.getResource();      } catch(Exception e) {//    System.out.println(e.getMessage());        e.printStackTrace();        pool.returnBrokenResource(jedis);      }      count++;    } while (jedis==null && count < 3);    return jedis;  }

構(gòu)建JedisPool的邏輯中,只是設(shè)置了config.setMaxWait(1000 * 200000);,這個(gè)是引入新的jedis實(shí)例的最大等待時(shí)間,并沒有進(jìn)行其他相關(guān)的連接超時(shí)的配置;于是查看JedisPool的源代碼,發(fā)現(xiàn)如下:

public JedisPool(final Config poolConfig, final String host) {    this(poolConfig, host, Protocol.DEFAULT_PORT, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);  }  public JedisPool(String host, int port) {    this(new Config(), host, port, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);  }  public JedisPool(final String host) {    this(host, Protocol.DEFAULT_PORT);  }  public JedisPool(final Config poolConfig, final String host, int port,      int timeout, final String password) {    this(poolConfig, host, port, timeout, password, Protocol.DEFAULT_DATABASE);  }  public JedisPool(final Config poolConfig, final String host, final int port) {    this(poolConfig, host, port, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);  }  public JedisPool(final Config poolConfig, final String host, final int port, final int timeout) {    this(poolConfig, host, port, timeout, null, Protocol.DEFAULT_DATABASE);  }  public JedisPool(final Config poolConfig, final String host, int port, int timeout, final String password,          final int database) {    super(poolConfig, new JedisFactory(host, port, timeout, password, database));  }

由上述代碼可以看到,JedisPool有多個(gè)重載的構(gòu)造函數(shù),并且構(gòu)造函數(shù)中需要傳入一個(gè)timeout參數(shù)作為連接的超時(shí)時(shí)間,如果沒有傳,則采用Protocol.DEFAULT_TIMEOUT作為默認(rèn)的超時(shí)時(shí)間,繼續(xù)跟蹤源碼:

public final class Protocol {  public static final int DEFAULT_PORT = 6379;  public static final int DEFAULT_TIMEOUT = 2000;  public static final int DEFAULT_DATABASE = 0;  public static final String CHARSET = "UTF-8";  public static final byte DOLLAR_BYTE = '$';  public static final byte ASTERISK_BYTE = '*';  public static final byte PLUS_BYTE = '+';  public static final byte MINUS_BYTE = '-';  public static final byte COLON_BYTE = ':';  private Protocol() { // this prevent the class from instantiation  }

可以得出結(jié)論,默認(rèn)JedisPool中連接的默認(rèn)超時(shí)時(shí)間為2秒,而我們調(diào)用的JedisPool構(gòu)造函數(shù),恰恰采用的是這個(gè)配置,只要兩秒鐘沒有連接成功,redis的連接就斷開,從而報(bào)錯(cuò),這在數(shù)據(jù)庫請求并發(fā)量比較大的時(shí)候是有可能發(fā)生的,遂做如下更改,在創(chuàng)建JedisPool的時(shí)候,傳入一個(gè)較大的超時(shí)時(shí)間:

pool = new JedisPool(config, ParamUtil.REDIS_ADDRESS[0], ParamUtil.REDIS_PORT, 1000 * 10);

2、總結(jié)

遇到問題還是多查,多看源碼,多看源碼中的配置,仔細(xì)一項(xiàng)一項(xiàng)地排查問題!

到此這篇關(guān)于Redis連接超時(shí)異常處理的文章就介紹到這了,更多相關(guān)Redis連接超時(shí)異常內(nèi)容請搜索武林網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持武林網(wǎng)!

發(fā)表評論 共有條評論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 留坝县| 大厂| 永登县| 旅游| 扎兰屯市| 隆尧县| 二连浩特市| 独山县| 会理县| 荔浦县| 伊春市| 塔城市| 大洼县| 阳高县| 茶陵县| 遂川县| 建平县| 平邑县| 密山市| 庄浪县| 上蔡县| 苗栗县| 河北区| 成武县| 正宁县| 汉阴县| 徐州市| 海口市| 贵定县| 和静县| 六安市| 文水县| 元朗区| 阿坝县| 新乡县| 襄垣县| 承德市| 双辽市| 平邑县| 同仁县| 昌图县|