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

RedissonClient.getMap介绍

[英]Returns map instance by name.
[中]按名称返回映射实例。

代码示例

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

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

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

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

代码示例来源：origin: mrniko/netty-socketio

@Override
public <K, V> Map<K, V> createMap(String name) {
  return redisClient.getMap(name);
}

代码示例来源：origin: mrniko/netty-socketio

public RedissonStore(UUID sessionId, RedissonClient redisson) {
  this.map = redisson.getMap(sessionId.toString());
}

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

@Override
public R call() throws Exception {
  this.codec = (Codec) codecClass.getConstructor().newInstance();
  
  Injector.inject(collator, redisson);
  
  RMap<KOut, VOut> resultMap = redisson.getMap(resultMapName, codec);
  R result = collator.collate(resultMap);
  resultMap.delete();
  return result;
}

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

@Override
public R call() throws Exception {
  this.codec = (Codec) codecClass.getConstructor().newInstance();
  
  Injector.inject(collator, redisson);
  
  RMap<KOut, VOut> resultMap = redisson.getMap(resultMapName, codec);
  R result = collator.collate(resultMap);
  resultMap.delete();
  return result;
}

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

public RMap<String, Object> getMap(String sessionId) {
  String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
  String name = keyPrefix + separator + "redisson:tomcat_session:" + sessionId;
  return redisson.getMap(name, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
}

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

public RMap<String, Object> getMap(String sessionId) {
  String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
  String name = keyPrefix + separator + "redisson:tomcat_session:" + sessionId;
  return redisson.getMap(name, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
}

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

public RMap<String, Object> getMap(String sessionId) {
  String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
  String name = keyPrefix + separator + "redisson:tomcat_session:" + sessionId;
  return redisson.getMap(name, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
}

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

public RMap<String, Object> getMap(String sessionId) {
  String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
  String name = keyPrefix + separator + "redisson:tomcat_session:" + sessionId;
  return redisson.getMap(name, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
}

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

public RedissonSession(String keyPrefix, String sessionId) {
  this.delegate = new MapSession(sessionId);
  map = redisson.getMap(keyPrefix + sessionId, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
  principalName = resolvePrincipal(delegate);
}

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

public RedissonSession(String keyPrefix, String sessionId) {
  this.delegate = new MapSession(sessionId);
  map = redisson.getMap(keyPrefix + sessionId, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
  principalName = resolvePrincipal(delegate);
}

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

@Override
public void scheduleWithFixedDelay(ScheduledWithFixedDelayParameters params) {
  executeRunnable(params, false);
  if (!redisson.getMap(tasksName, StringCodec.INSTANCE).containsKey(params.getRequestId())) {
    return;
  }
  
  long newStartTime = System.currentTimeMillis() + params.getDelay();
  params.setStartTime(newStartTime);
  asyncScheduledServiceAtFixed(params.getExecutorId(), params.getRequestId()).scheduleWithFixedDelay(params);
}

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

@Override
public void scheduleWithFixedDelay(ScheduledWithFixedDelayParameters params) {
  executeRunnable(params, false);
  if (!redisson.getMap(tasksName, StringCodec.INSTANCE).containsKey(params.getRequestId())) {
    return;
  }
  
  long newStartTime = System.currentTimeMillis() + params.getDelay();
  params.setStartTime(newStartTime);
  asyncScheduledServiceAtFixed(params.getExecutorId(), params.getRequestId()).scheduleWithFixedDelay(params);
}

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

public RedissonSession(String keyPrefix) {
  this.delegate = new MapSession();
  map = redisson.getMap(keyPrefix + delegate.getId(), new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
  principalName = resolvePrincipal(delegate);
  Map<String, Object> newMap = new HashMap<String, Object>(3);
  newMap.put("session:creationTime", delegate.getCreationTime());
  newMap.put("session:lastAccessedTime", delegate.getLastAccessedTime());
  newMap.put("session:maxInactiveInterval", delegate.getMaxInactiveIntervalInSeconds());
  map.putAll(newMap);
  updateExpiration();
  
  String channelName = getEventsChannelName(delegate.getId());
  RTopic topic = redisson.getTopic(channelName, StringCodec.INSTANCE);
  topic.publish(delegate.getId());
}

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

public RedissonSession(String keyPrefix) {
  this.delegate = new MapSession();
  map = redisson.getMap(keyPrefix + delegate.getId(), new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec()));
  principalName = resolvePrincipal(delegate);
  Map<String, Object> newMap = new HashMap<String, Object>(3);
  newMap.put("session:creationTime", delegate.getCreationTime());
  newMap.put("session:lastAccessedTime", delegate.getLastAccessedTime());
  newMap.put("session:maxInactiveInterval", delegate.getMaxInactiveIntervalInSeconds());
  map.putAll(newMap);
  updateExpiration();
  
  String channelName = getEventsChannelName(delegate.getId());
  RTopic topic = redisson.getTopic(channelName, StringCodec.INSTANCE);
  topic.publish(delegate.getId());
}

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

@Override
  public void operationComplete(Future<RemoteServiceCancelRequest> future) throws Exception {
    if (!future.isSuccess()) {
      return;
    }
    boolean res = submitFuture.cancel(future.getNow().isMayInterruptIfRunning());
    if (res) {
      RemoteServiceCancelResponse response = new RemoteServiceCancelResponse(request.getId(), true);
      if (!responseHolder.compareAndSet(null, response)) {
        response = new RemoteServiceCancelResponse(request.getId(), false);
      }
      
      // could be removed not from future object
      if (future.getNow().isSendResponse()) {
        RMap<String, RemoteServiceCancelResponse> map = redisson.getMap(cancelResponseMapName, new CompositeCodec(StringCodec.INSTANCE, codec, codec));
        map.fastPutAsync(request.getId(), response);
        map.expireAsync(60, TimeUnit.SECONDS);
      }
    }
  }
});

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

@Override
  public void operationComplete(Future<RemoteServiceCancelRequest> future) throws Exception {
    if (!future.isSuccess()) {
      return;
    }
    boolean res = submitFuture.cancel(future.getNow().isMayInterruptIfRunning());
    if (res) {
      RemoteServiceCancelResponse response = new RemoteServiceCancelResponse(request.getId(), true);
      if (!responseHolder.compareAndSet(null, response)) {
        response = new RemoteServiceCancelResponse(request.getId(), false);
      }
      
      // could be removed not from future object
      if (future.getNow().isSendResponse()) {
        RMap<String, RemoteServiceCancelResponse> map = redisson.getMap(cancelResponseMapName, new CompositeCodec(StringCodec.INSTANCE, codec, codec));
        map.fastPutAsync(request.getId(), response);
        map.expireAsync(60, TimeUnit.SECONDS);
      }
    }
  }
});

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

private void cancelExecution(RemoteInvocationOptions optionsCopy,
    boolean mayInterruptIfRunning, RemotePromise<Object> remotePromise) {
  RMap<String, RemoteServiceCancelRequest> canceledRequests = redisson.getMap(cancelRequestMapName, new CompositeCodec(StringCodec.INSTANCE, codec, codec));
  canceledRequests.fastPutAsync(remotePromise.getRequestId().toString(), new RemoteServiceCancelRequest(mayInterruptIfRunning, false));
  canceledRequests.expireAsync(60, TimeUnit.SECONDS);
  
  // subscribe for async result if it's not expected before
  if (!optionsCopy.isResultExpected()) {
    RemoteInvocationOptions options = new RemoteInvocationOptions(optionsCopy);
    options.expectResultWithin(60, TimeUnit.SECONDS);
    RFuture<RRemoteServiceResponse> responseFuture = pollResponse(options.getExecutionTimeoutInMillis(), remotePromise.getRequestId(), false);
    awaitResultAsync(options, remotePromise, responseFuture);
  }
}

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

private void cancelExecution(RemoteInvocationOptions optionsCopy,
    boolean mayInterruptIfRunning, RemotePromise<Object> remotePromise) {
  RMap<String, RemoteServiceCancelRequest> canceledRequests = redisson.getMap(cancelRequestMapName, new CompositeCodec(StringCodec.INSTANCE, codec, codec));
  canceledRequests.fastPutAsync(remotePromise.getRequestId().toString(), new RemoteServiceCancelRequest(mayInterruptIfRunning, false));
  canceledRequests.expireAsync(60, TimeUnit.SECONDS);
  
  // subscribe for async result if it's not expected before
  if (!optionsCopy.isResultExpected()) {
    RemoteInvocationOptions options = new RemoteInvocationOptions(optionsCopy);
    options.expectResultWithin(60, TimeUnit.SECONDS);
    RFuture<RRemoteServiceResponse> responseFuture = pollResponse(options.getExecutionTimeoutInMillis(), remotePromise.getRequestId(), false);
    awaitResultAsync(options, remotePromise, responseFuture);
  }
}