生產(chǎn)系統(tǒng)隨著業(yè)務(wù)增長(zhǎng)總會(huì)經(jīng)歷一個(gè)業(yè)務(wù)量由小變大的過(guò)程，可擴(kuò)展性是考量數(shù)據(jù)庫(kù)系統(tǒng)高可用性的一個(gè)重要指標(biāo);在單表/數(shù)據(jù)庫(kù)數(shù)據(jù)量過(guò)大，更新量不斷飆漲時(shí)，MySQL DBA往往會(huì)對(duì)業(yè)務(wù)系統(tǒng)提出sharding的方案。既然要sharding，那么不可避免的要討論到sharding key問(wèn)題，在有些業(yè)務(wù)系統(tǒng)中，必須保證sharding key全局唯一,比如存放商品的數(shù)據(jù)庫(kù)等，那么如何生成全局唯一的ID呢，下文將從DBA的角度介紹幾種常見(jiàn)的方案。

1、使用CAS思想

什么是CAS協(xié)議

Memcached于1.2.4版本新增CAS(Check and Set)協(xié)議類同于Java并發(fā)的CAS(Compare and Swap)原子操作，處理同一item被多個(gè)線程更改過(guò)程的并發(fā)問(wèn)題

CAS的基本原理

基本原理非常簡(jiǎn)單，一言以蔽之，就是“版本號(hào)”，每個(gè)存儲(chǔ)的數(shù)據(jù)對(duì)象，都有一個(gè)版本號(hào)。

我們可以從下面的例子來(lái)理解：

不采用CAS，則有如下的情景：

 •第一步，A取出數(shù)據(jù)對(duì)象X；
 •第二步，B取出數(shù)據(jù)對(duì)象X；
 •第三步，B修改數(shù)據(jù)對(duì)象X，并將其放入緩存；
 •第四步，A修改數(shù)據(jù)對(duì)象X，并將其放入緩存。

結(jié)論：第四步中會(huì)產(chǎn)生數(shù)據(jù)寫(xiě)入沖突。

采用CAS協(xié)議，則是如下的情景。

 •第一步，A取出數(shù)據(jù)對(duì)象X，并獲取到CAS-ID1；

•第二步，B取出數(shù)據(jù)對(duì)象X，并獲取到CAS-ID2； 

•第三步，B修改數(shù)據(jù)對(duì)象X，在寫(xiě)入緩存前，檢查CAS-ID與緩存空間中該數(shù)據(jù)的CAS-ID是否一致。結(jié)果是“一致”，就將修改后的帶有CAS-ID2的X寫(xiě)入到緩存。

 •第四步，A修改數(shù)據(jù)對(duì)象Y，在寫(xiě)入緩存前，檢查CAS-ID與緩存空間中該數(shù)據(jù)的CAS-ID是否一致。結(jié)果是“不一致”，則拒絕寫(xiě)入，返回存儲(chǔ)失敗。

這樣CAS協(xié)議就用了“版本號(hào)”的思想，解決了沖突問(wèn)題。（樂(lè)觀鎖概念）

其實(shí)這里并不是嚴(yán)格的CAS，而是使用了比較交換原子操作的思想。

生成思路如下：每次生成全局id時(shí)，先從sequence表中獲取當(dāng)前的全局最大id。然后在獲取的全局id上做加1操作，加1后的值更新到數(shù)據(jù)庫(kù)，如加1后的值為203,表名是users，數(shù)據(jù)表結(jié)構(gòu)如下：

CREATE TABLE `SEQUENCE` (
  `name` varchar(30) NOT NULL COMMENT '分表的表名',
  `gid` bigint(20) NOT NULL COMMENT '最大全局id',
  PRIMARY KEY (`name`)
) ENGINE=innodb 

sql語(yǔ)句

update sequence set gid = 203 where name = 'users' and gid < 203; 

sql語(yǔ)句的 and gid < 203 是為了保證并發(fā)環(huán)境下gid的值只增不減。

如果update語(yǔ)句的影響記錄條數(shù)為0說(shuō)明，已經(jīng)有其他進(jìn)程提前生成了203這個(gè)值，并寫(xiě)入了數(shù)據(jù)庫(kù)。需要重復(fù)以上步驟從新生成。

代碼實(shí)現(xiàn)如下：

//$name 表名
function next_id_db($name){
  //獲取數(shù)據(jù)庫(kù)全局sequence對(duì)象
  $seq_dao = Wk_Sequence_Dao_Sequence::getInstance();
  $threshold = 100; //最大嘗試次數(shù)
  for($i = 0; $i < $threshold; $i++){
    $last_id = $seq_dao->get_seq_id($name);//從數(shù)據(jù)庫(kù)獲取全局id
    $id = $last_id +1;
    $ret = $seq_dao->set_seq_id($name, $id);
    if($ret){
      return $id;
      break;
    }
  }
  return false;
}

2、使用全局鎖

在進(jìn)行并發(fā)編程時(shí)，一般都會(huì)使用鎖機(jī)制。其實(shí)，全局id的生成也是解決并發(fā)問(wèn)題。

生成思路如下：

在使用redis的setnx方法和memcace的add方法時(shí)，如果指定的key已經(jīng)存在，則返回false。利用這個(gè)特性，實(shí)現(xiàn)全局鎖

