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

x33g5p2x  于2022-01-20 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(295)

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

HashOperations介绍

[英]Redis map specific operations working on a hash.
[中]Redis映射特定于哈希的操作。

代码示例

代码示例来源:origin: yu199195/Raincat

@Override
public Boolean addTxTransaction(final String txGroupId, final TxTransactionItem txTransactionItem) {
  try {
    redisTemplate.opsForHash().put(cacheKey(txGroupId), txTransactionItem.getTaskKey(), txTransactionItem);
  } catch (Exception e) {
    return false;
  }
  return true;
}

代码示例来源:origin: yu199195/Raincat

@Override
public int findTxTransactionGroupStatus(final String txGroupId) {
  try {
    final TxTransactionItem item = (TxTransactionItem)
        redisTemplate.opsForHash().get(cacheKey(txGroupId), txGroupId);
    return item.getStatus();
  } catch (BeansException e) {
    e.printStackTrace();
    return TransactionStatusEnum.ROLLBACK.getCode();
  }
}

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

@Override
public Long delete(Object... keys) {
  return ops.delete(getKey(), keys);
}

代码示例来源:origin: yu199195/Raincat

@Override
public void updateTxTransactionItemStatus(final String key, final String hashKey,
                     final int status, final Object message) {
  try {
    final TxTransactionItem item = (TxTransactionItem)
        redisTemplate.opsForHash().get(cacheKey(key), hashKey);
    item.setStatus(status);
    if (Objects.nonNull(message)) {
      item.setMessage(message);
    }
    //计算耗时
    final String createDate = item.getCreateDate();
    final LocalDateTime now = LocalDateTime.now();
    try {
      final LocalDateTime createDateTime = DateUtils.parseLocalDateTime(createDate);
      final long consumeTime = DateUtils.getSecondsBetween(createDateTime, now);
      item.setConsumeTime(consumeTime);
    } catch (ParseException e) {
      e.printStackTrace();
    }
    redisTemplate.opsForHash().put(cacheKey(key), item.getTaskKey(), item);
  } catch (BeansException e) {
    e.printStackTrace();
  }
}

代码示例来源:origin: yu199195/Raincat

@Override
public List<TxTransactionItem> listByTxGroupId(final String txGroupId) {
  final Map<Object, TxTransactionItem> entries =
      redisTemplate.opsForHash().entries(cacheKey(txGroupId));
  final Collection<TxTransactionItem> values = entries.values();
  return new ArrayList<>(values);
}

代码示例来源:origin: com.alibaba/tac-engine

@Override
public Boolean removeMsInst(Long instId) {
  String key = String.valueOf(instId);
  TacInst tacInst = hashOperations.get(getMainKey(), key);
  if (tacInst != null) {
    hashOperations.delete(getMainKey() + tacInst.getMsCode(), key);
  }
  hashOperations.delete(getMainKey(), key);
  return true;
}

代码示例来源:origin: zhangxd1989/springboot-dubbox

/**
 * 根据key值删除
 *
 * @param key      the key
 * @param hashKeys the hash keys
 */
public void delHashValues(String key, Object... hashKeys) {
  LOGGER.info("[redisTemplate redis]  delHashValues()  key={}", key);
  opsForHash().delete(key, hashKeys);
}

代码示例来源:origin: zhangxd1989/springboot-dubbox

/**
 * 批量添加
 *
 * @param key the key
 * @param map the map
 */
public void putHashValues(String key, Map<String, String> map) {
  opsForHash().putAll(key, map);
}

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

@Override
public void put(HK key, HV value) {
  ops.put(getKey(), key, value);
}

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

@Override
public HV get(Object key) {
  return ops.get(getKey(), key);
}

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

@Override
public Map<HK, HV> entries() {
  return ops.entries(getKey());
}

代码示例来源:origin: mrdear/JavaWEB

/**
  * 查询全部用户
  */
 public List<User> query(){
  HashOperations<String, String, String> opsForHash = stringRedisTemplate.opsForHash();
  List<String> usersJson = opsForHash.values(KEY_PREFIX);
  List<User> users = new ArrayList<>(usersJson.size());
  usersJson.forEach(x -> {
   try {
    users.add(objectMapper.readValue(x,User.class));
   } catch (IOException e) {
    logger.error("read user error id is {}",x);
   }
  });
  return users;
 }
}

代码示例来源:origin: xautlx/s2jh4net

@Override
public Collection getKeys() {
  CAPTCHA_LOG.debug("Get captcha keys.");
  return this.hashOperations.keys(CAPTCHA_SESSION_KEY);
}

代码示例来源:origin: rhettpang/Springboot-Shiro

/**
 * 判断key和field下是否有值
 *
 * @param key 判断的key
 * @param field 判断的field
 */
public Boolean hasKey(String key,String field) {
  return hashOperations.hasKey(key,field);
}

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

@Override
public void putAll(Map<? extends HK, ? extends HV> m) {
  ops.putAll(getKey(), m);
}

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

@Override
public Set<HK> keys() {
  return ops.keys(getKey());
}

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

@Override
public Boolean hasKey(Object key) {
  return ops.hasKey(getKey(), key);
}

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

@Override
public List<HV> values() {
  return ops.values(getKey());
}

代码示例来源:origin: yu199195/Raincat

@Override
public void removeCommitTxGroup() {
  final Set<String> keys = redisTemplate.keys(Constant.REDIS_KEYS);
  keys.parallelStream().forEach(key -> {
    final Map<Object, TxTransactionItem> entries = redisTemplate.opsForHash().entries(key);
    final Collection<TxTransactionItem> values = entries.values();
    final boolean present = values.stream()
        .anyMatch(item -> item.getStatus() != TransactionStatusEnum.COMMIT.getCode());
    if (!present) {
      redisTemplate.delete(key);
    }
  });
}

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

@Override
public Boolean unbindJob(Long jobId) {
  String jobIdStr = jobId.toString();
  String server = String.valueOf(redis.opsForHash().get(RedisKeys.JOB_SERVER_MAPPINGS, jobIdStr));
  // remove the job from the server
  String serverJobsKey = RedisKeys.keyOfServerJobs(server);
  redis.opsForSet().remove(serverJobsKey, jobIdStr);
  // remote the job server mapping
  redis.opsForHash().delete(RedisKeys.JOB_SERVER_MAPPINGS, jobIdStr);
  return Boolean.TRUE;
}

相关文章