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

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

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

MemcachedClient.delete介绍

[英]Delete the given key from the cache.
[中]从缓存中删除给定的密钥。

代码示例

代码示例来源：origin: ninjaframework/ninja

  1. public void delete(String key) {
  2.   client.delete(key);
  3. }

代码示例来源：origin: ninjaframework/ninja

  1. public boolean safeDelete(String key) {
  2.   Future<Boolean> future = client.delete(key);
  3.   try {
  4.     return future.get(1, TimeUnit.SECONDS);
  5.   } catch (Exception e) {
  6.     future.cancel(false);
  7.   }
  8.   return false;
  9. }

代码示例来源：origin: brianfrankcooper/YCSB

  1. @Override
  2. public Status delete(String table, String key) {
  3.  key = createQualifiedKey(table, key);
  4.  try {
  5.   OperationFuture<Boolean> future = memcachedClient().delete(key);
  6.   return getReturnCode(future);
  7.  } catch (Exception e) {
  8.   logger.error("Error deleting value", e);
  9.   return Status.ERROR;
  10.  }
  11. }

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

  1. @Override
  2. public boolean evictBlock(BlockCacheKey cacheKey) {
  3.  try {
  4.   cacheStats.evict();
  5.   return client.delete(cacheKey.toString()).get();
  6.  } catch (InterruptedException e) {
  7.   LOG.warn("Error deleting " + cacheKey.toString(), e);
  8.   Thread.currentThread().interrupt();
  9.  } catch (ExecutionException e) {
  10.   if (LOG.isDebugEnabled()) {
  11.    LOG.debug("Error deleting " + cacheKey.toString(), e);
  12.   }
  13.  }
  14.  return false;
  15. }

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

  1. @Override
  2. public void delete(Set<CacheKeyTO> keys) throws CacheCenterConnectionException {
  3.   if (null == memcachedClient || null == keys || keys.isEmpty()) {
  4.     return;
  5.   }
  6.   String hfield;
  7.   for (CacheKeyTO cacheKeyTO : keys) {
  8.     if (null == cacheKeyTO) {
  9.       continue;
  10.     }
  11.     String cacheKey = cacheKeyTO.getCacheKey();
  12.     if (null == cacheKey || cacheKey.isEmpty()) {
  13.       continue;
  14.     }
  15.     hfield = cacheKeyTO.getHfield();
  16.     if (null != hfield && hfield.length() > 0) {
  17.       throw new RuntimeException("memcached does not support hash cache.");
  18.     }
  19.     try {
  20.       String allKeysPattern = "*";
  21.       if (allKeysPattern.equals(cacheKey)) {
  22.         memcachedClient.flush();
  23.       } else {
  24.         memcachedClient.delete(cacheKey);
  25.       }
  26.     } catch (Exception e) {
  27.       log.error(e.getMessage(), e);
  28.     }
  29.   }
  30. }

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

  1. @Override
  2. protected void delete(final String storageKey) throws ResourceIOException {
  3.   client.delete(storageKey);
  4. }

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

  1. @Override
  2. public Future<Boolean> delete(String key) {
  3.   return _memcached.delete(key);
  4. }

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

  1. @Override
  2. public void delete(String sessionId) {
  3.   this.sessions.delete(sessionId);
  4. }

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

  1. @Override
  2. protected Cancellable delete(final String storageKey, final FutureCallback<Boolean> callback) {
  3.   return operation(client.delete(storageKey), callback);
  4. }

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

  1. @SuppressWarnings("unchecked")
  2. @BeforeMethod
  3. public void setup() throws Exception {
  4.   final StandardContext context = createContext();
  5.   context.setBackgroundProcessorDelay( 1 ); // needed for test of updateExpiration
  6.   final SessionManager manager = createSessionManager(context);
  7.   _service = manager.getMemcachedSessionService();
  8.   _service.setMemcachedNodes( "n1:127.0.0.1:11211" );
  9.   _service.setSessionBackupAsync( false );
  10.   _service.setSticky( true );
  11.   _memcachedMock = mock( MemcachedClient.class );
  12.   final OperationFuture<Boolean> setResultMock = mock( OperationFuture.class );
  13.   when( setResultMock.get( ) ).thenReturn( Boolean.TRUE );
  14.   when( setResultMock.get( anyInt(), any( TimeUnit.class ) ) ).thenReturn( Boolean.TRUE );
  15.   when( _memcachedMock.set( any( String.class ), anyInt(), any(), any( Transcoder.class ) ) ).thenReturn( setResultMock );
  16.   final OperationFuture<Boolean> deleteResultMock = mock( OperationFuture.class );
  17.   when( deleteResultMock.get() ).thenReturn( Boolean.TRUE );
  18.   when( _memcachedMock.delete( anyString() ) ).thenReturn( deleteResultMock );
  19.   startInternal( manager, _memcachedMock );
  20.   _executor = Executors.newCachedThreadPool();
  21. }

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

  1. verify( _memcachedMock, times( 1 ) ).delete( eq( oldSessionId ) );
  2. verify( _memcachedMock, times( 1 ) ).set( eq( session.getId() ), anyInt(), any(), any( Transcoder.class ) );
  3.   Thread.sleep(200l);
  4.   verify( _memcachedMock, times( 1 ) ).delete( eq( new SessionIdFormat().createValidityInfoKeyName( oldSessionId ) ) );
  5.   verify( _memcachedMock, times( 1 ) ).set( eq( new SessionIdFormat().createValidityInfoKeyName( session.getId() ) ), anyInt(), any(), any( Transcoder.class ) );

