如何使用 Spymemcached 对 Redis Cloud Memcached 进行身份验证？

Question

我正在尝试连接到 Redis Cloud Memcached，但出现错误（如下）。我检查了apps.redislabs.com界面中的用户名、密码、主机和端口是否正确。如果我禁用 SASL 并在未经身份验证的情况下连接，我可以连接。

我该如何诊断？

（使用 spymemcached 2.11.6。）

import net.spy.memcached.auth.*;
import net.spy.memcached.*;
...
List<InetSocketAddress> addresses = Collections.singletonList(addr);
AuthDescriptor ad = new AuthDescriptor(new String[] { "CRAM-MD5", "PLAIN" },
        new PlainCallbackHandler(user, password));
MemcachedClient mc = new MemcachedClient(new ConnectionFactoryBuilder()
       .setProtocol(ConnectionFactoryBuilder.Protocol.BINARY)
       .setAuthDescriptor(ad).build(),
AddrUtil.getAddresses(host + ":" + port));

堆栈跟踪：

net.spy.memcached.MemcachedConnection:  Added {QA sa=pub-memcache-14154.us-central1-1-1.gce.garantiadata.com/104.197.191.74:14514, #Rops=0, #Wops=0, #iq=0, topRop=null, topWop=null, toWrite=0, interested=0} to connect queue
net.spy.memcached.protocol.binary.BinaryMemcachedNodeImpl:  Discarding partially completed op: SASL auth operation
net.spy.memcached.MemcachedConnection:  Reconnecting due to exception on {QA sa=pub-memcache-14154.us-central1-1-1.gce.garantiadata.com/104.197.191.74:14514, #Rops=0, #Wops=0, #iq=0, topRop=null, topWop=null, toWrite=0, interested=1}
java.io.IOException: An existing connection was forcibly closed by the remote host
    at sun.nio.ch.SocketDispatcher.read0(Native Method)
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
    at sun.nio.ch.IOUtil.read(IOUtil.java:192)
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
    at net.spy.memcached.MemcachedConnection.handleReads(MemcachedConnection.java:820)
    at net.spy.memcached.MemcachedConnection.handleReadsAndWrites(MemcachedConnection.java:720)
    at net.spy.memcached.MemcachedConnection.handleIO(MemcachedConnection.java:683)
    at net.spy.memcached.MemcachedConnection.handleIO(MemcachedConnection.java:436)
    at net.spy.memcached.MemcachedConnection.run(MemcachedConnection.java:1446)
 net.spy.memcached.MemcachedConnection:  Closing, and reopening {QA sa=pub-memcache-14154.us-central1-1-1.gce.garantiadata.com/104.197.191.74:14514, #Rops=0, #Wops=0, #iq=0, topRop=null, topWop=null, toWrite=0, interested=1}, attempt 0.
net.spy.memcached.MemcachedConnection:  Could not redistribute to another node, retrying primary node for foo.

Answer 1

在您的 AuthDescriptior 声明中丢失 "CRAM-MD5"。

以下在我的测试中有效：（删除了用户、通行证和 url）

AuthDescriptor ad = new AuthDescriptor(new String[] {"PLAIN"}, new PlainCallbackHandler(user, pass));
MemcachedClient mc = null;
    try {
        mc = new MemcachedClient(
        new ConnectionFactoryBuilder()
            .setProtocol(ConnectionFactoryBuilder.Protocol.BINARY)
            .setAuthDescriptor(ad).build(),
        AddrUtil.getAddresses(host + ":" + port ));
    } catch (IOException e) {
        // handle exception
    }
mc.set("foo", 0, "bar");
String value = (String) mc.get("foo");
System.out.println(value);