Java 类redis.clients.jedis.params.sortedset.ZAddParams 实例源码

项目：conductor 文件：JedisMock.java

@Override
public Long zadd(String key, double score, String member, ZAddParams params) {

    try {

        if(params.contains("xx")) {
            Double existing = redis.zscore(key, member);
            if(existing == null) {
                return 0L;
            }
            return redis.zadd(key, new ZsetPair(member, score));
        }else {
            return redis.zadd(key, new ZsetPair(member, score));
        }

    } catch (Exception e) {
        throw new JedisException(e);
    }
}

项目：conductor 文件：JedisMock.java

@Override
public Long zadd(String key, double score, String member, ZAddParams params) {

    try {

        if(params.contains("xx")) {
            Double existing = redis.zscore(key, member);
            if(existing == null) {
                return 0L;
            }
            return redis.zadd(key, new ZsetPair(member, score));
        }else {
            return redis.zadd(key, new ZsetPair(member, score));
        }

    } catch (Exception e) {
        throw new JedisException(e);
    }
}

项目：commons-jkit 文件：JedisFacade.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers) {
    if (scoreMembers == null || scoreMembers.isEmpty()) {
        return 0L;
    }
    final Jedis resource = this.getResource();
    try {
        final byte[] rawKey = this.serializeKey(key);

        final Map<byte[], Double> rawScoreMembers = new HashMap<byte[], Double>();
        for (Map.Entry<String, Double> entry : scoreMembers.entrySet()) {
            final byte[] rawField = this.serializeKey(entry.getKey());

            rawScoreMembers.put(rawField, entry.getValue());
        }

        return resource.zadd(rawKey, rawScoreMembers, ZAddParams.zAddParams());
    }
    catch (Exception e) {
        throw new CacheException("redis:zadd", e);
    }
    finally {
        this.returnResource(resource);
    }
}

项目：commons-jkit 文件：JedisClusterFacade.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers) {
    if (scoreMembers == null || scoreMembers.isEmpty()) {
        return 0L;
    }
    try {
        final byte[] rawKey = this.serializeKey(key);

        final Map<byte[], Double> rawScoreMembers = new HashMap<byte[], Double>();
        for (Map.Entry<String, Double> entry : scoreMembers.entrySet()) {
            final byte[] rawField = this.serializeKey(entry.getKey());

            rawScoreMembers.put(rawField, entry.getValue());
        }

        return this.jedisCluster.zadd(rawKey, rawScoreMembers, ZAddParams.zAddParams());
    }
    catch (Exception e) {
        throw new CacheException("redis:zadd", e);
    }
}

项目：JRediClients 文件：BinaryClient.java

public void zaddBinary(final byte[] key, final Map<byte[], Double> scoreMembers, final ZAddParams params) {
    ArrayList<byte[]> args = convertScoreMembersToByteArrays(scoreMembers);
    byte[][] argsArray = new byte[args.size()][];
    args.toArray(argsArray);

    sendCommand(ZADD, params.getByteParams(key, argsArray));
}

项目：JRediClients 文件：JedisCluster.java

@Override
public Long zadd(final String key, final double score, final String member, final ZAddParams params) {
    return new JedisClusterCommand<Long>(connectionHandler, maxAttempts) {
        @Override
        public Long execute(Jedis connection) {
            return connection.zadd(key, score, member, params);
        }
    }.run(key);
}

项目：JRediClients 文件：JedisCluster.java

@Override
public Long zadd(final String key, final Map<String, Double> scoreMembers, final ZAddParams params) {
    return new JedisClusterCommand<Long>(connectionHandler, maxAttempts) {
        @Override
        public Long execute(Jedis connection) {
            return connection.zadd(key, scoreMembers, params);
        }
    }.run(key);
}

项目：JRediClients 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final double score, final byte[] member, final ZAddParams params) {
    return new JedisClusterCommand<Long>(connectionHandler, maxAttempts) {
        @Override
        public Long execute(Jedis connection) {
            return connection.zadd(key, score, member, params);
        }
    }.runBinary(key);
}

