<dependency>
	<groupId>com.ibeetl</groupId>
	<artifactId>redis-server</artifactId>
	<version>0.1.0</version>
</dependency>

public class RedisServerTest {


    RedisServer server;
    @Before
    public void init() throws IOException {
        server = new RedisServer();
        server.listener("localhost",9999);
    }

    @After
    public void close() throws IOException {
        server.close();
    }


    @Test
    public void testPing2() throws IOException {
        JedisCluster jedis = connection();
        jedis.set("abc","efg");
   
        String value = jedis.get("abc");
        Assert.assertEquals("efg",value);

    }

  protected JedisCluster connection() throws IOException {
        InetSocketAddress address = (InetSocketAddress)server.getServerSocket().getLocalSocketAddress();


        Set<HostAndPort> hostAndPortsSet = new HashSet<HostAndPort>();
        // 添加节点
        hostAndPortsSet.add(new HostAndPort(address.getHostName(), address.getPort()));


        // Jedis连接池配置
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

        //最小空闲连接数, 默认0
        jedisPoolConfig.setMinIdle(0);
        // 获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
        jedisPoolConfig.setMaxWaitMillis(200000); // 设置2秒
        //对拿到的connection进行validateObject校验
        jedisPoolConfig.setTestOnBorrow(true);


        JedisCluster jedis = new JedisCluster(hostAndPortsSet,jedisPoolConfig);
        return jedis;
    }



}