注:此处使用的是spymemcached客户端。
[java]
MemcachedClient cache = new MemcachedClient(cacheServerAddr);
cache.set("key", 3600, bigData);
return cache.get("key");
如此写入缓存后,如果立刻就有其他客户端进行读操作,则会读取失败,因为set是同步操作(sync),很可能仍还没有写入完。
一种可行的方法,是采用同步写操作。常用的set方法没有这种方式,需要采用遵守Memcached的CAS(Check And Set)协议的写操作。而这种写操作,一般是基于读取后得到CAS ID(类似于SVN中的版本ID),根据这个CAS ID来保证写入时,没有和其他写入操作产生“写重复”冲突。因此,在我们现在所讨论的场景中,可以如下使用CAS协议:
(1)初始写入:写一个简单的初始值;
(3)同步写入:以同步方式写入数据,保证在读取前,已经写入结束。
[java]
MemcachedClient cache = new MemcachedClient(cacheServerAddr);
cache.set(“key”, 3600, "");
long casId = cache.asyncGets("key").get().getCas();
cache.cas("key", cased, bigData);
return cache.get("key");
以这种“Set-Asyncgets-Cas”方式的缓存异步实时读写问题的解决方案,我们称之为“SAC”(你一定想到了什么……)。
尊重知识,转载请注明本文来自: 编程艺术家Poechant的CSDN博客http://blog.csdn.net/poechant