Java ZAddParams类代码示例

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

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

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

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

示例1: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
	}
}

开发者ID:Netflix，项目名称:conductor，代码行数:20，代码来源:JedisMock.java

示例2: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
	}
}

开发者ID:5waynewang，项目名称:commons-jkit，代码行数:26，代码来源:JedisFacade.java

示例3: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
	}
}

开发者ID:5waynewang，项目名称:commons-jkit，代码行数:22，代码来源:JedisClusterFacade.java

示例4: zaddBinary

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
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));
}

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

示例5: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
}

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

示例6: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
}

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

示例7: setTimeout

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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;
	}
}

开发者ID:MeiPian，项目名称:delay-queue，代码行数:29，代码来源:RedisDelayQueue.java

示例8: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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();
  }
}

开发者ID:opentracing-contrib，项目名称:java-redis-client，代码行数:16，代码来源:TracingJedisCluster.java

示例9: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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();
}

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

示例10: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
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));
}

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

示例11: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
}

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

示例12: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
}

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

示例13: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
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));
}

开发者ID:Wangab，项目名称:Jedis，代码行数:9，代码来源:BinaryClient.java

示例14: d_zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
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);
        }

    });
}

开发者ID:Netflix，项目名称:dyno，代码行数:13，代码来源:DynoJedisClient.java

示例15: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@Override
public Long zadd(String key, double score, String member, ZAddParams params) {
	Jedis j = getShard(key);
	return j.zadd(key, score, member, params);
}

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

示例16: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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();
}

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

示例17: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
public void zadd(final byte[] key, final double score, final byte[] member, final ZAddParams params) {
	sendCommand(ZADD, params.getByteParams(key, toByteArray(score), member));
}

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

示例18: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@Override
public Long zadd(byte[] key, double score, byte[] member, ZAddParams params) {
	Jedis j = getShard(key);
	return j.zadd(key, score, member, params);
}

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

示例19: zadd

import redis.clients.jedis.params.sortedset.ZAddParams; //导入依赖的package包/类
@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);
}

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

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