MyCat專題(九)-MyCat全局序列之本地時間戳方式

1.簡介

上一篇檔案主要講解了在MyCat中如何實作資料庫方式的全局序列，除了上面講過的本地檔案方式以及資料庫方式，其實還可以使用本地時間戳方式生成全局唯一序列作為主鍵，本文将總結時間戳方式實作全局序列作為主鍵。

2.時間戳方式

實作方式：

ID = 64 位二進制 [42(毫秒)+5(機器 ID)+5(業務編碼)+12(重複累加) ]換算成十進制為 18 位數的 long 類型，每毫秒可以并發12 位二進制的累加。

3.實作步驟

【a】建立資料庫和表：

注意點：使用時間戳的方式實作全局唯一主鍵的話，主鍵的類型要是bigint，如果使用int類型的話長度不夠，可能會報錯。

create database testtimeseq1;
create database testtimeseq2;
 
use testtimeseq1;
create table test(id bigint auto_increment primary key,xm varchar(32));
 
 
use testtimeseq2;
create table test(id bigint auto_increment primary key,xm varchar(32));      

【b】配置 server.xml : sequnceHandlerType 需要配置為 2，指定全局序列方式為本地時間戳方式。

<system><property name="sequnceHandlerType">2</property></system>      

具體代碼：

<?xml version="1.0" encoding="UTF-8"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the "License"); 
  - you may not use this file except in compliance with the License. - You 
  may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 
  - - Unless required by applicable law or agreed to in writing, software - 
  distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT 
  WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the 
  License for the specific language governing permissions and - limitations 
  under the License. -->
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
  <system>
  <property name="useSqlStat">0</property>  <!-- 1為開啟實時統計、0為關閉 -->
  <property name="useGlobleTableCheck">0</property>  <!-- 1為開啟全加班一緻性檢測、0為關閉 -->
 
    <property name="sequnceHandlerType">2</property>
      <!--  <property name="useCompression">1</property>--> <!--1為開啟mysql壓縮協定-->
        <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--設定模拟的MySQL版本号-->
  <!-- <property name="processorBufferChunk">40960</property> -->
  <!-- 
  <property name="processors">1</property> 
  <property name="processorExecutor">32</property> 
   -->
    <!--預設為type 0: DirectByteBufferPool | type 1 ByteBufferArena-->
    <property name="processorBufferPoolType">0</property>
    <!--預設是65535 64K 用于sql解析時最大文本長度 -->
    <!--<property name="maxStringLiteralLength">65535</property>-->
    <!--<property name="sequnceHandlerType">0</property>-->
    <!--<property name="backSocketNoDelay">1</property>-->
    <!--<property name="frontSocketNoDelay">1</property>-->
    <!--<property name="processorExecutor">16</property>-->
    <!--
      <property name="serverPort">8066</property> <property name="managerPort">9066</property> 
      <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> 
      <property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> -->
    <!--分布式事務開關，0為不過濾分布式事務，1為過濾分布式事務（如果分布式事務内隻涉及全局表，則不過濾），2為不過濾分布式事務,但是記錄分布式事務日志-->
    <property name="handleDistributedTransactions">0</property>
    
      <!--
      off heap for merge/order/group/limit      1開啟   0關閉
    -->
    <property name="useOffHeapForMerge">1</property>
 
    <!--
      機關為m
    -->
    <property name="memoryPageSize">1m</property>
 
    <!--
      機關為k
    -->
    <property name="spillsFileBufferSize">1k</property>
 
    <property name="useStreamOutput">0</property>
 
    <!--
      機關為m
    -->
    <property name="systemReserveMemorySize">384m</property>
 
 
    <!--是否采用zookeeper協調切換  -->
    <property name="useZKSwitch">true</property>
 
 
  </system>
  
  <!-- 全局SQL防火牆設定 -->
  <!-- 
  <firewall> 
     <whitehost>
        <host host="127.0.0.1" user="mycat"/>
        <host host="127.0.0.2" user="mycat"/>
     </whitehost>
       <blacklist check="false">
       </blacklist>
  </firewall>
  -->
  
  <user name="root">
    <property name="password">123456</property>
    <property name="schemas">TESTTIME</property>
    
    <!-- 表級 DML 權限設定 -->
    <!--    
    <privileges check="false">
      <schema name="TESTDB" dml="0110" >
        <table name="tb01" dml="0000"></table>
        <table name="tb02" dml="1111"></table>
      </schema>
    </privileges>   
     -->
  </user>
 
  <user name="user">
    <property name="password">123456</property>
    <property name="schemas">TESTTIME</property>
    <property name="readOnly">true</property>
  </user>
 
</mycat:server>      

【c】配置sequence_time_conf.properties：

WORKID=0-31 任意整數
DATAACENTERID=0-31 任意整數      

多個mycat 節點下每個 mycat 配置的 WORKID，DATAACENTERID 不同，組成唯一辨別，總共支援 32*32=1024 種組合。

#sequence depend on TIME
WORKID=05
DATAACENTERID=05      

【d】schema.xml 的對應邏輯表位置配置 autoIncrement="true"指定主鍵自增, 然後重新開機mycat服務。

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
 
        <schema name="TESTTIME" checkSQLschema="false" sqlMaxLimit="100">
                <table name="test" dataNode="dn1,dn2" primaryKey="id" autoIncrement="true" rule="mod-long" />
        </schema>
 
        <dataNode name="dn1" dataHost="localhost1" database="testtimeseq1" />
        <dataNode name="dn2" dataHost="localhost1" database="testtimeseq2" />
        
        <dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>
                <!-- can have multi write hosts -->
                <writeHost host="hostM1" url="192.168.70.128:3306" user="root" password="123">
                </writeHost>
        </dataHost>
 
</mycat:schema>      

rule.xml

<function name="mod-long" class="io.mycat.route.function.PartitionByMod">
  <!-- how many data nodes -->
  <property name="count">2</property>
</function>      

【e】使用示例：

登入MyCat：

select next value for MYCATSEQ_GLOBAL;      

插入資料進行測試：

insert into test(xm) values ("zhangsan");      

insert into test(id,xm) values(next value for MYCATSEQ_GLOBAL，'lisi') ; 
 
insert into test(id,xm) values(next value for MYCATSEQ_GLOBAL，'lisi') ;      

4.總結

使用時間戳方式的話，整體步驟總結如下：

1. 本地檔案方式
缺點：在MyCat重新開機(或者MyCat所在主機發生當機時)後，配置檔案中sequence會恢複到初始值，造成下次操作序列重複。
優點：本地加載，讀取速度較快
 
2. 資料庫方式
優點：在MyCat重新開機後，sequence值不會被初始化
缺點：如果存取sequence的資料庫挂了，會遇到單點故障
 
3. 本地時間戳方式
優點：不存在上面兩種方式因為MyCat的重新開機導緻id重複的現象
缺點：資料類型太長，建議采用bigint(最大取值18446744073709551615)