org.springframework.data.redis.core.BoundHashOperations.entries()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(11.8k)|赞(0)|评价(0)|浏览(124)

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

BoundHashOperations.entries介绍

[英]Get entire hash at the bound key.
[中]在绑定键处获取整个哈希。

代码示例

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

@Override
public Set<java.util.Map.Entry<K, V>> entrySet() {
  Map<K, V> entries = hashOps.entries();
  checkResult(entries);
  return entries.entrySet();
}

代码示例来源：origin: spring-projects/spring-session

/**
 * Gets the session.
 * @param id the session id
 * @param allowExpired if true, will also include expired sessions that have not been
 * deleted. If false, will ensure expired sessions are not returned.
 * @return the Redis session
 */
private RedisSession getSession(String id, boolean allowExpired) {
  Map<Object, Object> entries = getSessionBoundHashOperations(id).entries();
  if (entries.isEmpty()) {
    return null;
  }
  MapSession loaded = loadSession(id, entries);
  if (!allowExpired && loaded.isExpired()) {
    return null;
  }
  RedisSession result = new RedisSession(loaded);
  result.originalLastAccessTime = loaded.getLastAccessedTime();
  return result;
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void onMessageDeletedSessionFound() {
  String deletedId = "deleted-id";
  given(this.redisOperations.boundHashOps(getKey(deletedId)))
      .willReturn(this.boundHashOperations);
  Map map = map(RedisOperationsSessionRepository.MAX_INACTIVE_ATTR, 0,
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
      System.currentTimeMillis() - TimeUnit.MINUTES.toMillis(5));
  given(this.boundHashOperations.entries()).willReturn(map);
  String channel = "__keyevent@0__:del";
  String body = "spring:session:sessions:expires:" + deletedId;
  DefaultMessage message = new DefaultMessage(
      channel.getBytes(StandardCharsets.UTF_8),
      body.getBytes(StandardCharsets.UTF_8));
  this.redisRepository.setApplicationEventPublisher(this.publisher);
  this.redisRepository.onMessage(message, "".getBytes(StandardCharsets.UTF_8));
  verify(this.redisOperations).boundHashOps(eq(getKey(deletedId)));
  verify(this.boundHashOperations).entries();
  verify(this.publisher).publishEvent(this.event.capture());
  assertThat(this.event.getValue().getSessionId()).isEqualTo(deletedId);
  verifyZeroInteractions(this.defaultSerializer);
  verifyZeroInteractions(this.publisher);
  verifyZeroInteractions(this.redisOperations);
  verifyZeroInteractions(this.boundHashOperations);
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void onMessageExpiredSessionFound() {
  String expiredId = "expired-id";
  given(this.redisOperations.boundHashOps(getKey(expiredId)))
      .willReturn(this.boundHashOperations);
  Map map = map(RedisOperationsSessionRepository.MAX_INACTIVE_ATTR, 1,
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
      System.currentTimeMillis() - TimeUnit.MINUTES.toMillis(5));
  given(this.boundHashOperations.entries()).willReturn(map);
  String channel = "__keyevent@0__:expired";
  String body = "spring:session:sessions:expires:" + expiredId;
  DefaultMessage message = new DefaultMessage(
      channel.getBytes(StandardCharsets.UTF_8),
      body.getBytes(StandardCharsets.UTF_8));
  this.redisRepository.setApplicationEventPublisher(this.publisher);
  this.redisRepository.onMessage(message, "".getBytes(StandardCharsets.UTF_8));
  verify(this.redisOperations).boundHashOps(eq(getKey(expiredId)));
  verify(this.boundHashOperations).entries();
  verify(this.publisher).publishEvent(this.event.capture());
  assertThat(this.event.getValue().getSessionId()).isEqualTo(expiredId);
  verifyZeroInteractions(this.defaultSerializer);
  verifyZeroInteractions(this.publisher);
  verifyZeroInteractions(this.redisOperations);
  verifyZeroInteractions(this.boundHashOperations);
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void onMessageDeletedSessionNotFound() {
  String deletedId = "deleted-id";
  given(this.redisOperations.boundHashOps(getKey(deletedId)))
      .willReturn(this.boundHashOperations);
  given(this.boundHashOperations.entries()).willReturn(map());
  String channel = "__keyevent@0__:del";
  String body = "spring:session:sessions:expires:" + deletedId;
  DefaultMessage message = new DefaultMessage(
      channel.getBytes(StandardCharsets.UTF_8),
      body.getBytes(StandardCharsets.UTF_8));
  this.redisRepository.setApplicationEventPublisher(this.publisher);
  this.redisRepository.onMessage(message, "".getBytes(StandardCharsets.UTF_8));
  verify(this.redisOperations).boundHashOps(eq(getKey(deletedId)));
  verify(this.boundHashOperations).entries();
  verifyZeroInteractions(this.defaultSerializer);
  verifyZeroInteractions(this.publisher);
  verifyZeroInteractions(this.redisOperations);
  verifyZeroInteractions(this.boundHashOperations);
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void onMessageExpiredSessionNotFound() {
  String expiredId = "expired-id";
  given(this.redisOperations.boundHashOps(getKey(expiredId)))
      .willReturn(this.boundHashOperations);
  given(this.boundHashOperations.entries()).willReturn(map());
  String channel = "__keyevent@0__:expired";
  String body = "spring:session:sessions:expires:" + expiredId;
  DefaultMessage message = new DefaultMessage(
      channel.getBytes(StandardCharsets.UTF_8),
      body.getBytes(StandardCharsets.UTF_8));
  this.redisRepository.setApplicationEventPublisher(this.publisher);
  this.redisRepository.onMessage(message, "".getBytes(StandardCharsets.UTF_8));
  verify(this.redisOperations).boundHashOps(eq(getKey(expiredId)));
  verify(this.boundHashOperations).entries();
  verifyZeroInteractions(this.defaultSerializer);
  verifyZeroInteractions(this.publisher);
  verifyZeroInteractions(this.redisOperations);
  verifyZeroInteractions(this.boundHashOperations);
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void getSessionExpired() {
  String expiredId = "expired-id";
  given(this.redisOperations.boundHashOps(getKey(expiredId)))
      .willReturn(this.boundHashOperations);
  Map map = map(RedisOperationsSessionRepository.MAX_INACTIVE_ATTR, 1,
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
      Instant.now().minus(5, ChronoUnit.MINUTES).toEpochMilli());
  given(this.boundHashOperations.entries()).willReturn(map);
  assertThat(this.redisRepository.findById(expiredId)).isNull();
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void findByPrincipalNameExpired() {
  String expiredId = "expired-id";
  given(this.redisOperations.boundSetOps(anyString()))
      .willReturn(this.boundSetOperations);
  given(this.boundSetOperations.members())
      .willReturn(Collections.singleton(expiredId));
  given(this.redisOperations.boundHashOps(getKey(expiredId)))
      .willReturn(this.boundHashOperations);
  Map map = map(RedisOperationsSessionRepository.MAX_INACTIVE_ATTR, 1,
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
      Instant.now().minus(5, ChronoUnit.MINUTES).toEpochMilli());
  given(this.boundHashOperations.entries()).willReturn(map);
  assertThat(this.redisRepository.findByIndexNameAndIndexValue(
      FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME, "principal"))
          .isEmpty();
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void findByPrincipalName() {
  Instant lastAccessed = Instant.now().minusMillis(10);
  Instant createdTime = lastAccessed.minusMillis(10);
  Duration maxInactive = Duration.ofHours(1);
  String sessionId = "some-id";
  given(this.redisOperations.boundSetOps(anyString()))
      .willReturn(this.boundSetOperations);
  given(this.boundSetOperations.members())
      .willReturn(Collections.singleton(sessionId));
  given(this.redisOperations.boundHashOps(getKey(sessionId)))
      .willReturn(this.boundHashOperations);
  Map map = map(RedisOperationsSessionRepository.CREATION_TIME_ATTR, createdTime.toEpochMilli(),
      RedisOperationsSessionRepository.MAX_INACTIVE_ATTR, (int) maxInactive.getSeconds(),
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR, lastAccessed.toEpochMilli());
  given(this.boundHashOperations.entries()).willReturn(map);
  Map<String, RedisSession> sessionIdToSessions = this.redisRepository
      .findByIndexNameAndIndexValue(
          FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME,
          "principal");
  assertThat(sessionIdToSessions).hasSize(1);
  RedisSession session = sessionIdToSessions.get(sessionId);
  assertThat(session).isNotNull();
  assertThat(session.getId()).isEqualTo(sessionId);
  assertThat(session.getLastAccessedTime().truncatedTo(ChronoUnit.MILLIS))
      .isEqualTo(lastAccessed.truncatedTo(ChronoUnit.MILLIS));
  assertThat(session.getMaxInactiveInterval()).isEqualTo(maxInactive);
  assertThat(session.getCreationTime().truncatedTo(ChronoUnit.MILLIS))
      .isEqualTo(createdTime.truncatedTo(ChronoUnit.MILLIS));
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void getSessionNotFound() {
  String id = "abc";
  given(this.redisOperations.boundHashOps(getKey(id)))
      .willReturn(this.boundHashOperations);
  given(this.boundHashOperations.entries()).willReturn(map());
  assertThat(this.redisRepository.findById(id)).isNull();
}

代码示例来源：origin: spring-projects/spring-session

@Test
public void delete() {
  String attrName = "attrName";
  MapSession expected = new MapSession();
  expected.setLastAccessedTime(Instant.now().minusSeconds(60));
  expected.setAttribute(attrName, "attrValue");
  given(this.redisOperations.boundHashOps(anyString()))
      .willReturn(this.boundHashOperations);
  given(this.redisOperations.boundSetOps(anyString()))
      .willReturn(this.boundSetOperations);
  Map map = map(RedisOperationsSessionRepository.getSessionAttrNameKey(attrName),
      expected.getAttribute(attrName),
      RedisOperationsSessionRepository.CREATION_TIME_ATTR,
      expected.getCreationTime().toEpochMilli(),
      RedisOperationsSessionRepository.MAX_INACTIVE_ATTR,
      (int) expected.getMaxInactiveInterval().getSeconds(),
      RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
      expected.getLastAccessedTime().toEpochMilli());
  given(this.boundHashOperations.entries()).willReturn(map);
  given(this.redisOperations.boundSetOps(anyString()))
      .willReturn(this.boundSetOperations);
  String id = expected.getId();
  this.redisRepository.deleteById(id);
  assertThat(getDelta().get(RedisOperationsSessionRepository.MAX_INACTIVE_ATTR))
      .isEqualTo(0);
  verify(this.redisOperations, atLeastOnce()).delete(getKey("expires:" + id));
  verify(this.redisOperations, never()).boundValueOps(getKey("expires:" + id));
}

代码示例来源：origin: spring-projects/spring-session

RedisOperationsSessionRepository.LAST_ACCESSED_ATTR,
    expected.getLastAccessedTime().toEpochMilli());
given(this.boundHashOperations.entries()).willReturn(map);

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

@Override
public Set<java.util.Map.Entry<K, V>> entrySet() {
  Map<K, V> entries = hashOps.entries();
  checkResult(entries);
  return entries.entrySet();
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public Set<java.util.Map.Entry<K, V>> entrySet() {
  Map<K, V> entries = hashOps.entries();
  checkResult(entries);
  return entries.entrySet();
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-dataflow-registry

@Override
public Map<String, URI> findAll() {
  Map<String, URI> map = new HashMap<>();
  for (Map.Entry<String, String> entry : hashOps().entries().entrySet()) {
    map.put(entry.getKey(), toUri(entry.getValue()));
  }
  return map;
}

代码示例来源：origin: davidmarquis/redisq

public <T> Message<T> loadMessageById(String queueName, String id, Class<T> payloadType) {
  String messageKey = keyForMessage(queueName, id);
  BoundHashOperations<String, String, String> ops = redisTemplate.boundHashOps(messageKey);
  Map<String, String> messageData = ops.entries();
  return messageConverter.toMessage(messageData, payloadType, payloadSerializer);
}

代码示例来源：origin: dhis2/dhis2-core

.entries();

代码示例来源：origin: chengzhx76/weixin-shop-spring-cloud

public Map<Serializable, Object> getEntries(String key) {
  BoundHashOperations hashOps = redisTemplate.boundHashOps(key);
  //redisTemplate.setHashKeySerializer(new GenericToStringSerializer(String.class));
  redisTemplate.setHashValueSerializer(new GenericToStringSerializer(Long.class));
  return hashOps.entries();
}

内容来源于网络，如有侵权，请联系作者删除！

BoundHashOperations

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com