org.springframework.data.redis.core.SetOperations类的使用及代码示例

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

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

SetOperations介绍

[英]Redis set specific operations.
[中]Redis设置特定的操作。

代码示例

代码示例来源:origin: crossoverJie/cim

@Override
public boolean saveAndCheckUserLoginStatus(Long userId) throws Exception {
  Long add = redisTemplate.opsForSet().add(LOGIN_STATUS_PREFIX, userId.toString());
  if (add == 0){
    return false ;
  }else {
    return true ;
  }
}

代码示例来源:origin: crossoverJie/cim

@Override
public Set<CIMUserInfo> onlineUser() {
  Set<CIMUserInfo> set = null ;
  Set<String> members = redisTemplate.opsForSet().members(LOGIN_STATUS_PREFIX);
  for (String member : members) {
    if (set == null){
      set = new HashSet<>(64) ;
    }
    CIMUserInfo cimUserInfo = loadUserInfoByUserId(Long.valueOf(member)) ;
    set.add(cimUserInfo) ;
  }
  return set;
}

代码示例来源:origin: crossoverJie/cim

@Override
public void removeLoginStatus(Long userId) throws Exception {
  redisTemplate.opsForSet().remove(LOGIN_STATUS_PREFIX,userId.toString()) ;
}

代码示例来源:origin: ihaolin/diablo

@Override
public boolean serverOffline(String server) {
  SetOperations<String, String> ops = redis.opsForSet();
  ops.remove(RedisKeys.CLUSTER_SERVERS_ONLINE, server);
  ops.add(RedisKeys.CLUSTER_SERVERS_OFFLINE, server);
  return Boolean.TRUE;
}

代码示例来源:origin: vvsuperman/coolmq

@Override
public List getMsgPrepare() throws Exception  {
  SetOperations setOperations = redisTemplate.opsForSet();
  Set<String> messageIds = setOperations.members(MQConstants.MQ_MSG_PREPARE);
  List<String> messageAlert = new ArrayList();
  for(String messageId: messageIds){
    /**如果消息超时,加入超时队列*/
    if(messageTimeOut(messageId)){
      messageAlert.add(messageId);
    }
  }
  /**在redis中删除已超时的消息*/
  setOperations.remove(MQConstants.MQ_MSG_READY,messageAlert);
  return messageAlert;
}

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

@Override
public Long add(V... values) {
  return ops.add(getKey(), values);
}

代码示例来源:origin: org.springframework.analytics/spring-analytics

@Override
public long increment(String name, long amount, DateTime dateTime) {
  final AggregateKeyGenerator akg = new AggregateKeyGenerator(
      AGGREGATE_COUNTER_KEY_PREFIX, name, dateTime);
  String bookkeepingKey = bookkeepingKeyFor(name);
  if (!this.setOperations.isMember(AGGREGATE_COUNTER_KEY_PREFIX, name)) {
    this.setOperations.add(AGGREGATE_COUNTER_KEY_PREFIX, name);
  }
  doIncrementHash(akg.getYearsKey(), akg.getYear(), amount, bookkeepingKey);
  doIncrementHash(akg.getYearKey(), akg.getMonth(), amount, bookkeepingKey);
  doIncrementHash(akg.getMonthKey(), akg.getDay(), amount, bookkeepingKey);
  doIncrementHash(akg.getDayKey(), akg.getHour(), amount, bookkeepingKey);
  doIncrementHash(akg.getHourKey(), akg.getMinute(), amount, bookkeepingKey);
  return redisTemplate.boundValueOps(getMetricKey(name)).increment(amount);
}

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

@Override
public Set<V> members() {
  return ops.members(getKey());
}

代码示例来源:origin: whvcse/EasyWeb

/**
 * 获取集合的大小
 *
 * @param key
 * @return
 */
public Long sSize(String key) {
  return redisTemplate.opsForSet().size(key);
}

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

@Override
public Long remove(Object... values) {
  return ops.remove(getKey(), values);
}

代码示例来源:origin: souyunku/SpringBootExamples

/**
 * key 缓存Key
 * @param key
 * @return
 */
public static String getFromSet(String key) {
  return cacheUtils.redisTemplate.opsForSet().pop(key);
}

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

@Override
public Long size() {
  return ops.size(getKey());
}

代码示例来源:origin: Ouyangan/hunt-admin

@Override
public boolean isForbiddenIp(String remoteAddr) {
  Boolean result = redisTemplate.opsForSet().isMember("ip_intercepter", remoteAddr);
  log.debug("isForbiddenIp result : {}", result);
  return result;
}

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

@Override
public V pop() {
  return ops.pop(getKey());
}

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

@Override
public Boolean isMember(Object o) {
  return ops.isMember(getKey(), o);
}

代码示例来源:origin: ihaolin/diablo

@Override
public boolean serverOnline(String server) {
  SetOperations<String, String> ops = redis.opsForSet();
  ops.add(RedisKeys.CLUSTER_SERVERS_ONLINE, server);
  ops.remove(RedisKeys.CLUSTER_SERVERS_OFFLINE, server);
  return Boolean.TRUE;
}

代码示例来源:origin: org.springframework.analytics/spring-analytics

@Override
  public void reset(String id) {
    redisTemplate.delete(getMetricKey(id));
    String metricMetaKey = bookkeepingKeyFor(id);
    Set<String> otherKeys = setOperations.members(metricMetaKey);
    otherKeys.add(metricMetaKey);
    redisTemplate.delete(otherKeys);
    Set<String> members = this.setOperations.members(AGGREGATE_COUNTER_KEY_PREFIX);
    if (members.contains(id)) {
      this.setOperations.remove(AGGREGATE_COUNTER_KEY_PREFIX, id);
    }
  }
}

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

@Override
public Long add(V... values) {
  return ops.add(getKey(), values);
}

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

@Override
public Set<V> members() {
  return ops.members(getKey());
}

代码示例来源:origin: youngMen1/JAVA-

/** 获取在线用户数量 */
  public Integer getAllUserNumber() {
    return redisTemplate.opsForSet().size(Constants.ALLUSER_NUMBER).intValue();
  }
}

相关文章