项目：JRediClients 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final Map<byte[], Double> scoreMembers, final ZAddParams params) {
    return new JedisClusterCommand<Long>(connectionHandler, maxAttempts) {
        @Override
        public Long execute(Jedis connection) {
            return connection.zadd(key, scoreMembers, params);
        }
    }.runBinary(key);
}

项目：delay-queue 文件：RedisDelayQueue.java

@Override
public boolean setTimeout(String messageId, long timeout) {
    try {
        String json = jedisCluster.hget(messageStoreKey, messageId);
        if (json == null) {
            return false;
        }
        Message message = om.readValue(json, Message.class);
        message.setTimeout(timeout);
        Double score = jedisCluster.zscore(realQueueName, messageId);
        if (score != null) {
            double priorityd = message.getPriority() / 100;
            double newScore = Long.valueOf(System.currentTimeMillis() + timeout).doubleValue() + priorityd;
            ZAddParams params = ZAddParams.zAddParams().xx();
            long added = jedisCluster.zadd(realQueueName, newScore, messageId, params);
            if (added == 1) {
                json = om.writeValueAsString(message);
                jedisCluster.hset(messageStoreKey, message.getId(), json);
                return true;
            }
            return false;
        }
        return false;
    } catch (Exception e) {
        e.printStackTrace();
        return false;
    }
}

项目：java-redis-client 文件：TracingJedisCluster.java

@Override
public Long zadd(String key, double score, String member, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("score", score);
  span.setTag("member", member);
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, score, member, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedisCluster.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("scoreMembers", TracingHelper.toString(scoreMembers));
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, scoreMembers, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedisCluster.java

@Override
public Long zadd(byte[] key, double score, byte[] member, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("member", Arrays.toString(member));
  span.setTag("score", score);
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, score, member, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedisCluster.java

@Override
public Long zadd(byte[] key, Map<byte[], Double> scoreMembers, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("scoreMembers", TracingHelper.toStringMap2(scoreMembers));
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, scoreMembers, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@Override
public Long zadd(String key, double score, String member, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("score", score);
  span.setTag("member", member);
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, score, member, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("scoreMembers", TracingHelper.toString(scoreMembers));
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, scoreMembers, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@Override
public Long zadd(byte[] key, double score, byte[] member, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("member", Arrays.toString(member));
  span.setTag("score", score);
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, score, member, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@Override
public Long zadd(byte[] key, Map<byte[], Double> scoreMembers, ZAddParams params) {
  Span span = helper.buildSpan("zadd", key);
  span.setTag("scoreMembers", TracingHelper.toStringMap2(scoreMembers));
  span.setTag("params", TracingHelper.toString(params.getByteParams()));
  try {
    return super.zadd(key, scoreMembers, params);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：cachecloud 文件：Jedis.java

@Override
public Long zadd(final String key, final double score, final String member,
    final ZAddParams params) {
  checkIsInMultiOrPipeline();
  client.zadd(key, score, member, params);
  return client.getIntegerReply();
}

项目：cachecloud 文件：BinaryClient.java

public void zadd(final byte[] key, final Map<byte[], Double> scoreMembers, final ZAddParams params) {
  ArrayList<byte[]> args = convertScoreMembersToByteArrays(scoreMembers);
  byte[][] argsArray = new byte[args.size()][];
  args.toArray(argsArray);

  sendCommand(ZADD, params.getByteParams(key, argsArray));
}

项目：cachecloud 文件：JedisCluster.java

@Override
public Long zadd(final String key, final double score, final String member,
    final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, score, member, params);
    }
  }.run(key);
}

项目：cachecloud 文件：JedisCluster.java

@Override
public Long zadd(final String key, final Map<String, Double> scoreMembers, final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, scoreMembers, params);
    }
  }.run(key);
}

项目：cachecloud 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final double score, final byte[] member,
    final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, score, member, params);
    }
  }.runBinary(key);
}

项目：cachecloud 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final Map<byte[], Double> scoreMembers, final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, scoreMembers, params);
    }
  }.runBinary(key);
}

项目：Jedis 文件：Jedis.java

