本文整理了Java中org.springframework.data.redis.core.SetOperations
类的一些代码示例,展示了SetOperations
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SetOperations
类的具体详情如下:
包路径:org.springframework.data.redis.core.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();
}
}
内容来源于网络,如有侵权,请联系作者删除!