org.redisson.api.RedissonClient.getMapCache()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(816)

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

RedissonClient.getMapCache介绍

[英]Returns map-based cache instance by name. Supports entry eviction with a given MaxIdleTime and TTL settings.

If eviction is not required then it's better to use regular map #getMap(String).
[中]按名称返回基于映射的缓存实例。支持使用给定的MaxIdleTime和TTL设置逐出条目。
如果不需要逐出，那么最好使用常规映射#getMap（String）。

代码示例

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getMapCache(String name, CacheConfig config) {
  if (codec != null) {
    return redisson.getMapCache(name, codec);
  }
  return redisson.getMapCache(name);
}

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getMapCache(String name, CacheConfig config) {
  if (codec != null) {
    return redisson.getMapCache(name, codec);
  }
  return redisson.getMapCache(name);
}

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getCache(String regionName, Map properties, String defaultKey) {
  return redisson.getMapCache(regionName);
}

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
  return redisson.getMapCache(regionName);
}

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
  return redisson.getMapCache(regionName);
}

代码示例来源：origin: redisson/redisson

protected RMapCache<Object, Object> getCache(String regionName, Properties properties, String defaultKey) {
  return redisson.getMapCache(regionName);
}

代码示例来源：origin: redisson/redisson

@Override
public void run() {
  Codec codec;
  try {
    codec = (Codec) objectCodecClass.getConstructor().newInstance();
  } catch (Exception e) {
    throw new IllegalStateException(e);
  }
  
  Injector.inject(mapper, redisson);
  RCollector<KOut, VOut> collector = new Collector<KOut, VOut>(codec, redisson, collectorMapName, workersAmount, timeout);
  for (String objectName : objectNames) {
    RMap<KIn, VIn> map = null;
    if (RMapCache.class.isAssignableFrom(objectClass)) {
      map = redisson.getMapCache(objectName, codec);
    } else {
      map = redisson.getMap(objectName, codec);
    }
    
    for (Entry<KIn, VIn> entry : map.entrySet()) {
      if (Thread.currentThread().isInterrupted()) {
        return;
      }
      
      mapper.map(entry.getKey(), entry.getValue(), collector);
    }
  }
}

代码示例来源：origin: redisson/redisson

@Override
public void run() {
  Codec codec;
  try {
    codec = (Codec) objectCodecClass.getConstructor().newInstance();
  } catch (Exception e) {
    throw new IllegalStateException(e);
  }
  
  Injector.inject(mapper, redisson);
  RCollector<KOut, VOut> collector = new Collector<KOut, VOut>(codec, redisson, collectorMapName, workersAmount, timeout);
  for (String objectName : objectNames) {
    RMap<KIn, VIn> map = null;
    if (RMapCache.class.isAssignableFrom(objectClass)) {
      map = redisson.getMapCache(objectName, codec);
    } else {
      map = redisson.getMap(objectName, codec);
    }
    
    for (Entry<KIn, VIn> entry : map.entrySet()) {
      if (Thread.currentThread().isInterrupted()) {
        return;
      }
      
      mapper.map(entry.getKey(), entry.getValue(), collector);
    }
  }
}

代码示例来源：origin: org.redisson/redisson

protected RMapCache<Object, Object> getMapCache(String name, CacheConfig config) {
  if (codec != null) {
    return redisson.getMapCache(name, codec);
  }
  return redisson.getMapCache(name);
}

代码示例来源：origin: yangwenjie88/delay-queue

/**
 * 获取支持单个元素过期的map对象
 *
 * @param <K>        the type parameter
 * @param <V>        the type parameter
 * @param objectName the object name
 * @return the r map cache
 */
public static <K,V> RMapCache<K,V> getMapCache(String objectName){
  return redissonClient.getMapCache(objectName);
}

代码示例来源：origin: debop/hibernate-redis

private RMapCache<Object, Object> getCache(final String region) {
  RMapCache<Object, Object> cache = caches.get(region);
  if (cache == null) {
   cache = redisson.getMapCache(region);
   RMapCache<Object, Object> concurrent = caches.putIfAbsent(region, cache);
   if (concurrent != null) {
    cache = concurrent;
   }
  }
  return cache;
 }
}

代码示例来源：origin: debop/hibernate-redis

private RMapCache<Object, Object> getCache(final String region) {
  RMapCache<Object, Object> cache = caches.get(region);
  if (cache == null) {
   cache = redisson.getMapCache(region);
   RMapCache<Object, Object> concurrent = caches.putIfAbsent(region, cache);
   if (concurrent != null) {
    cache = concurrent;
   }
  }
  return cache;
 }
}

代码示例来源：origin: com.github.debop/hibernate-redis

