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

Transaction.zrem介绍

暂无

代码示例

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

@Override
public Long zRem(byte[] key, byte[]... values) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(values, "Values must not be null!");
  Assert.noNullElements(values, "Values must not contain null elements!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrem(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zrem(key, values)));
      return null;
    }
    return connection.getJedis().zrem(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

transaction.zrem(BUCKET_MONITOR + point, token);
transaction.zrem(BUCKET + point, token);
transaction.exec();

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

private void unIndex(final AttributeWrapper wrapper, final String member)
{
  Set<String> keys = wrapper.getIndexes().keySet();
  // keys
  for (String key : keys)
  {
    if (this.pipeLineOrConnection.getClass().isAssignableFrom(Transaction.class))
    {
      ((Transaction) this.pipeLineOrConnection).zrem(key, member);
    }
    else
    {
      ((Pipeline) this.pipeLineOrConnection).zrem(key, member);
    }
  }
}

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

/**
 * Deletes inverted indexes from redis.
 * 
 * @param connection
 *            redis instance.
 * @param wrapper
 *            attribute wrapper
 * @param member
 *            sorted set member name.
 */
private void unIndex(final Object connection, final AttributeWrapper wrapper, final String member)
{
  Set<String> keys = wrapper.getIndexes().keySet();
  for (String key : keys)
  {
    if (resource != null && resource.isActive())
    {
      ((Transaction) connection).zrem(key, member);
    }
    else
    {
      ((Pipeline) connection).zrem(key, member);
    }
  }
}

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

private void zrem0(String key, String... members) {
  t.zrem(key, members);
}

代码示例来源：origin: davidmarquis/redis-scheduler

@Override
public void removeFromSet(String key, String taskId) {
  if (txn != null) {
    txn.zrem(key, taskId);
  } else {
    jedis.zrem(key, taskId);
  }
}

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

((Transaction) connection).zrem(getHashKey(tableName, colName), rowKey); // delete

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

private void unIndex(final AttributeWrapper wrapper, final String member)
{
  Set<String> keys = wrapper.getIndexes().keySet();
   // keys
  for (String key : keys)
  {
    if (this.pipeLineOrConnection.getClass().isAssignableFrom(Transaction.class))
    {
      ((Transaction) this.pipeLineOrConnection).zrem(key, member);
    }
    else
    {
      ((Pipeline) this.pipeLineOrConnection).zrem(key, member);
    }
  }
}

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

public boolean unFollow(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.zrem(followeeKey, String.valueOf(userId));
  // 当前对这类实体关注-1
  transaction.zrem(followeeKey, 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: Impetus/Kundera

((Transaction) connection).zrem(
    getHashKey(entityMetadata.getTableName(),
        ((AbstractAttribute) entityMetadata.getIdAttribute()).getJPAColumnName()), rowKey);

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

/**
 * Deletes inverted indexes from redis.
 * 
 * @param connection
 *            redis instance.
 * @param wrapper
 *            attribute wrapper
 * @param member
 *            sorted set member name.
 */
private void unIndex(final Object connection, final AttributeWrapper wrapper, final String member)
{
  Set<String> keys = wrapper.getIndexes().keySet();
  for (String key : keys)
  {
    if (resource != null && resource.isActive())
    {
      ((Transaction) connection).zrem(key, member);
    }
    else
    {
      ((Pipeline) connection).zrem(key, member);
    }
  }
}

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

public static void doRemoveRecurringEnqueue(final Jedis jedis, final String namespace, final String queue, final String jobJson) {
  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.hdel(hashKey, jobJson);
    transaction.zrem(queueKey, jobJson);
    if (transaction.exec() == null) {
      throw new RuntimeException("cannot remove " + jobJson + " from recurring queue " + queue);
    }
  } else {
    throw new IllegalArgumentException(queue + " cannot be used as a recurring queue");
  }
}

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

@Override
public void evict(Object key) {
  redisContext.run(jedis -> {
    byte[] keyBytes = toKeyBytes(key);
    Transaction multi = jedis.multi();
    multi.del(keyBytes);
    multi.zrem(keysetBytes, keyBytes);
    multi.exec();
  });
}

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

private void cleanExpiredKeys() {
  redisContext.run(jedis -> {
    long currentSeconds = System.currentTimeMillis() / 1000;
    long expiredTimeSeconds = currentSeconds - expireTime;// 过期元素的时点
    while (true) {
      ScanResult<Tuple> zscan = jedis.zscan(keysetBytes, ScanParams.SCAN_POINTER_START_BINARY);
      List<Tuple> result = zscan.getResult();
      for (Tuple tuple : result) {
        byte[] key = tuple.getBinaryElement();
        long score = (long) tuple.getScore();
        if (score < expiredTimeSeconds) {// 已过期
          Transaction multi = jedis.multi();
          multi.del(key);
          multi.zrem(keysetBytes, key);
          multi.exec();
        }
      }
      String stringCursor = zscan.getStringCursor();
      if (stringCursor.equals(ScanParams.SCAN_POINTER_START)) {
        break;
      }
    }
  });
}

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

@Override
public Long zRem(byte[] key, byte[]... values) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(values, "Values must not be null!");
  Assert.noNullElements(values, "Values must not contain null elements!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrem(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zrem(key, values)));
      return null;
    }
    return connection.getJedis().zrem(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

Transaction multi = jedis.multi();
multi.del(key);
multi.zrem(keysetBytes, key);
multi.exec();

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

@Override
public Long zRem(byte[] key, byte[]... values) {
  Assert.notNull(key, "Key must not be null!");
  Assert.notNull(values, "Values must not be null!");
  Assert.noNullElements(values, "Values must not contain null elements!");
  try {
    if (isPipelined()) {
      pipeline(connection.newJedisResult(connection.getRequiredPipeline().zrem(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().zrem(key, values)));
      return null;
    }
    return connection.getJedis().zrem(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

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

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

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

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

((Transaction) connection).zrem(
    getHashKey(entityMetadata.getTableName(),
        ((AbstractAttribute) entityMetadata.getIdAttribute()).getJPAColumnName()), rowKey);