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

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

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

BoundHashOperations.get介绍

[英]Get value for given key from the hash at the bound key.
[中]从绑定键处的哈希中获取给定键的值。

代码示例

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

@Override
@Nullable
public V get(Object key) {
  return hashOps.get(key);
}

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

@Override
@Nullable
public V get(Object key) {
  return hashOps.get(key);
}

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

@Override
@Nullable
public V get(Object key) {
  return hashOps.get(key);
}

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

@Test
@RedisAvailable
public void testPersistKeyValue() {
  RedisConnectionFactory jcf = this.getConnectionFactoryForTest();
  RedisMetadataStore metadataStore = new RedisMetadataStore(jcf, "testMetadata");
  metadataStore.put("RedisMetadataStoreTests-Spring", "Integration");
  StringRedisTemplate redisTemplate = new StringRedisTemplate(jcf);
  BoundHashOperations<String, Object, Object> ops = redisTemplate.boundHashOps("testMetadata");
  assertEquals("Integration", ops.get("RedisMetadataStoreTests-Spring"));
}

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

@Override
public StreamDefinition findOne(String s) {
  String dsl = hashOperations.get(s);
  return dsl != null ? new StreamDefinition(s, dsl) : null;
}

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

public Object hget(String key, String field) {
  return redisTemplate.boundHashOps(key).get(field);
}

代码示例来源:origin: spring-projects/spring-xd-samples

public int getProductCategoryCount(String category, String product) {
  int count = 0;
  String sCount = (String) redisTemplate.boundHashOps(buildRedisKey(product)).get(category);
  if (!(sCount == null || "nil".equals(sCount))) {
    count = Integer.valueOf(sCount);
  }
  return count;
}

代码示例来源:origin: zuihou/zuihou-admin-cloud

/**
 * 获取
 *
 * @return
 */
@Override
public Optional<V> getCache() {
  V value = this.getBoundHashOperations().get(this.field());
  if (value != null) {
    return Optional.of(value);
  }
  return Optional.empty();
}

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

@Override
public URI find(String key) {
  String uri = hashOps().get(key);
  Assert.notNull(uri, String.format("No URI registered for %s", key));
  return toUri(uri);
}

代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot

@Override
public Object hget(String key, Serializable field) {
  return getRedisTemplate().boundHashOps(key).get(field);
}

代码示例来源:origin: yzgod/tw-sso

/** 记录用户登录后对应userId和SessionId的Map关系 */
private static void addToMap(User user) {
  String uId = user.getId().toString();
  String sId = getRequest().getSession().getId();
  Boolean hasKey = ou.hasKey(uId);
  if (hasKey) {
    String sids = ou.get(uId);
    ou.put(uId, sids + sId);
  } else {
    ou.put(uId, sId);
  }
}

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

public Object getValueByKeyANdField(String key, String field) {
  BoundHashOperations hashOps = redisTemplate.boundHashOps(key);
  redisTemplate.setHashValueSerializer(new GenericToStringSerializer(Long.class));
  return hashOps.get(field);
}

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

@Override
public Object getJobSummaryByJobId( JobType jobType, String jobId )
{
  String existingSummaryTypeStr = redisTemplate.boundValueOps( generateSummaryTypeKey( jobType ) ).get();
  if ( existingSummaryTypeStr == null )
  {
    return null;
  }
  try
  {
    Class<?> existingSummaryType = Class.forName( existingSummaryTypeStr );
    Object serializedSummary = redisTemplate.boundHashOps( generateSummaryKey( jobType ) ).get( jobId );
    return serializedSummary != null ? objectMapper.readValue( (String) serializedSummary, existingSummaryType ) : null;
  }
  catch ( IOException | ClassNotFoundException ex )
  {
    log.warn( String.format( NOTIFIER_ERROR, ex.getMessage() ) );
  }
  return null;
}

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

@Override
public Object getJobSummary( JobType jobType )
{
  String existingSummaryTypeStr = redisTemplate.boundValueOps( generateSummaryTypeKey( jobType ) ).get();
  if ( existingSummaryTypeStr == null )
  {
    return null;
  }
  
  try
  {
    Class<?> existingSummaryType = Class.forName( existingSummaryTypeStr );
    Set<String> lastJobUidSet = redisTemplate.boundZSetOps( generateSummaryOrderKey( jobType ) ).range( -1,
      -1 );
    if ( !lastJobUidSet.iterator().hasNext() )
    {
      return null;
    }
    String lastJobUid = (String) lastJobUidSet.iterator().next();
    Object serializedSummary = redisTemplate.boundHashOps( generateSummaryKey( jobType ) ).get( lastJobUid );
    return serializedSummary != null ? objectMapper.readValue( (String) serializedSummary, existingSummaryType ) : null;
  }
  catch ( IOException | ClassNotFoundException ex )
  {
    log.warn( String.format( NOTIFIER_ERROR, ex.getMessage() ) );
  }
  return null;
}

代码示例来源:origin: TyCoding/springboot-seckill

@Override
public Exposer exportSeckillUrl(long seckillId) {
  Seckill seckill = (Seckill) redisTemplate.boundHashOps(key).get(seckillId);
  if (seckill == null) {
    //说明redis缓存中没有此key对应的value
    //查询数据库,并将数据放入缓存中
    seckill = seckillMapper.findById(seckillId);
    if (seckill == null) {
      //说明没有查询到
      return new Exposer(false, seckillId);
    } else {
      //查询到了,存入redis缓存中。 key:秒杀表的ID值; value:秒杀表数据
      redisTemplate.boundHashOps(key).put(seckill.getSeckillId(), seckill);
      logger.info("RedisTemplate -> 从数据库中读取并放入缓存中");
    }
  } else {
    logger.info("RedisTemplate -> 从缓存中读取");
  }
  Date startTime = seckill.getStartTime();
  Date endTime = seckill.getEndTime();
  //获取系统时间
  Date nowTime = new Date();
  if (nowTime.getTime() < startTime.getTime() || nowTime.getTime() > endTime.getTime()) {
    return new Exposer(false, seckillId, nowTime.getTime(), startTime.getTime(), endTime.getTime());
  }
  //转换特定字符串的过程,不可逆的算法
  String md5 = getMD5(seckillId);
  return new Exposer(true, md5, seckillId);
}

代码示例来源:origin: TyCoding/springboot-seckill

Seckill seckill = (Seckill) redisTemplate.boundHashOps(key).get(seckillId);
seckill.setStockCount(seckill.getSeckillId() - 1);
redisTemplate.boundHashOps(key).put(seckillId, seckill);

相关文章