MyCat全局序列之本地时间戳方式

一、简介

上一篇文件主要讲解了在MyCat中如何实现数据库方式的全局序列，除了上面讲过的本地文件方式以及数据库方式，其实还可以使用本地时间戳方式生成全局唯一序列作为主键，本文将总结时间戳方式实现全局序列作为主键。

二、时间戳方式

实现方式：

ID = 64 位二进制 (42(毫秒)+5(机器 ID)+5(业务编码)+12(重复累加) 换算成十进制为 18 位数的 long 类型，每毫秒可以并发 12 位二进制的累加。

三、实现步骤

【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">0905</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">0905</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服务。

<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.1.10:3306" user="root" password="0905"></writeHost></dataHost></mycat:schema>

【e】使用示例：

登录MyCat：

mysql -uroot -p0905 -h192.168.1.10 -P8066

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') ;

四、总结

使用时间戳方式的话，整体步骤总结如下：

server.xml指定时间戳方式生成序列方式；
schema.xml中配置分片表，注意分片表的主键为自增长，分片表的主键类型不能为int类型；
配置sequence_time_conf.properties；
使用 next value for MYCATSEQ_GLOBAL 获取全局序列；

至此，已经总结了三种方式（本地文件方式、数据库方式、本地时间戳方式）实现MyCat全局唯一主键，三种方式都有优点和缺点，总结如下：

1. 本地文件方式
缺点：在MyCat重启(或者MyCat所在主机发生宕机时)后，配置文件中sequence会恢复到初始值，造成下次操作序列重复。
优点：本地加载，读取速度较快2. 数据库方式
优点：在MyCat重启后，sequence值不会被初始化
缺点：如果存取sequence的数据库挂了，会遇到单点故障3. 本地时间戳方式
优点：不存在上面两种方式因为MyCat的重启导致id重复的现象
缺点：数据类型太长，建议采用bigint(最大取值18446744073709551615)

除了这三种方式， MyCat还集成了ZK实现全局唯一主键，到时候总结ZK的时候会进行研究。