本文整理了Java中org.springframework.data.redis.core.RedisTemplate.opsForZSet
方法的一些代码示例,展示了RedisTemplate.opsForZSet
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisTemplate.opsForZSet
方法的具体详情如下:
包路径:org.springframework.data.redis.core.RedisTemplate
类名称:RedisTemplate
方法名:opsForZSet
暂无
代码示例来源:origin: yu199195/Raincat
@Override
public Boolean batchRemove(final List<String> txGroupIdList) {
if (CollectionUtils.isEmpty(txGroupIdList)) {
return false;
}
try {
for (String key : txGroupIdList) {
redisTemplate.opsForZSet().remove(CommonConstant.REDIS_KEY_SET, key);
}
final List<String> keys = txGroupIdList.stream().map(txGroupId ->
String.format(CommonConstant.REDIS_PRE_FIX, txGroupId)).collect(Collectors.toList());
redisTemplate.delete(keys);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
代码示例来源:origin: yu199195/Raincat
@Override
public Boolean saveTxTransactionGroup(final TxTransactionGroup txTransactionGroup) {
try {
final String groupId = txTransactionGroup.getId();
//保存数据 到sortSet
redisTemplate.opsForZSet().add(CommonConstant.REDIS_KEY_SET, groupId, CommonConstant.REDIS_SCOPE);
final List<TxTransactionItem> itemList = txTransactionGroup.getItemList();
if (CollectionUtils.isNotEmpty(itemList)) {
for (TxTransactionItem item : itemList) {
redisTemplate.opsForHash().put(cacheKey(groupId), item.getTaskKey(), item);
}
}
} catch (Exception e) {
return false;
}
return true;
}
代码示例来源:origin: yu199195/Raincat
} else {
keys = redisTemplate.keys(CommonConstant.REDIS_KEYS);
rangeKeys = redisTemplate.opsForZSet()
.range(CommonConstant.REDIS_KEY_SET, start, end - 1);
代码示例来源:origin: yjjdick/sdb-mall
@Bean
public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
return redisTemplate.opsForZSet();
}
}
代码示例来源:origin: JayTange/Jantent
/**
* 对有序集合类型的数据操作
*
* @param redisTemplate
* @return
*/
@Bean
public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
return redisTemplate.opsForZSet();
}
}
代码示例来源:origin: yzcheng90/X-SpringBoot
@Bean
public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
return redisTemplate.opsForZSet();
}
}
代码示例来源:origin: JayTange/springbootRedis
/**
* 对有序集合类型的数据操作
*
* @param redisTemplate
* @return
*/
@Bean
public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
return redisTemplate.opsForZSet();
}
}
代码示例来源:origin: 5-Ason/ason-spring-cloud
/**
* 有序集合添加
* @param key
* @param value
* @param scoure
*/
public void zAdd(String key,Object value,double scoure){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
zset.add(key,value,scoure);
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public long totalCountRt() {
return redisCacheTemplate.opsForZSet().size(RedisKey.PROXY_IP_RT_KEY);
}
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public List<Serializable> findAllByPage(int pageNumber, int pageSize) {
Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_KEY, pageNumber*pageSize, (pageNumber+1)*pageSize);
return new ArrayList<Serializable>(set);
}
代码示例来源:origin: xuyaohui/cloud-ida-cli
/**
* 有序集合添加
* @param key
* @param value
* @param scoure
*/
public void zAdd(String key,Object value,double scoure){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
zset.add(key,value,scoure);
}
代码示例来源:origin: 5-Ason/ason-spring-cloud
/**
* 有序集合获取
* @param key
* @param scoure
* @param scoure1
* @return
*/
public Set<Object> rangeByScore(String key,double scoure,double scoure1){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
return zset.rangeByScore(key, scoure, scoure1);
}
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public List<Serializable> findAllByPageRt(int pageNumber, int pageSize) {
Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_RT_KEY, pageNumber*pageSize, (pageNumber+1)*pageSize);
return new ArrayList<Serializable>(set);
}
代码示例来源:origin: xuyaohui/cloud-ida-cli
/**
* 有序集合获取
* @param key
* @param scoure
* @param scoure1
* @return
*/
public Set<Object> rangeByScore(String key,double scoure,double scoure1){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
return zset.rangeByScore(key, scoure, scoure1);
}
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public ProxyIp getOneRt() {
int totalCount = (int) totalCountRt();
int range=new Random().nextInt(totalCount);
Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_RT_KEY, range, range);
return (ProxyIp) new ArrayList<Serializable>(set).get(0);
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public ProxyIp getOne() {
int totalCount = (int) totalCountRt();
int range=new Random().nextInt(totalCount);
Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_KEY, range, range);
return (ProxyIp) new ArrayList<Serializable>(set).get(0);
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public boolean add(ProxyIp proxyIp) {
return redisCacheTemplate.opsForZSet().add(RedisKey.PROXY_IP_KEY, proxyIp, proxyIp.getId());
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public boolean isExist(ProxyIp proxyIp) {
Set<Serializable> set = redisCacheTemplate.opsForZSet().rangeByScore(RedisKey.PROXY_IP_KEY, proxyIp.getId(), proxyIp.getId());
if (set.isEmpty()) {
return false;
} else {
return true;
}
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public boolean isExistRt(ProxyIp proxyIp) {
Set<Serializable> set = redisCacheTemplate.opsForZSet().rangeByScore(RedisKey.PROXY_IP_RT_KEY, proxyIp.getId(), proxyIp.getId());
if (set.isEmpty()) {
return false;
} else {
return true;
}
}
代码示例来源:origin: Alex-Jerry/Java-Poetry
@Autowired
public RedisDBHelperImpl(RedisTemplate<String, T> redisTemplate) {
this.redisTemplate = redisTemplate;
this.hashOperations = redisTemplate.opsForHash();
this.listOperations = redisTemplate.opsForList();
this.zSetOperations = redisTemplate.opsForZSet();
this.setOperations = redisTemplate.opsForSet();
this.valueOperations = redisTemplate.opsForValue();
}
内容来源于网络,如有侵权,请联系作者删除!