Java ClientKillerUtil类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中redis.clients.jedis.tests.utils.ClientKillerUtil类的典型用法代码示例。如果您正苦于以下问题：Java ClientKillerUtil类的具体用法？Java ClientKillerUtil怎么用？Java ClientKillerUtil使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ClientKillerUtil类属于redis.clients.jedis.tests.utils包，在下文中一共展示了ClientKillerUtil类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: scriptExistsWithBrokenConnection

import redis.clients.jedis.tests.utils.ClientKillerUtil; //导入依赖的package包/类
@Test
public void scriptExistsWithBrokenConnection() {
  Jedis deadClient = new Jedis(jedis.getClient().getHost(), jedis.getClient().getPort());
  deadClient.auth("foobared");

  deadClient.clientSetname("DEAD");

  ClientKillerUtil.killClient(deadClient, "DEAD");

  // sure, script doesn't exist, but it's just for checking connection
  try {
    deadClient.scriptExists("abcdefg");
  } catch (JedisConnectionException e) {
    // ignore it
  }

  assertEquals(true, deadClient.getClient().isBroken());

  deadClient.close();
}

开发者ID:qq1588518，项目名称:JRediClients，代码行数:21，代码来源:ScriptingCommandsTest.java

示例2: testReturnConnectionOnJedisConnectionException

import redis.clients.jedis.tests.utils.ClientKillerUtil; //导入依赖的package包/类
@Test(timeout = DEFAULT_TIMEOUT)
public void testReturnConnectionOnJedisConnectionException() throws InterruptedException {
  Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();
  jedisClusterNode.add(new HostAndPort("127.0.0.1", 7379));
  JedisPoolConfig config = DEFAULT_CONFIG;
  config.setMaxTotal(1);
  JedisCluster jc = new JedisCluster(jedisClusterNode, DEFAULT_TIMEOUT, DEFAULT_TIMEOUT, DEFAULT_REDIRECTIONS, "cluster", config);

  Jedis j = jc.getClusterNodes().get("127.0.0.1:7380").getResource();
  ClientKillerUtil.tagClient(j, "DEAD");
  ClientKillerUtil.killClient(j, "DEAD");
  j.close();

  jc.get("test");
}

开发者ID:qq1588518，项目名称:JRediClients，代码行数:16，代码来源:JedisClusterTest.java

示例3: testReturnConnectionOnJedisConnectionException

import redis.clients.jedis.tests.utils.ClientKillerUtil; //导入依赖的package包/类
@Test(timeout = 2000)
public void testReturnConnectionOnJedisConnectionException() throws InterruptedException {
  Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();
  jedisClusterNode.add(new HostAndPort("127.0.0.1", 7379));
  JedisPoolConfig config = new JedisPoolConfig();
  config.setMaxTotal(1);
  JedisCluster jc = new JedisCluster(jedisClusterNode, config);

  Jedis j = jc.getClusterNodes().get("127.0.0.1:7380").getResource();
  ClientKillerUtil.tagClient(j, "DEAD");
  ClientKillerUtil.killClient(j, "DEAD");
  j.close();

  jc.get("test");
}

开发者ID:sohutv，项目名称:cachecloud，代码行数:16，代码来源:JedisClusterTest.java

示例4: testAvoidLeaksUponDisconnect

import redis.clients.jedis.tests.utils.ClientKillerUtil; //导入依赖的package包/类
/**
 * Test for "Issue - BinaryShardedJedis.disconnect() may occur memory leak". You can find more
 * detailed information at https://github.com/xetorthio/jedis/issues/808
 * @throws InterruptedException
 */
@Test
public void testAvoidLeaksUponDisconnect() throws InterruptedException {
  List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(2);
  // 6379
  JedisShardInfo shard1 = new JedisShardInfo(redis1.getHost(), redis1.getPort());
  shard1.setPassword("foobared");
  shards.add(shard1);
  // 6380
  JedisShardInfo shard2 = new JedisShardInfo(redis2.getHost(), redis2.getPort());
  shard2.setPassword("foobared");
  shards.add(shard2);

  @SuppressWarnings("resource")
  ShardedJedis shardedJedis = new ShardedJedis(shards);
  // establish the connection for two redis servers
  shardedJedis.set("a", "bar");
  JedisShardInfo ak = shardedJedis.getShardInfo("a");
  assertEquals(shard2, ak);
  shardedJedis.set("b", "bar1");
  JedisShardInfo bk = shardedJedis.getShardInfo("b");
  assertEquals(shard1, bk);

  // We set a name to the instance so it's easy to find it
  Iterator<Jedis> it = shardedJedis.getAllShards().iterator();
  Jedis deadClient = it.next();
  deadClient.clientSetname("DEAD");

  ClientKillerUtil.killClient(deadClient, "DEAD");

  assertEquals(true, deadClient.isConnected());
  assertEquals(false, deadClient.getClient().getSocket().isClosed());
  assertEquals(false, deadClient.getClient().isBroken()); // normal - not found

  shardedJedis.disconnect();

  assertEquals(false, deadClient.isConnected());
  assertEquals(true, deadClient.getClient().getSocket().isClosed());
  assertEquals(true, deadClient.getClient().isBroken());

  Jedis jedis2 = it.next();
  assertEquals(false, jedis2.isConnected());
  assertEquals(true, jedis2.getClient().getSocket().isClosed());
  assertEquals(false, jedis2.getClient().isBroken());

}

开发者ID:qq1588518，项目名称:JRediClients，代码行数:51，代码来源:ShardedJedisTest.java

注：本文中的redis.clients.jedis.tests.utils.ClientKillerUtil类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。