@Override
public Long zadd(final String key, final double score, final String member,
    final ZAddParams params) {
  checkIsInMultiOrPipeline();
  client.zadd(key, score, member, params);
  return client.getIntegerReply();
}

项目：Jedis 文件：BinaryClient.java

public void zadd(final byte[] key, final Map<byte[], Double> scoreMembers,
    final ZAddParams params) {
  ArrayList<byte[]> args = convertScoreMembersToByteArrays(scoreMembers);
  byte[][] argsArray = new byte[args.size()][];
  args.toArray(argsArray);

  sendCommand(ZADD, params.getByteParams(key, argsArray));
}

项目：Jedis 文件：JedisCluster.java

@Override
public Long zadd(final String key, final double score, final String member,
    final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, score, member, params);
    }
  }.run(key);
}

项目：Jedis 文件：JedisCluster.java

@Override
public Long zadd(final String key, final Map<String, Double> scoreMembers, final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, scoreMembers, params);
    }
  }.run(key);
}

项目：Jedis 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final double score, final byte[] member,
    final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, score, member, params);
    }
  }.runBinary(key);
}

项目：Jedis 文件：BinaryJedisCluster.java

@Override
public Long zadd(final byte[] key, final Map<byte[], Double> scoreMembers, final ZAddParams params) {
  return new JedisClusterCommand<Long>(connectionHandler, maxRedirections) {
    @Override
    public Long execute(Jedis connection) {
      return connection.zadd(key, scoreMembers, params);
    }
  }.runBinary(key);
}

项目：dyno 文件：DynoJedisClient.java

public OperationResult<Long> d_zadd(final String key, final double score, final String member,
        final ZAddParams params) {

    return connPool.executeWithFailover(new BaseKeyOperation<Long>(key, OpName.ZADD) {

        @Override
        public Long execute(Jedis client, ConnectionContext state) {
            return client.zadd(key, score, member, params);
        }

    });
}

项目：JRediClients 文件：ShardedJedis.java

@Override
public Long zadd(String key, double score, String member, ZAddParams params) {
    Jedis j = getShard(key);
    return j.zadd(key, score, member, params);
}

项目：JRediClients 文件：ShardedJedis.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers, ZAddParams params) {
    Jedis j = getShard(key);
    return j.zadd(key, scoreMembers, params);
}

项目：JRediClients 文件：Jedis.java

@Override
public Long zadd(final String key, final double score, final String member, final ZAddParams params) {
    checkIsInMultiOrPipeline(key);
    client.zadd(key, score, member, params);
    return client.getIntegerReply();
}

项目：JRediClients 文件：Jedis.java

@Override
public Long zadd(String key, Map<String, Double> scoreMembers, ZAddParams params) {
    checkIsInMultiOrPipeline(key);
    client.zadd(key, scoreMembers, params);
    return client.getIntegerReply();
}

项目：JRediClients 文件：BinaryClient.java

public void zadd(final byte[] key, final double score, final byte[] member, final ZAddParams params) {
    sendCommand(ZADD, params.getByteParams(key, toByteArray(score), member));
}

项目：JRediClients 文件：BinaryShardedJedis.java

@Override
public Long zadd(byte[] key, double score, byte[] member, ZAddParams params) {
    Jedis j = getShard(key);
    return j.zadd(key, score, member, params);
}

项目：JRediClients 文件：BinaryShardedJedis.java

@Override
public Long zadd(byte[] key, Map<byte[], Double> scoreMembers, ZAddParams params) {
    Jedis j = getShard(key);
    return j.zadd(key, scoreMembers, params);
}

项目：JRediClients 文件：Client.java

@Override
public void zadd(final String key, final double score, final String member, final ZAddParams params) {
    zadd(SafeEncoder.encode(key), score, SafeEncoder.encode(member), params);
}

项目：JRediClients 文件：Client.java

@Override
public void zadd(final String key, final Map<String, Double> scoreMembers, final ZAddParams params) {
    HashMap<byte[], Double> binaryScoreMembers = convertScoreMembersToBinary(scoreMembers);
    zaddBinary(SafeEncoder.encode(key), binaryScoreMembers, params);
}