net.spy.memcached.MemcachedClient.get()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(205)

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

MemcachedClient.get介绍

[英]Get with a single key and decode using the default transcoder.
[中]用一个键获取，并使用默认转码器进行解码。

代码示例

代码示例来源：origin: aol/micro-server

  1. @Override
  2. public Optional<V> get(String key) {
  3.   return (Optional<V>) Optional.ofNullable(memcachedClient.get(key));
  4. }

代码示例来源：origin: qiujiayu/AutoLoadCache

  1. @SuppressWarnings("unchecked")
  2. @Override
  3. public CacheWrapper<Object> get(final CacheKeyTO cacheKeyTO, Method method) throws CacheCenterConnectionException {
  4.   if (null == cacheKeyTO) {
  5.     return null;
  6.   }
  7.   String cacheKey = cacheKeyTO.getCacheKey();
  8.   if (null == cacheKey || cacheKey.isEmpty()) {
  9.     return null;
  10.   }
  11.   String hfield = cacheKeyTO.getHfield();
  12.   if (null != hfield && hfield.length() > 0) {
  13.     throw new RuntimeException("memcached does not support hash cache.");
  14.   }
  15.   return (CacheWrapper<Object>) memcachedClient.get(cacheKey);
  16. }

代码示例来源：origin: jooby-project/jooby

  1. @SuppressWarnings("unchecked")
  2. @Override
  3. public Session get(final Builder builder) {
  4.  String key = key(builder.sessionId());
  5.  Map<String, String> attrs = (Map<String, String>) memcached.get(key);
  6.  if (attrs == null || attrs.size() == 0) {
  7.   // expired
  8.   return null;
  9.  }
  10.  // touch session
  11.  memcached.touch(key, timeout);
  12.  return builder
  13.    .accessedAt(Long.parseLong(attrs.remove("_accessedAt")))
  14.    .createdAt(Long.parseLong(attrs.remove("_createdAt")))
  15.    .savedAt(Long.parseLong(attrs.remove("_savedAt")))
  16.    .set(attrs)
  17.    .build();
  18. }

代码示例来源：origin: apache/hbase

  1. @Override
  2. public Cacheable getBlock(BlockCacheKey cacheKey, boolean caching,
  3.              boolean repeat, boolean updateCacheMetrics) {
  4.  // Assume that nothing is the block cache
  5.  HFileBlock result = null;
  6.  try (TraceScope traceScope = TraceUtil.createTrace("MemcachedBlockCache.getBlock")) {
  7.   result = client.get(cacheKey.toString(), tc);
  8.  } catch (Exception e) {
  9.   // Catch a pretty broad set of exceptions to limit any changes in the memecache client
  10.   // and how it handles failures from leaking into the read path.
  11.   if (LOG.isDebugEnabled()) {
  12.    LOG.debug("Exception pulling from memcached [ "
  13.      + cacheKey.toString()
  14.      + " ]. Treating as a miss.", e);
  15.   }
  16.   result = null;
  17.  } finally {
  18.   // Update stats if this request doesn't have it turned off 100% of the time
  19.   if (updateCacheMetrics) {
  20.    if (result == null) {
  21.     cacheStats.miss(caching, cacheKey.isPrimary(), cacheKey.getBlockType());
  22.    } else {
  23.     cacheStats.hit(caching, cacheKey.isPrimary(), cacheKey.getBlockType());
  24.    }
  25.   }
  26.  }
  27.  return result;
  28. }

代码示例来源：origin: aol/micro-server

  1. @Before
  2. public void setup() {
  3.   memcachedClient = mock(MemcachedClient.class);
  4.   stub(memcachedClient.get("key1")).toReturn("value1");
  5.   stub(memcachedClient.get("key2")).toReturn("value2");
  6.   OperationFuture<Boolean> mockedFuture = mock(OperationFuture.class);
  7.   stub(memcachedClient.add("keyAdd", 3600, "valueadd")).toReturn(mockedFuture);
  8. }

代码示例来源：origin: pippo-java/pippo

  1. @Override
  2. public SessionData get(String sessionId) {
  3.   return (SessionData) this.sessions.get(sessionId);
  4. }

代码示例来源：origin: magro/memcached-session-manager

  1. @Override
  2. public byte[] get(String key) {
  3.   return _memcached.get(key, ByteArrayTranscoder.INSTANCE);
  4. }

代码示例来源：origin: magro/memcached-session-manager

  1. @Override
  2.   public Object call() throws Exception {
  3.     return _client.get( sessionId1 );
  4.   }
  5. }, notNullValue() );

代码示例来源：origin: magro/memcached-session-manager

  1. @Override
  2.   public Object call() throws Exception {
  3.     return _client.get( sessionId1 );
  4.   }
  5. }, notNullValue());

代码示例来源：origin: magro/memcached-session-manager

  1. @Override
  2.   public byte[] get(final String key) {
  3.     return _client.get(key, ByteArrayTranscoder.INSTANCE);
  4.   }
  5. };

代码示例来源：origin: magro/memcached-session-manager

  1. @Override
  2.   public byte[] get(final String key) {
  3.     return _client.get(key, ByteArrayTranscoder.INSTANCE);
  4.   }
  5. };

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

  1. public Object get(final String key) {
  2.   return fromCacheValue(client.get(key));
  3. }