private RMapCache<Object, Object> getCache(final String region) {
  RMapCache<Object, Object> cache = caches.get(region);
  if (cache == null) {
   cache = redisson.getMapCache(region);
   RMapCache<Object, Object> concurrent = caches.putIfAbsent(region, cache);
   if (concurrent != null) {
    cache = concurrent;
   }
  }
  return cache;
 }
}

代码示例来源：origin: Nepxion/Aquarius

@PostConstruct
public void initialize() {
  try {
    redissonHandler.validateStartedStatus();
    RedissonClient redission = redissonHandler.getRedisson();
    cache = redission.getMapCache(prefix);
  } catch (Exception e) {
    LOG.error("Get MapCache in Redisson failed", e);
  }
}

代码示例来源：origin: com.nepxion/aquarius-cache-redis

@PostConstruct
public void initialize() {
  try {
    redissonHandler.validateStartedStatus();
    RedissonClient redission = redissonHandler.getRedisson();
    cache = redission.getMapCache(prefix);
  } catch (Exception e) {
    LOG.error("Get MapCache in Redisson failed", e);
  }
}

代码示例来源：origin: justlive1/earth-frost

@Override
public List<JobExecutor> queryJobExecutors() {
 String uuid = UUID.randomUUID().toString();
 int subscribers = (int) workerTopic.publish(uuid);
 if (subscribers == 0) {
  return Collections.emptyList();
 }
 RMapCache<String, JobExecutor> cache = redissonClient
   .getMapCache(String.format(JobConfig.WORKER_REQ_VAL, uuid));
 waitFor(uuid, subscribers);
 return new ArrayList<>(cache.readAllValues());
}

代码示例来源：origin: justlive1/earth-frost

@Override
public int countExecutors() {
 String uuid = UUID.randomUUID().toString();
 int subscribers = (int) workerTopic.publish(uuid);
 if (subscribers == 0) {
  return 0;
 }
 RMapCache<String, JobExecutor> cache = redissonClient
   .getMapCache(String.format(JobConfig.WORKER_REQ_VAL, uuid));
 waitFor(uuid, subscribers);
 return cache.size();
}

代码示例来源：origin: org.redisson/redisson

@Override
public void run() {
  Codec codec;
  try {
    codec = (Codec) objectCodecClass.getConstructor().newInstance();
  } catch (Exception e) {
    throw new IllegalStateException(e);
  }
  
  Injector.inject(mapper, redisson);
  RCollector<KOut, VOut> collector = new Collector<KOut, VOut>(codec, redisson, collectorMapName, workersAmount, timeout);
  for (String objectName : objectNames) {
    RMap<KIn, VIn> map = null;
    if (RMapCache.class.isAssignableFrom(objectClass)) {
      map = redisson.getMapCache(objectName, codec);
    } else {
      map = redisson.getMap(objectName, codec);
    }
    
    for (Entry<KIn, VIn> entry : map.entrySet()) {
      if (Thread.currentThread().isInterrupted()) {
        return;
      }
      
      mapper.map(entry.getKey(), entry.getValue(), collector);
    }
  }
}

代码示例来源：origin: justlive1/earth-frost

@Override
public void register() {
 List<JobGroup> jobGroups = jobExecutor.getGroups();
 if (jobGroups == null || jobGroups.isEmpty()) {
  log.info("no jobs need to register");
  return;
 }
 // 注册job执行器
 for (JobGroup jobGroup : jobGroups) {
  String key = String
    .format(JobConfig.JOB_BEAN_CHANNEL, jobGroup.getGroupKey(), jobGroup.getJobKey());
  log.info("register job [{}]", key);
  redissonClient.getExecutorService(key).registerWorkers(JobConfig.getParallel());
 }
 // script执行器
 if (JobConfig.getExecutor().getScriptJobEnabled()) {
  redissonClient.getExecutorService(String.format(JobConfig.JOB_SCRIPT_CHANNEL, ""))
    .registerWorkers(JobConfig.getParallel());
  redissonClient
    .getExecutorService(String.format(JobConfig.JOB_SCRIPT_CHANNEL, jobExecutor.getKey()))
    .registerWorkers(JobConfig.getParallel());
 }
 // 订阅worker
 redissonClient.<String>getTopic(JobConfig.WORKER_REGISTER).addListener((channel, uuid) -> {
  redissonClient.getMapCache(String.format(JobConfig.WORKER_REQ_VAL, uuid))
    .put(jobExecutor.getId(), jobExecutor, 20, TimeUnit.SECONDS);
  redissonClient.getSemaphore(String.format(JobConfig.WORKER_REQ, uuid)).release();
 });
}

代码示例来源：origin: redisson/redisson-examples

RMapCache<String, Integer> mapCache = redisson.getMapCache("test");

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

RedissonClient

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    RedissonClient类方法

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