JedisConnectionSuddenlyBroken.java

package net.heartsavior.dev;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.exceptions.JedisConnectionException;

public class JedisConnectionSuddenlyBrokenTest {

    public static void main(String[] args) throws InterruptedException {
	Jedis jedis = new Jedis("127.0.0.1", 6379);
	
	for (int i = 0 ; i < 10000000 ; i++) {
	    try {
		jedis.set("hello", "world");
		
		if (i % 10000 == 0) {
		    System.out.println(i);
		}
	    } catch (JedisConnectionException ex) {
		System.out.println("JedisConnectionException - exc: " + ex);
	    } catch (Exception ex) {
		System.out.println("Exception - exc: " + ex);
		Thread.sleep(1000);
		//break;
	    }
	}
	
	jedis.disconnect();
	
	System.out.println("Done...");
    }

}