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