每次生成全局id前，先檢測(cè)指定的key是否存在，如果不存在則使用redis的incr方法或者memcache的increment進(jìn)行加1操作。這兩個(gè)方法的返回值是加1后的值，如果存在，則程序進(jìn)入循環(huán)等待狀態(tài)。循環(huán)過(guò)程中不斷檢測(cè)key是否還存在，如果key不存在就執(zhí)行上面的操作。

代碼如下：

//使用redis實(shí)現(xiàn)
//$name 為 邏輯表名
function next_id_redis($name){
  $redis = Wk_Redis_Util::getRedis();//獲取redis對(duì)象
  $seq_dao = Wk_Sequence_Dao_Sequence::getInstance();//獲取存儲(chǔ)全局id數(shù)據(jù)表對(duì)象
  if(!is_object($redis)){
    throw new Exception("fail to create redis object");
  }
  $max_times = 10; //最大執(zhí)行次數(shù) 避免redis不可用的時(shí)候 進(jìn)入死循環(huán)
  while(1){
    $i++;
    //檢測(cè)key是否存在，相當(dāng)于檢測(cè)鎖是否存在
    $ret = $redis->setnx("sequence_{$name}_flag",time());
    if($ret){
      break;
    }
    if($i > $max_times){
      break;
    }
    $time = $redis->get("sequence_{$name}_flag");
    if(is_numeric($time) && time() - $time > 1){//如果循環(huán)等待時(shí)間大于1秒，則不再等待。
      break;
    }
  }
  $id = $redis->incr("sequence_{$name}");
  //如果操作失敗，則從sequence表中獲取全局id并加載到redis
  if (intval($id) === 1 or $id === false) {
    $last_id = $seq_dao->get_seq_id($name);//從數(shù)據(jù)庫(kù)獲取全局id
    if(!is_numeric($last_id)){
      throw new Exception("fail to get id from db");
    }
    $ret = $redis->set("sequence_{$name}",$last_id);
    if($ret == false){
      throw new Exception("fail to set redis key [ sequence_{$name} ]");
    }
    $id = $redis->incr("sequence_{$name}");
    if(!is_numeric($id)){
      throw new Exception("fail to incr redis key [ sequence_{$name} ]");
    }
  }
  $seq_dao->set_seq_id($name, $id);//把生成的全局id寫(xiě)入數(shù)據(jù)表sequence
  $redis->delete("sequence_{$name}_flag");//刪除key，相當(dāng)于釋放鎖
  $db = null;
  return $id;
} 

3、redis和db結(jié)合

使用redis直接操作內(nèi)存，可能性能會(huì)好些。但是如果redis死掉后，如何處理呢？把以上兩種方案結(jié)合，提供更好的穩(wěn)定性。
代碼如下：

function next_id($name){
  try{
    return $this->next_id_redis($name);
  }
  catch(Exception $e){
    return $this->next_id_db($name);
  }
} 

4、Flicker的解決方案

因?yàn)閙ysql本身支持auto_increment操作，很自然地，我們會(huì)想到借助這個(gè)特性來(lái)實(shí)現(xiàn)這個(gè)功能。Flicker在解決全局ID生成方案里就采用了MySQL自增長(zhǎng)ID的機(jī)制（auto_increment + replace into + MyISAM）。一個(gè)生成64位ID方案具體就是這樣的：
先創(chuàng)建單獨(dú)的數(shù)據(jù)庫(kù)(eg:ticket)，然后創(chuàng)建一個(gè)表：

CREATE TABLE Tickets64 (
      id bigint(20) unsigned NOT NULL auto_increment,
      stub char(1) NOT NULL default '',
      PRIMARY KEY (id),
      UNIQUE KEY stub (stub)
  ) ENGINE=MyISAM 

當(dāng)我們插入記錄后，執(zhí)行SELECT * from Tickets64，查詢結(jié)果就是這樣的：

+-------------------+------+
| id                | stub |
+-------------------+------+
| 72157623227190423 |    a |
+-------------------+------+

在我們的應(yīng)用端需要做下面這兩個(gè)操作，在一個(gè)事務(wù)會(huì)話里提交：

REPLACE INTO Tickets64 (stub) VALUES ('a');
SELECT LAST_INSERT_ID(); 

這樣我們就能拿到不斷增長(zhǎng)且不重復(fù)的ID了。
到上面為止，我們只是在單臺(tái)數(shù)據(jù)庫(kù)上生成ID，從高可用角度考慮，
接下來(lái)就要解決單點(diǎn)故障問(wèn)題：Flicker啟用了兩臺(tái)數(shù)據(jù)庫(kù)服務(wù)器來(lái)生成ID，
通過(guò)區(qū)分auto_increment的起始值和步長(zhǎng)來(lái)生成奇偶數(shù)的ID。

TicketServer1:
auto-increment-increment = 2
auto-increment-offset = 1
TicketServer2:
auto-increment-increment = 2
auto-increment-offset = 2 

最后，在客戶端只需要通過(guò)輪詢方式取ID就可以了。

 •優(yōu)點(diǎn)：充分借助數(shù)據(jù)庫(kù)的自增ID機(jī)制，提供高可靠性，生成的ID有序。

 •缺點(diǎn)：占用兩個(gè)獨(dú)立的MySQL實(shí)例，有些浪費(fèi)資源，成本較高。

以上內(nèi)容是小編給大家分享的Mysql全局ID生成方法，希望大家喜歡。