最近在寫入redis的時候，程式跑著跑著會發現碰到這樣的問題。

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.readByte(RedisInputStream.java:40)
    at redis.clients.jedis.Protocol.process(Protocol.java:151)
    at redis.clients.jedis.Protocol.read(Protocol.java:215)
    at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340)
    at redis.clients.jedis.Connection.getBinaryMultiBulkReply(Connection.java:276)
    at redis.clients.jedis.Connection.getMultiBulkReply(Connection.java:269)
    at redis.clients.jedis.Jedis.lrange(Jedis.java:935)
    at com.redislabs.provider.redis.rdd.RedisListRDD$$anonfun$getLIST$1$$anonfun$3.apply(RedisRDD.scala:98)
    at com.redislabs.provider.redis.rdd.RedisListRDD$$anonfun$getLIST$1$$anonfun$3.apply(RedisRDD.scala:98)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
    at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
    at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
    at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
    at scala.collection.mutable.ArrayOps$ofRef.flatMap(ArrayOps.scala:186)
 

針對這一問題，之前直接都是利用

val client = new Jedis(ip, port)的方法，巢狀在dataframe.foreach()中的方式。

由於之前部署是流式的資料處理，所以每次處理間隔都非常短，因此沒有任何問題。但是這回為了檢視一個數據想快取到spark的時候，發現了這個BUG。也才具體發現以前程式設定的不合理的地方。

還好，Jedis提供了這種解決方法。

• public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, final int port, final int timeout)
• public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, int timeout, final String password, final int database)
• public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, int timeout, final String password, final int database, final String clientName)

根據大概程式寫入redis的資料量和時長來設定即可。

由於本來寫入的資料量大概有7億多條記錄，為了方便，拆分了400個小片斷分開寫入，再用上述預設設定，也能夠通過。

程式碼片斷可以如下：

Jediscommands jediscommands;
JedisPool jedisPool;
JedisPoolConfig config = new JedisPoolConfig()

String ip = "***"
int port = 6379
long timeOut = 2000

String auth = "***"
JedisPool jedisPool = new JedisPool(config,ip,port,timeOut,auth)

Jedis jedis = jedisPool.getResource();

當前，也只可以對JedisPoolConfig進行設定。