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

x33g5p2x  于2022-01-21 转载在 其他  
字(5.6k)|赞(0)|评价(0)|浏览(233)

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

Jedis.sadd介绍

[英]Add the specified member to the set value stored at key. If member is already a member of the set no operation is performed. If key does not exist a new set with the specified member as sole member is created. If the key exists but does not hold a set value an error is returned.

Time complexity O(1)
[中]将指定的成员添加到键处存储的集合值。如果成员已经是集合的成员,则不执行任何操作。如果密钥不存在,则将创建一个新的集合,其中指定的成员为唯一成员。如果密钥存在但不包含设置值,则返回错误。
时间复杂度O(1)

代码示例

代码示例来源:origin: sohutv/cachecloud

@Override
 public Long execute(Jedis connection) {
  return connection.sadd(key, member);
 }
}.run(key);

代码示例来源:origin: sohutv/cachecloud

@Override
 public Long execute(Jedis connection) {
  return connection.sadd(key, member);
 }
}.runBinary(key);

代码示例来源:origin: sohutv/cachecloud

public Long execute(Jedis connection) {
    return connection.sadd(keyByte, member);
  }
}.runBinary(keyByte);

代码示例来源:origin: caoxinyu/RedisClient

protected void addSet() {
  for(String value: values){
    jedis.sadd(key, value);
    size++;
  }
}

代码示例来源:origin: caoxinyu/RedisClient

protected void addSet() {
  size = jedis.sadd(key, values);
}

代码示例来源:origin: sohutv/cachecloud

@Override
public Long sadd(String key, String... members) {
 Jedis j = getShard(key);
 return j.sadd(key, members);
}

代码示例来源:origin: sohutv/cachecloud

@Override
public Long sadd(byte[] key, byte[]... members) {
 Jedis j = getShard(key);
 return j.sadd(key, members);
}

代码示例来源:origin: code4craft/webmagic

@Override
public boolean isDuplicate(Request request, Task task) {
  Jedis jedis = pool.getResource();
  try {
    return jedis.sadd(getSetKey(task), request.getUrl()) == 0;
  } finally {
    pool.returnResource(jedis);
  }
}

代码示例来源:origin: shuzheng/zheng

/**
 * sadd
 * @param key
 * @param value
 * @param seconds
 */
public synchronized static void sadd(String key, String value, int seconds) {
  try {
    Jedis jedis = RedisUtil.getJedis();
    jedis.sadd(key, value);
    jedis.expire(key, seconds);
    jedis.close();
  } catch (Exception e) {
    LOGGER.error("sadd error : " + e);
  }
}

代码示例来源:origin: Netflix/conductor

@Override
public Long sadd(String key, String... member) {
 Jedis jedis = null;
  try {
   jedis = jedisPool.getResource();
   return jedis.sadd(key, member);
  } finally {
   if (jedis != null)
    jedis.close();
  }
}

代码示例来源:origin: jfinal/jfinal

/**
 * 将一个或多个 member 元素加入到集合 key 当中,已经存在于集合的 member 元素将被忽略。
 * 假如 key 不存在,则创建一个只包含 member 元素作成员的集合。
 * 当 key 不是集合类型时,返回一个错误。
 */
public Long sadd(Object key, Object... members) {
  Jedis jedis = getJedis();
  try {
    return jedis.sadd(keyToBytes(key), valuesToBytesArray(members));
  }
  finally {close(jedis);}
}

代码示例来源: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: GoogleCloudPlatform/java-docs-samples

/**
  * Adds a {@code word} to the index.
  */
 public void add(Word word) {
  try (Jedis jedis = pool.getResource()) {
   jedis.select(TOKEN_DB);
   jedis.sadd(word.word().toLowerCase(), word.path().toString());
  }
 }
}

代码示例来源:origin: jwpttcg66/NettyGameServer

public void saddStrings(String key,String... values){
  Jedis jedis = null;
  boolean sucess = true;
  try {
    jedis = jedisPool.getResource();
    jedis.sadd(key, values);
  } catch (Exception e) {
    sucess = false;
    returnBrokenResource(jedis, "saddStrings"+key, e);
  } finally {
    if (sucess && jedis != null) {
      returnResource(jedis);
    }
  }
}

代码示例来源:origin: jwpttcg66/NettyGameServer

public long saddString(String key,String value){
  Jedis jedis = null;
  boolean sucess = true;
  try {
    jedis = jedisPool.getResource();
    Long ret = jedis.sadd(key,value);
    return ret;
  } catch (Exception e) {
    sucess = false;
    returnBrokenResource(jedis, "saddString"+key, e);
  } finally {
    if (sucess && jedis != null) {
      returnResource(jedis);
    }
  }
  return 0;
}

代码示例来源:origin: foxinmy/weixin4j

@Override
public void caching(String key, T cache) {
  Jedis jedis = null;
  try {
    jedis = jedisPool.getResource();
    byte[] cacheKey = key.getBytes(Consts.UTF_8);
    byte[] value = SerializationUtils.serialize(cache);
    if (cache.getExpires() > 0) {
      jedis.setex(cacheKey, (int) (cache.getExpires() - CUTMS) / 1000, value);
    } else {
      jedis.set(cacheKey, value);
    }
    jedis.sadd(ALLKEY, key);
  } finally {
    if (jedis != null) {
      jedis.close();
    }
  }
}

代码示例来源:origin: wso2/msf4j

@POST
@Consumes("application/json")
@Timed
public Response addCategory(Category category) {
  String name = category.getName();
  log.info("Using Redis master:" + REDIS_MASTER_HOST + ":" + REDIS_MASTER_PORT);
  try (Jedis jedis = pool.getResource()) {
    jedis.sadd(org.wso2.msf4j.examples.petstore.pet.PetConstants.CATEGORIES_KEY, name);
    log.info("Added category");
  }
  return Response.status(Response.Status.OK).entity("Category with name " + name + " successfully added").build();
}

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

/**
   * {@inheritDoc}
   */
  @Override
  public Void doWork(final Jedis jedis) throws IOException {
    jedis.sadd(key(WORKERS), name);
    jedis.set(key(WORKER, name, STARTED), new SimpleDateFormat(DATE_FORMAT).format(new Date()));
    listenerDelegate.fireEvent(WORKER_START, WorkerPoolImpl.this, null, null, null, null, null);
    loadRedisScripts(jedis);
    return null;
  }
});

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

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

代码示例来源:origin: wso2/msf4j

public static void srem(String key, String value) {
  fetchMaster();
  try {
    master.srem(key, value);
  } catch (JedisConnectionException e) {
    master = getJedis();
    master.sadd(key, value);
  }
}

相关文章

微信公众号

最新文章

更多

Jedis类方法