1

我有以下使用 net.spy.memcached.MemcachedClient 的单元测试

    @Test
public void testCASFailsWrite() throws Exception {
    Integer begin = new Integer(3);
    client.set(key, 0, begin);

    CASValue<Object> casValue = client.gets(key);

    Assert.assertNotNull(casValue);
    Assert.assertTrue(casValue.getValue() instanceof Integer);

    Integer fromCache = (Integer) casValue.getValue();  
    Integer nextSeq = new Integer(fromCache + 9);

    long myInvalidValue = casValue.getCas() - 1;

    CASResponse response = client.cas(key, myInvalidValue, nextSeq);
    Assert.assertEquals(CASResponse.EXISTS, response);
}

我希望 CASResponse 显示该值已经存在，因为我有一个无效的 casValue，但是它在最后一个 Assert 上返回为 OK。我想确保我的密钥句柄在多个 JVM 上同时更新。我的单元测试是通过 com.thimbleware.jmemcached.AbstractCache 的实现使用嵌入式 memcache 进程。当我的密钥已经在内存缓存中并且我没有相同的 casValue() 时，我可以依靠 CASResponse 来显示 EXISTS 吗？

4

1 回答 1

0

这很可能是因为您正在针对一个全新的 memcached 实例运行此测试。cas 值在 memcached 实例中是全局的，第一组接收 cas 值 1，第二组接收 cas 值 2，依此类推。当您运行测试时，您的密钥的 cas 值为 1。由于您的无效 cas 是通过仅减少此密钥的 cas 值生成的，因此您的无效 cas 值最终为 0。在更新中指定 cas 值为 0 意味着忽略cas，然后更新。将 myInvalidValue 设置为像 123456 这样的随机数，这个问题就会消失。另一个有趣的事情是，如果你在上面两次运行测试，它会通过第二次。

于 2013-04-13T00:25:47.410 回答