代码示例来源：origin: net.spy/spymemcached

  1. /**
  2.  * Delete the given key from the cache.
  3.  *
  4.  * @param key the key to delete
  5.  * @return whether or not the operation was performed
  6.  * @throws IllegalStateException in the rare circumstance where queue is too
  7.  *           full to accept any more requests
  8.  */
  9. @Override
  10. public OperationFuture<Boolean> delete(String key) {
  11.  return delete(key, 0L);
  12. }

代码示例来源：origin: apache/apex-malhar

  1. @Override
  2. public void remove(Object key)
  3. {
  4.  memcacheClient.delete(key.toString());
  5. }

代码示例来源：origin: org.apache.apex/malhar-contrib

  1. @Override
  2. public void remove(Object key)
  3. {
  4.  memcacheClient.delete(key.toString());
  5. }

代码示例来源：origin: com.google.code.maven-play-plugin.org.playframework/play

  1. @Override
  2. public boolean safeDelete(String key) {
  3.   Future<Boolean> future = client.delete(key);
  4.   try {
  5.     return future.get(1, TimeUnit.SECONDS);
  6.   } catch (Exception e) {
  7.     future.cancel(false);
  8.   }
  9.   return false;
  10. }

代码示例来源：origin: org.wicketstuff/wicketstuff-datastore-memcached

  1. @Override
  2. public void removeData(String sessionId) {
  3.   Set<String> keys = keysPerSession.get(sessionId);
  4.   if (keys != null) {
  5.     for (String key : keys) {
  6.       client.delete(key);
  7.     }
  8.     keysPerSession.remove(sessionId);
  9.     LOG.debug("Removed the data for session '{}'", sessionId);
  10.   }
  11. }

代码示例来源：origin: org.datanucleus/datanucleus-cache

  1. public void evict(Query query)
  2. {
  3.   String baseKey = QueryUtils.getKeyForQueryResultsCache(query, null);
  4.   client.delete(keyPrefix + baseKey);
  5.   // TODO Delete all entries for this query (with any possible set of params) i.e key starting baseKey
  6. }

代码示例来源：origin: indeedeng/lsmtree

  1. public void delete(K key) {
  2.   String str = keyStringifier.toString(key);
  3.   if (log.isTraceEnabled()) {
  4.     log.trace("Deleting key " + str);
  5.   }
  6.   memcache.delete(prefix + str);
  7. }

代码示例来源：origin: io.snappydata/gemfire-junit

  1. public void testDelete() throws Exception {
  2.  MemcachedClient client = bootstrapClient();
  3.  Future<Boolean> b = client.delete("key");
  4.  assertTrue(b.get());
  5.  b = client.delete("nonExistentkey");
  6.  assertFalse(b.get());
  7. }

代码示例来源：origin: mugglmenzel/serverless-examples-cached-rds-ws

  1. @Override
  2. public boolean delete(String key) {
  3.   try {
  4.     return getClient().delete(key).get(timeout, timeoutUnit);
  5.   } catch (Exception e) {
  6.     logger.log(String.format("Exception or timeout while deleting key %s in cache. %s", key, e.getMessage()));
  7.     return false;
  8.   }
  9. }

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

MemcachedClient

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    MemcachedClient类方法

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