在大量请求并发访问和更新Tair中储存的共享资源时,必须有一种精准高效的并发控制机制来防止逻辑异常和数据错误,乐观锁就是这样一种机制。比起原生Redis,云原生内存数据库Tair的TairString模块能帮助您实现性能更高、成本更低的乐观锁。

并发与Last-Writer-Win

下图展示了一个典型的并发导致资源竞争的场景:

  1. 初始状态,string类型数据key_1的值为hello
  2. t1时刻,App1读取到key_1的值hello
  3. t2时刻,App2读取到key_1的值hello
  4. t3时刻,App1将key_1的值修改为world
  5. t4时刻,App2将key_1的值修改为universe

key_1的值是由最后一次写入决定的,到了t4时刻,App1对key_1的认知已经出现了明显的误差,后续操作很可能出现问题,这就是所谓的Last-Writer-Win。要解决Last-Writer-Win问题,就需要保证访问并更新string数据这个操作的原子性,或者说,将作为共享资源的string数据转变为具有原子性的变量。您可以使用TairString数据结构,构建高性能的乐观锁来达成这个效果。

使用TairString实现乐观锁

TairString,又称为exString(extended string),是一种带版本号的string类型数据结构。原生Redis String仅由key和value组成,而TairString不仅包含key和value,还携带了版本(version),极为适合乐观锁等场景。详细介绍及命令解析请参见TairString

说明 TairString与Redis原生String是两种不同的数据结构,相关命令不可混用。

TairString有以下特性:

  • 每个key都有对应的version,用于说明key当前的版本。使用EXSET命令创建一个key时,默认其version为1。
  • 对某个key使用EXGET时,可以获取到value和version两个字段。
  • 更新TairString的value时,需要校验version,如果校验失败会返回异常信息ERR update version is stale
  • value更新后version自动加1。
  • 除了比特位(bit)相关操作外,TairString可以覆盖原生Redis String的所有其它功能。

因为这些特性,TairString类型的数据本身就具有锁的机制,使用TairString实现乐观锁就非常方便了,示例如下:

while(true){
    {value, version} = EXGET(key);      // 获取key的value和version
    value2 = update(...);               // 先将新value保存到value2
    ret = EXSET(key, value2, version);  // 尝试更新key并将返回值赋予变量ret
    if(ret == OK)
       break;                           // 如果返回值为OK则更新成功,跳出循环
    else if (ret.contanis("version is stale"))     
       continue;                        // 如果返回值包含"version is stale"则更新失败,重复循环
}
说明
  • 删除TairString后,即便以相同的key重新设置一条TairString,其version也会是1,而不会继承原TairString的version。
  • 使用ABS选项可以跳过version校验强行覆盖version并更新TairString,详情参见EXSET

降低乐观锁的性能消耗

前文的示例代码中,如果在执行EXGET后该共享资源被其它客户端更新了,当前客户端会获取到更新失败的异常信息,然后重复循环,再次执行EXGET获取共享资源的当前value和version,直到更新成功,这样每次循环都有两次访问Redis的IO操作。如果使用TairString的EXCAS命令,可以将两次访问减少为一次,极大地节约系统资源消耗,提升高并发场景下的服务性能。

EXCAS命令可以在调用时携带一个用于校验的version值,如果校验成功则直接更新TairString的value,如果校验失败则返回三个字段:

  • update version is stale
  • value
  • version

更新失败后可以直接得到TairString当前的版本,无需再次查询,将原本每个循环需要进行两次的访问减少到一次。示例如下:

while(true){
    {ret, value, version} = excas(key, new_value, old_version)    // 直接尝试用CAS命令置换value
    if(ret == OK)
       break;    // 如果返回值为OK则更新成功,跳出循环
    else (if ret.contanis("update version is stale"))    // 如果返回值包含"update version is stale"则更新失败,更新两个变量
       update(value);
       old_version = version;
 }