本文整理了Java中redis.clients.jedis.JedisCluster.brpop()方法的一些代码示例，展示了JedisCluster.brpop()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JedisCluster.brpop()方法的具体详情如下：
包路径：redis.clients.jedis.JedisCluster
类名称：JedisCluster
方法名：brpop

JedisCluster.brpop介绍

暂无

代码示例

代码示例来源：origin: net.oschina.j2cache/j2cache-core

@Override
public List<byte[]> brpop(byte[] bytes) {
  return cluster.brpop(0, bytes);
}

代码示例来源：origin: org.nutz/nutz-integration-jedis

public List<String> brpop(int timeout, String... keys) {
  return jedisCluster.brpop(timeout, keys);
}

代码示例来源：origin: org.nutz/nutz-integration-jedis

public List<String> brpop(int timeout, String key) {
  return jedisCluster.brpop(timeout, key);
}

代码示例来源：origin: org.nutz/nutz-integration-jedis

public List<byte[]> brpop(int timeout, byte[]... keys) {
  return jedisCluster.brpop(timeout, keys);
}

代码示例来源：origin: hhfcyong/xxxx-dubbo

/**
 *  RPOP 命令的阻塞版本，当给定列表内没有任何元素可供弹出的时候，连接将被 BLPOP 命令阻塞，直到等待超时或发现可弹出元素为止
 * @param timeout 超时时间，设置为0 表示无限制等待
 * @param key
 * @return
 */
public String brpop(int timeout,String key){
  List<String> value=jedisCluster.brpop(timeout, key);
  return value.get(0);
}
/**

代码示例来源：origin: org.nutz/nutz-integration-jedis

@Deprecated @Override
public List<String> brpop(String arg) {
  return jedisCluster.brpop(arg);
}

代码示例来源：origin: com.github.yamingd.argo/argo-redis

@Override
public <T> List<T> brpop(Class<T> clazz, int timeout, String... keys) {
  List<byte[]> bs = jedisCluster.brpop(timeout, SafeEncoder.encodeMany(keys));
  return fromBytes(clazz, bs);
}

代码示例来源：origin: yangfuhai/jboot

/**
 * BRPOP 是列表的阻塞式(blocking)弹出原语。
 * 它是 RPOP 命令的阻塞版本，当给定列表内没有任何元素可供弹出的时候，连接将被 BRPOP 命令阻塞，直到等待超时或发现可弹出元素为止。
 * 当给定多个 key 参数时，按参数 key 的先后顺序依次检查各个列表，弹出第一个非空列表的尾部元素。
 * 关于阻塞操作的更多信息，请查看 BLPOP 命令， BRPOP 除了弹出元素的位置和 BLPOP 不同之外，其他表现一致。
 */
@SuppressWarnings("rawtypes")
public List brpop(Object... keys) {
  List<byte[]> data = jedisCluster.brpop(timeout, keysToBytesArray(keys));
  return valueListFromBytesList(data);
}

代码示例来源：origin: yangfuhai/jboot

/**
 * BRPOP 是列表的阻塞式(blocking)弹出原语。
 * 它是 RPOP 命令的阻塞版本，当给定列表内没有任何元素可供弹出的时候，连接将被 BRPOP 命令阻塞，直到等待超时或发现可弹出元素为止。
 * 当给定多个 key 参数时，按参数 key 的先后顺序依次检查各个列表，弹出第一个非空列表的尾部元素。
 * 关于阻塞操作的更多信息，请查看 BLPOP 命令， BRPOP 除了弹出元素的位置和 BLPOP 不同之外，其他表现一致。
 */
@SuppressWarnings("rawtypes")
public List brpop(Integer timeout, Object... keys) {
  List<byte[]> data = jedisCluster.brpop(timeout, keysToBytesArray(keys));
  return valueListFromBytesList(data);
}

代码示例来源：origin: com.github.yamingd.argo/argo-redis

@Override
public List<String> brpop(int timeout, String... keys) {
  List<byte[]> bs = jedisCluster.brpop(timeout, SafeEncoder.encodeMany(keys));
  return fromBytes(bs);
}

代码示例来源：origin: org.nanoframework/nano-orm-jedis

break;
case RPOP:
  values = cluster.brpop(timeout, keys);
  break;
default:

代码示例来源：origin: org.nanoframework/nano-orm-jedis

@Override
public String bpop(final String key, final int timeout, final Mark pop) {
  Assert.hasText(key);
  Assert.notNull(pop);
  try {
    final List<String> values;
    switch (pop) {
      case LPOP:
        values = cluster.blpop(timeout, key);
        break;
      case RPOP:
        values = cluster.brpop(timeout, key);
        break;
      default:
        throw new RedisClientException("Unknown Pop type");
    }
    if (!CollectionUtils.isEmpty(values)) {
      return values.get(1);
    }
    return null;
  } catch (final Throwable e) {
    throw new RedisClientException(e.getMessage(), e);
  }
}