memcached 服务器重新启动后出现意外行为。如何配置/纠正它？

Question

我有一个持久连接池（Memcached 客户端）。数据正在缓存在 memcached 服务器中。如果重新启动memcached服务器后，我尝试使用客户端从池中获取缓存数据，我会收到以下异常：

java.util.concurrent.ExecutionException: java.lang.RuntimeException: Cancelled
    at net.spy.memcached.MemcachedClient$OperationFuture.get(MemcachedClient.java:1662)
    at net.spy.memcached.MemcachedClient$GetFuture.get(MemcachedClient.java:1708)
    at com.eos.gds.cache.CacheClient.get(CacheClient.java:49)

仅在重新启动后当我尝试获取缓存数据时第一次收到此异常。我做了很多搜索。但无法找到具体原因。

Answer 1

几天来一直在寻找解决方案。发布以防对其他人有帮助。

我们的 ServletContextListener 实现是在 contextInitialized 上获取一个新的 MemcachedClient(...) ，然后在 contextDestroyed 上调用 MemcachedClient 方法 shutdown() 。在我发送的第一个请求上，我总是会收到 CancellationException 或 ExecutionException。 （错误消息暗示了两者，但我能够捕获 ExecutionException。）

解决方案：从 shutdown() 切换到 shutdown(1, TimeUnit.SECONDS)

现在 get 调用在第一次运行时就成功了。

我无法确定 contextDestroyed 调用如何干扰请求的常规处理。我最好的猜测是，spymemcached 的单线程以某种方式在 servlet 之间共享，因此当创建 servlet 来处理构建过程的验证步骤发送的请求时，它将在第一个请求之前被销毁我要发送的请求，然后我的请求的 servlet 使用的 MemcachedClient 将尝试使用同一线程并受到关闭异常的影响。

（当我们得知我们的 Web 应用程序与 memcached 服务器有太多开放连接时，我们的团队不久前就确定需要调用 shutdown 。）

Answer 2

我有同样的问题。我正在使用 Spymemcached 客户端连接 Memcache 服务器。

我发现

一定是连接有问题。

参考： https://github.com/couchbase/spymemcached/blob/master/src/main/java/net/spy/memcached/internal/OperationFuture.java

Answer 3

为每个新客户端运行一次 MemcachedClient.getStats() ，这将解决取消问题。

Answer 4

我遇到了完全相同的问题并通过处理异常来修复它直到成功

while(true){
 try{
  memcacheclient.get(key);
  break;
 }
 catch(java.util.concurrent.CancellationException e ){
  log.info("cache cancelled");
 }
}

Answer 5

Spymemcached 有一堆内部队列，操作在实际发送到 memcached 之前先放入其中。这里发生的情况是，您执行一个操作，然后在通过网络发送该操作之前或从 memcached 收到响应之前，Spymemcached 意识到连接已丢失。因此，Spymemcached 取消所有正在进行的操作，然后重新建立连接。

当您在 Future 上调用 get() 时，由于 Spymemcached 取消了该操作，因此会引发异常。我建议在这里做的是捕获您使用 Spymemcached 执行的每个单独操作的所有异常，然后根据错误，重试该操作或只是忘记它。例如，如果它是一个 get 并且您的 memcached 服务器集群出现故障，那么您可能会忘记它，因为缓存将为空，但您可能想重试一组。