2

我将一组值存储到 memcached 客户端中,键为 setOfKeys。我将值放入 memcached 中,如下所示

Set<String> keys=new HashSet<String>();
mMemcachedClient = new MemcachedClient(new BinaryConnectionFactory(),
                AddrUtil.getAddresses("172.22.65.111:11211 172.22.65.11:11211"));

public void put(Object key, Object value) throws Result {

        try {
            synchronized (mMemcachedClient) {
                this.keys.add(key.toString());

                if(keys.size()==1){
                    mMemcachedClient.set(String.valueOf(hg.hash("setOfKeys")),
                            7200, keys);
                }
                else{
                    mMemcachedClient.replace(String.valueOf(hg.hash("setOfKeys")),
                            7200, keys);
                }
                mMemcachedClient.set(String.valueOf(hg.hash(key.toString())),
                        7200, value);
            }
        } catch (Excep`enter code here`tion ex) {`enter code here`
            mLogger.error(ex.getMessage());
            throw new Result("ERROR_PUT_MEMCACHED_INTO_CACHE");
        }
    }

但是当我尝试按如下方式从缓存中获取 setOfKeys 时,它给了我错误

net.spy.memcached.OperationTimeoutException: Timeout waiting for value

4

1 回答 1

2

MemcachedClient 中的 set 和 replace 函数是异步的并返回 Futures。您必须在返回的对象上调用 .get() 以使其阻塞,直到操作完成。

mMemcachedClient.set(String.valueOf(hg.hash("setOfKeys")), 7200, keys).get();

您还应该检查上述语句的返回值,以确保操作成功。

于 2013-07-30T17:21:09.573 回答