11、Mycat实战：全局序列号实现-程序员快看-教程，程序员编程资料站

文章目录

14.全局序列号
- 1.本地文件方式
1. 数据库方式
- 原理
- Sequence 获取步骤：
- - 1. 创建 MYCAT_SEQUENCE 表
  - 1. 创建相关 function
  - 1. 设置序列初始值
  - 1. sequence_db_conf.properties
  - 1. 修改server.xml
  - 1. 使用示例：
3.本地时间戳方式

14.全局序列号

在实现分库分表的情况下，数据库自增主键已无法保证自增主键的全局唯一。为此，MyCat 提供了全局

sequence，并且提供了包含本地配置和数据库配置等多种实现方式。

1.本地文件方式

**原理：**此方式 MyCAT 将 sequence 配置到文件中，当使用到 sequence 中的配置后，MyCAT 会更下

classpath 中的 sequence_conf.properties 文件中 sequence 当前的值。

配置方式：

在sequence_conf.properties 文件中做如下配置：

GLOBAL_SEQ.HISIDS=

GLOBAL_SEQ.MINID=1001

GLOBAL_SEQ.MAXID=1000000000

GLOBAL_SEQ.CURID=1000

其中HISIDS 表示使用过的历史分段(一般无特殊需要可不配置)，MINID 表示最小 ID 值，MAXID 表示最大

ID值，CURID 表示当前 ID 值。

server.xml 中配置：

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

注：sequnceHandlerType 需要配置为 0，表示使用本地文件方式。

使用示例：

insert into table1(id,name) values(next value for MYCATSEQ_GLOBAL,‘test’);

缺点：当 MyCAT 重新发布后，配置文件中的 sequence 会恢复到初始值。

优点：本地加载，读取速度较快。

2. 数据库方式

原理

在数据库中建立一张表，存放 sequence 名称(name)，sequence 当前值(current_value)，步长(increment

int类型每次读取多少个 sequence，假设为 K)等信息；

Sequence 获取步骤：

1).当初次使用该 sequence 时，根据传入的 sequence 名称，从数据库这张表中读取 current_value，和

increment 到 MyCat 中，并将数据库中的 current_value 设置为原 current_value 值+increment 值。

.MyCat 将读取到 current_value+increment 作为本次要使用的 sequence 值，下次使用时，自动加 1，当

使用increment 次后，执行步骤 1)相同的操作。

MyCat 负责维护这张表，用到哪些 sequence，只需要在这张表中插入一条记录即可。若某次读取的

sequence 没有用完，系统就停掉了，则这次读取的 sequence 剩余值不会再使用。

配置方式：

server.xml 配置：

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

注：sequnceHandlerType 需要配置为 1，表示使用数据库方式生成 sequence。

数据库配置：

1) 创建 MYCAT_SEQUENCE 表

–创建存放 sequence 的表

DROP TABLE IF EXISTS MYCAT_SEQUENCE;

–name sequence 名称

–current_value 当前 value

–increment 增长步长! 可理解为 mycat 在数据库中一次读取多少个 sequence. 当这些用完后, 下次再从数

据库中读取。

CREATE TABLE MYCAT_SEQUENCE (
    name VARCHAR(50) NOT NULL,
    current_value INT NOT NULL,
    increment INT NOT NULL DEFAULT 100,
    PRIMARY KEY(name)
) ENGINE=InnoDB;

–插入一条 sequence (全局)

INSERT INTO MYCAT_SEQUENCE(name,current_value,increment) VALUES ('GLOBAL', 100000,100);

2) 创建相关 function

获取当前 sequence 的值 (返回当前值,增量)

DELIMITER $$

CREATE FUNCTION mycat_seq_currval (seq_name VARCHAR (50)) RETURNS VARCHAR (64) DETERMINISTIC 
BEGIN
  DECLARE retval VARCHAR (64) ;
  SET retval = "-999999999,null" ;
  SELECT 
    CONCAT(
      CAST(current_value AS CHAR),
      ",",
      CAST(increment AS CHAR)
    ) INTO retval 
  FROM
    MYCAT_SEQUENCE 
  WHERE NAME = seq_name ;
  RETURN retval ;
END $$

DELIMITER ;

–设置 sequence 值

DELIMITER $$

CREATE FUNCTION mycat_seq_setval (seq_name VARCHAR (50), VALUE INTEGER) RETURNS VARCHAR (64) DETERMINISTIC 
BEGIN
  UPDATE 
    MYCAT_SEQUENCE 
  SET
    current_value = VALUE 
  WHERE NAME = seq_name ;
  RETURN mycat_seq_currval (seq_name) ;
END $$

DELIMITER ;

–获取下一个 sequence 值

DELIMITER $$

CREATE FUNCTION mycat_seq_nextval (seq_name VARCHAR (50)) RETURNS VARCHAR (64) DETERMINISTIC 
BEGIN
  UPDATE 
    MYCAT_SEQUENCE 
  SET
    current_value = current_value + increment 
  WHERE NAME = seq_name ;
  RETURN mycat_seq_currval (seq_name) ;
END $$

DELIMITER ;

3) 设置序列初始值

INSERT INTO MYCAT_SEQUENCE(NAME,current_value,increment) VALUES ('REGISTER', 400000,
100);

4) sequence_db_conf.properties

相关配置,指定 sequence 相关配置在哪个节点上：

例如：

#sequence stored in datanode
GLOBAL=dn1
REGISTER=dn1

注意：MYCAT_SEQUENCE 表和以上的 3 个 function，需要放在同一个节点上。function 请直接在具体节

点的数据库上执行，如果执行的时候报：

youmight want to use the less safe log_bin_trust_function_creators variable

需要对数据库做如下设置：

windows 下 my.ini[mysqld]加上 log_bin_trust_function_creators=1

linux 下/etc/my.cnf 下 my.ini[mysqld]加上 log_bin_trust_function_creators=1

修改完后，即可在 mysql 数据库中执行上面的函数。

5) 修改server.xml

修改sequnceHandlerType为1

全局序列类型：0-本地文件，1-数据库方式，2-时间戳方式。此处应该修改成1

<property name="sequnceHandlerType">1</property>

6) 使用示例：

在需要序列号的字段位置使用NEXT VALUE FOR MYCATSEQ_REGISTER进行站位，其中REGISTER即为MYCAT_SEQUENCE序号表中的name

insert into table1(id,name) values(next value for MYCATSEQ_GLOBAL,‘test’)；

3.本地时间戳方式

ID=64 位二进制 (42(毫秒)+5(机器 ID)+5(业务编码)+12(重复累加)

换算成十进制为 18 位数的 long 类型，每毫秒可以并发 12 位二进制的累加。

使用方式：

a. 配置 server.xml

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

b. 在 mycat 下配置：sequence_time_conf.properties

WORKID=0-31 任意整数

DATAACENTERID=0-31 任意整数

多个个mycat 节点下每个 mycat 配置的 WORKID，DATAACENTERID 不同，组成唯一标识，总共支持

32*32=1024 种组合。

ID示例：56763083475511

关注“指尖架构师”公众号，获取更多资讯