代码示例来源：origin: apache/httpcomponents-client

  1. @Override
  2. protected byte[] restore(final String storageKey) throws ResourceIOException {
  3.   try {
  4.     return castAsByteArray(client.get(storageKey));
  5.   } catch (final OperationTimeoutException ex) {
  6.     throw new MemcachedOperationTimeoutException(ex);
  7.   }
  8. }

代码示例来源：origin: magro/memcached-session-manager

  1. @Test( enabled = true )
  2. public void testInvalidateSessionShouldReleaseLockIssue144() throws IOException, InterruptedException, HttpException {
  3.   _tomcat1.getManager().setLockingMode(LockingMode.AUTO.name());
  4.   final String sessionId1 = get( _httpClient, TC_PORT_1, null ).getSessionId();
  5.   assertNotNull( sessionId1, "No session created." );
  6.   final Response response = get( _httpClient, TC_PORT_1, PATH_INVALIDATE, sessionId1 );
  7.   assertNull( response.getResponseSessionId() );
  8.   assertNull(_client.get( sessionId1 ), "Invalidated session should be removed from memcached");
  9.   assertNull(_client.get(new SessionIdFormat().createLockName(sessionId1)), "Lock should be released.");
  10. }

代码示例来源：origin: magro/memcached-session-manager

  1. @Test
  2. public void testInvalidNonStickySessionDoesNotCallOnBackupWithoutLoadedSessionIssue137() throws Exception {
  3.   _service.setStickyInternal( false );
  4.   _service.setLockingMode( LockingMode.NONE, null, false );
  5.   _service.startInternal(new MemcachedStorageClient(_memcachedMock)); // we must put in our mock again
  6.   final String sessionId = "nonStickySessionToTimeOut-n1";
  7.   // For findSession needed
  8.   final Request requestMock = mock(Request.class);
  9.   when(requestMock.getNote(eq(RequestTrackingContextValve.INVOKED))).thenReturn(Boolean.TRUE);
  10.   _service.getTrackingHostValve().storeRequestThreadLocal(requestMock);
  11.   final MemcachedBackupSession session = _service.findSession(sessionId);
  12.   assertNull(session);
  13.   _service.backupSession( sessionId, false, null ).get();
  14.   // check that validity info is not loaded - this would trigger the
  15.   // WARNING: Found no validity info for session id ...
  16.   final String validityKey = new SessionIdFormat().createValidityInfoKeyName( sessionId );
  17.   verify( _memcachedMock, times( 0 ) ).get( eq( validityKey ) );
  18. }

代码示例来源：origin: magro/memcached-session-manager

  1. when( _memcachedMock.get( eq( validityKey ), any ( Transcoder.class) ) ).thenReturn( validityData );

代码示例来源：origin: magro/memcached-session-manager

  1. assertNull( _client.get( sessionId1 ) );
  2. assertNotNull( _client.get( sessionId2 ) );

代码示例来源：origin: magro/memcached-session-manager

  1. @Test
  2. public void testBackupSessionInCouchbase() throws InterruptedException, ExecutionException {
  3.   final MemcachedSessionService service = _tomcat1.getService();
  4.   final MemcachedBackupSession session = createSession( service );
  5.   final String sessionId = "12345";
  6.   session.setId(sessionId);
  7.   session.setAttribute( "foo", "bar" );
  8.   final BackupResult backupResult = service.backupSession( session.getIdInternal(), false, null ).get();
  9.   assertEquals(backupResult.getStatus(), BackupResultStatus.SUCCESS);
  10.   final MemcachedBackupSession loadedSession = transcoderService.deserialize(mc.get(sessionId, ByteArrayTranscoder.INSTANCE), _tomcat1.getManager());
  11.   checkSession(loadedSession, session);
  12. }

代码示例来源：origin: magro/memcached-session-manager

  1. _service.getTrackingHostValve().storeRequestThreadLocal(requestMock);
  2. when(_memcachedMock.get(eq(session.getId()), any(Transcoder.class))).thenReturn(transcoderService.serialize(session));

代码示例来源：origin: magro/memcached-session-manager

  1. @Test(enabled = false) // spurious failures
  2. public void testBackupSessionInCouchbaseCluster() throws Exception {
  3.   final MemcachedSessionService service = _tomcat1.getService();
  4.   cluster.add(setupCouchbase(getMaxCouchbasePort() + 1));
  5.   service.setMemcachedNodes(getMemcachedNodesConfig(getURIs()));
  6.   setupCouchbaseClient();
  7.   waitForReconnect(service.getStorageClient(), cluster.size(), 1000);
  8.   waitForReconnect(mc, cluster.size(), 1000);
  9.   final MemcachedBackupSession session = createSession( service );
  10.   final String sessionId = "12345";
  11.   session.setId(sessionId);
  12.   session.setAttribute( "foo", "bar" );
  13.   final BackupResult backupResult = service.backupSession( session.getIdInternal(), false, null ).get();
  14.   assertEquals(backupResult.getStatus(), BackupResultStatus.SUCCESS);
  15.   final MemcachedBackupSession loadedSession = transcoderService.deserialize(mc.get(sessionId, ByteArrayTranscoder.INSTANCE), _tomcat1.getManager());
  16.   checkSession(loadedSession, session);
  17. }

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

MemcachedClient

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    MemcachedClient类方法

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