2.2.4 分布式offset-step方式

分布式offset-step方式利用zookeeper的分布式锁功能进行实现。

线程在获取序列值时执行如下步骤:

  1. 根据序列名(`schemaX`.`tableX`)获取相应的分布式锁。

  2. 从zookeeper服务器上获取未用序列值的最小值min。

  3. 根据配置(参见1.7.4 分布式offset-step序列),计算能获取的最大未用序列值max。

  4. 用max+1更新zookeeper服务器上的未用序列值的最小值min。

  5. 释放相应的分布式锁。

results matching ""

    No results matching ""