redis.clients.jedis.Transaction.zadd()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(267)

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

Transaction.zadd介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-data-redis

@Override
public Boolean zAdd(byte[] key, double score, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    return JedisConverters.toBoolean(connection.getJedis().zadd(key, score, value));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: spring-projects/spring-data-redis

@Override
public Long zAdd(byte[] key, Set<Tuple> tuples) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(tuples, "Tuples must not be null!");
  try {
    if (isPipelined()) {
      pipeline(
          connection.newJedisResult(connection.getRequiredPipeline().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    if (isQueueing()) {
      transaction(connection
          .newJedisResult(connection.getRequiredTransaction().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    return connection.getJedis().zadd(key, JedisConverters.toTupleMap(tuples));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: Impetus/Kundera

((Transaction) this.pipeLineOrConnection).zadd(idx_Name, value, parentId.toString());

代码示例来源：origin: Exrick/x-boot

transaction.zadd(BUCKET_MONITOR + point, now, token);
transaction.zadd(BUCKET + point, counter, token);
transaction.zrank(BUCKET + point, token);
results = transaction.exec();

代码示例来源：origin: mindwind/craft-atom

private void zadd0(String key, Map<String, Double> scoremembers) {
  t.zadd(key, scoremembers);
}

代码示例来源：origin: Impetus/Kundera

((Transaction) connection).zadd(getHashKey(tableName, inverseJoinKeyAsStr),
    getDouble(inverseJoinKeyAsStr), redisKey);
((Transaction) connection).zadd(getHashKey(tableName, joinKeyAsStr), getDouble(joinKeyAsStr),
    redisKey);

代码示例来源：origin: Sunybyjava/wenda

/**
 * 用户关注了某个实体,实体可以是问题,用户,评论等任何实体
 *
 * @param userId     用户的ID
 * @param entityType 实体的类型
 * @param entityId   实体的ID
 * @return
 */
public boolean follow(int userId, int entityType, int entityId) {
  String followerKey = RedisKeyUtil.getFollowerKey(entityType, entityId);
  String followeeKey = RedisKeyUtil.getFolloweeKey(userId, entityType);
  Date date = new Date();
  // 实体的粉丝增加当前用户
  Jedis jedis = jedisAdapter.getJedis();
  Transaction transaction = jedisAdapter.multi(jedis);
  transaction.zadd(followeeKey, date.getTime(), String.valueOf(userId));
  // 当前对这类实体关注+1
  transaction.zadd(followeeKey, date.getTime(), String.valueOf(entityId));
  List<Object> ret = jedisAdapter.exec(transaction, jedis);
  return ret.size() == 2 && (Long) ret.get(0) > 0 && (Long) ret.get(1) > 0;
}

代码示例来源：origin: com.impetus.client/kundera-redis

((Transaction) this.pipeLineOrConnection).zadd(idx_Name, value, parentId.toString());

代码示例来源：origin: gresrun/jesque

public static void doRecurringEnqueue(final Jedis jedis, final String namespace, final String queue, final String jobJson, final long future, final long frequency){
  final String queueKey = JesqueUtils.createKey(namespace, QUEUE, queue);
  final String hashKey = JesqueUtils.createRecurringHashKey(queueKey);
  if (JedisUtils.canUseAsRecurringQueue(jedis, queueKey, hashKey)) {
    Transaction transaction = jedis.multi();
    transaction.zadd(queueKey, future, jobJson);
    transaction.hset(hashKey, jobJson, String.valueOf(frequency));
    if (transaction.exec() == null) {
      throw new RuntimeException("cannot add " + jobJson + " to recurring queue " + queue);
    }
  } else {
    throw new IllegalArgumentException(queue + " cannot be used as a recurring queue");
  }
}

代码示例来源：origin: com.intoverflow.booster/booster-core

@Override
public void put(Object key, Object value) {
  redisContext.run(jedis -> {
    byte[] keyBytes = toKeyBytes(key);
    Transaction multi = jedis.multi();
    long currentSeconds = System.currentTimeMillis() / 1000;
    if (expireTime > 0) {
      multi.setex(keyBytes, expireTime, serialize(value));
    } else {
      multi.set(keyBytes, serialize(value));
    }
    multi.zadd(keysetBytes, currentSeconds, keyBytes);
    multi.exec();
  });
}

代码示例来源：origin: com.github.jkutner/tomcat-redis-session

transaction.expireAt(timeoutKey, getUnixTime(expireAtTimeWithReserve));
transaction.zadd(sessionsKey, currentTime, id);

代码示例来源：origin: zinin/tomcat-redis-session

transaction.expireAt(timeoutKey, getUnixTime(expireAtTimeWithReserve));
transaction.zadd(sessionsKey, currentTime, id);

代码示例来源：origin: apache/servicemix-bundles

@Override
public Long zAdd(byte[] key, Set<Tuple> tuples) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(tuples, "Tuples must not be null!");
  try {
    if (isPipelined()) {
      pipeline(
          connection.newJedisResult(connection.getRequiredPipeline().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    if (isQueueing()) {
      transaction(connection
          .newJedisResult(connection.getRequiredTransaction().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    return connection.getJedis().zadd(key, JedisConverters.toTupleMap(tuples));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: org.springframework.data/spring-data-redis

@Override
public Boolean zAdd(byte[] key, double score, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    return JedisConverters.toBoolean(connection.getJedis().zadd(key, score, value));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: org.springframework.data/spring-data-redis

@Override
public Long zAdd(byte[] key, Set<Tuple> tuples) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(tuples, "Tuples must not be null!");
  try {
    if (isPipelined()) {
      pipeline(
          connection.newJedisResult(connection.getRequiredPipeline().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    if (isQueueing()) {
      transaction(connection
          .newJedisResult(connection.getRequiredTransaction().zadd(key, JedisConverters.toTupleMap(tuples))));
      return null;
    }
    return connection.getJedis().zadd(key, JedisConverters.toTupleMap(tuples));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public Boolean zAdd(byte[] key, double score, byte[] value) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(value, "Value must not be null!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zadd(key, score, value),
          JedisConverters.longToBoolean()));
      return null;
    }
    return JedisConverters.toBoolean(connection.getJedis().zadd(key, score, value));
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: com.github.jkutner/tomcat-redis-session

transaction.expireAt(lastAccessTimeKey, getUnixTime(expireAtTime));
transaction.zadd(RedisSessionKeys.getSessionsKey(), currentTime, id);

代码示例来源：origin: zinin/tomcat-redis-session

transaction.expireAt(lastAccessTimeKey, getUnixTime(expireAtTime));
transaction.zadd(RedisSessionKeys.getSessionsKey(), currentTime, id);

代码示例来源：origin: com.github.jkutner/tomcat-redis-session

transaction.zadd(RedisSessionKeys.getSessionsKey(), lastAccessTime, id);
transaction.zrem(RedisSessionKeys.getSessionsKey(), this.id);

代码示例来源：origin: zinin/tomcat-redis-session

transaction.zadd(RedisSessionKeys.getSessionsKey(), lastAccessTime, id);
transaction.zrem(RedisSessionKeys.getSessionsKey(), this.id);

内容来源于网络，如有侵权，请联系作者删除！

Transaction

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Transaction类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com