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

Pipeline.sadd介绍

暂无

代码示例

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

@Override
public Long sAdd(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().sadd(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().sadd(key, values)));
      return null;
    }
    return connection.getJedis().sadd(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: com.netflix.dyno/dyno-jedis

@Override
Response<Long> execute(Pipeline jedisPipeline) throws DynoException {
  return jedisPipeline.sadd(key, member);
}

代码示例来源：origin: stackoverflow.com

try (Jedis jedis = new Jedis(host, port)) {
 Pipeline pipeline = jedis.pipelined();
 while (iter.hasNext()) {
  String[] keyValue = iter.next().split("\t");
  pipeline.sadd(keyValue[0], keyValue[1]);
  // you can call pipeline.sync() and start new pipeline here if you think there're so much operations in one pipeline
 }
 pipeline.sync();
}

代码示例来源：origin: com.netflix.spinnaker.kork/kork-jedis

@Override
public Response<Long> sadd(String key, String... member) {
 String command = "sadd";
 return instrumented(command, payloadSize(member), () -> delegated.sadd(key, member));
}

代码示例来源：origin: com.netflix.spinnaker.kork/kork-jedis

@Override
public Response<Long> sadd(byte[] key, byte[]... member) {
 String command = "sadd";
 return instrumented(command, payloadSize(member), () -> delegated.sadd(key, member));
}

代码示例来源：origin: com.opencredo/concourse-redis

private Response<Long> writeEventsForId(Pipeline pipeline, AggregateId id, List<Event> eventsForId) {
  return pipeline.sadd(id.toString(), serialiseEvents(eventsForId));
}

代码示例来源：origin: com.opencredo/concursus-redis

private Response<Long> writeEventsForId(Pipeline pipeline, AggregateId id, List<Event> eventsForId) {
  return pipeline.sadd(id.toString(), serialiseEvents(eventsForId));
}

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

public Long execute(final Jedis conn) throws Exception {
    byte[] bk = SafeEncoder.encode(key);
    Pipeline pipe = conn.pipelined();
    for(Object v : members){
      pipe.sadd(bk, SafeEncoder.encode(String.valueOf(v)));
    }
    pipe.exec();
    return 1L;
  }
});

代码示例来源：origin: com.netflix.spinnaker.fiat/fiat-roles

pipeline.sadd(allUsersKey(), userId);
 pipeline.sadd(adminKey(), userId);
} else {
 pipeline.srem(adminKey(), userId);
permission.getRoles().forEach(role -> pipeline.sadd(roleKey(role), userId));
existingRoles.stream()
 .filter(it -> !permission.getRoles().contains(it))

代码示例来源：origin: spinnaker/fiat

pipeline.sadd(allUsersKey(), userId);
 pipeline.sadd(adminKey(), userId);
} else {
 pipeline.srem(adminKey(), userId);
permission.getRoles().forEach(role -> pipeline.sadd(roleKey(role), userId));
existingRoles.stream()
 .filter(it -> !permission.getRoles().contains(it))

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

/**
 * Helper method that encapsulates the minimum logic for adding jobs to a queue.
 * 
 * @param jedis
 *            the connection to Redis
 * @param namespace
 *            the Resque namespace
 * @param queue
 *            the Resque queue name
 * @param jobJsons
 *            a list of jobs serialized as JSON
 */
public static void doBatchEnqueue(final Jedis jedis, final String namespace, final String queue, final List<String> jobJsons) {
  Pipeline pipelined = jedis.pipelined();
  pipelined.sadd(JesqueUtils.createKey(namespace, QUEUES), queue);
  for (String jobJson : jobJsons) {
    pipelined.rpush(JesqueUtils.createKey(namespace, QUEUE, queue), jobJson);
  }
  pipelined.sync();
}

代码示例来源：origin: pyloque/captain

public void set(KvItem item) {
  redis.pipeline(pipe -> {
    pipe.set(keyForItem(item.getKey()), item.getValue().toString());
    pipe.sadd(globalAllKeys, item.getKey());
    pipe.incr(keyForVersion(item.getKey()));
    pipe.incr(globalVersionKey);
  });
}

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

@Override
public Long sAdd(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().sadd(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().sadd(key, values)));
      return null;
    }
    return connection.getJedis().sadd(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

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

@Override
public Long sAdd(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().sadd(key, values)));
      return null;
    }
    if (isQueueing()) {
      transaction(connection.newJedisResult(connection.getRequiredTransaction().sadd(key, values)));
      return null;
    }
    return connection.getJedis().sadd(key, values);
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源：origin: gojektech/feast

private Response<?> writeRecord(RedisMutation mutation) {
 switch (mutation.getMethod()) {
  case APPEND:
   return pipeline.append(mutation.getKey(), mutation.getValue());
  case SET:
   return pipeline.set(mutation.getKey(), mutation.getValue());
  case LPUSH:
   return pipeline.lpush(mutation.getKey(), mutation.getValue());
  case RPUSH:
   return pipeline.rpush(mutation.getKey(), mutation.getValue());
  case SADD:
   return pipeline.sadd(mutation.getKey(), mutation.getValue());
  case ZADD:
   return pipeline.zadd(mutation.getKey(), mutation.getScore(), mutation.getValue());
  default:
   throw new UnsupportedOperationException(
     String.format("Not implemented writing records for %s", mutation.getMethod()));
 }
}