在使用Memcached时,一般实时读写的场景并不多见。但多是Memcached写入后,在一定时间后才会有读操作。但是如果应用场景,是写入后瞬间即会有读操作呢?似乎没有什么特别之处,我们依然可以这样写:

 

注:此处使用的是spymemcached客户端。

 

  1. MemcachedClient cache = new MemcachedClient(cacheServerAddr);  
  2. cache.set("key"3600, bigData);  
  3. return cache.get("key");  


如此写入缓存后,如果立刻就有其他客户端进行读操作,则会读取失败,因为set是异步操作(async),很可能仍还没有写入完。

 

一 种可行的方法,是采用同步写操作。常用的set方法没有这种方式,需要采用遵守Memcached的CAS(Check And Set)协议的写操作。而这种写操作,一般是基于读取后得到CAS ID(类似于SVN中的版本ID),根据这个CAS ID来保证写入时,没有和其他写入操作产生“写重复”冲突。因此,在我们现在所讨论的场景中,可以如下使用CAS协议:

(1)初始写入:写一个简单的初始值(set,异步操作);

(2)获取版本:使用异步方式获取CAS ID;

(3)同步写入:以同步方式写入数据,保证在读取前,已经写入结束。

  1. MemcachedClient cache = new MemcachedClient(cacheServerAddr);  
  2. cache.set(“key”, 3600"");  
  3. long casId = cache.asyncGets("key").get().getCas();  
  4. cache.cas("key", casid, bigData);  
  5. return cache.get("key");  

 

以这种“Set-Asyncgets-Cas”方式的缓存异步实时读写问题的解决方案,我们称之为“SAC”(你一定想到了什么⋯⋯)。

相关文章:

  • 2021-07-24
  • 2022-12-23
  • 2022-03-06
  • 2022-02-12
  • 2021-06-05
猜你喜欢
  • 2022-03-02
  • 2021-05-26
  • 2021-09-27
  • 2021-12-18
  • 2022-02-14
  • 2021-07-01
  • 2021-10-25
相关资源
相似解决方案