如何使用Spymemcached向Redis Cloud Memcached进行身份验证?

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了如何使用Spymemcached向Redis Cloud Memcached进行身份验证?相关的知识,希望对你有一定的参考价值。

我正在尝试连接到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.
答案

丢失了"CRAM-MD5"声明中的AuthDescriptior

以下内容在我的测试中起作用:(删除了用户,传递和网址)

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);

以上是关于如何使用Spymemcached向Redis Cloud Memcached进行身份验证?的主要内容,如果未能解决你的问题,请参考以下文章

redis如何清除所有的key

刚刚用spring boot 并用缓存数据库redis ,哪里有比较好的教程呢,菜鸟

如何使用 xmpppy 向聊天室发送消息?

唯实践Memcached使用那些事

Memcached的几种Java客户端

Redis Mass Insertion包含值中的换行符