mysql序列号生成_一文看懂mycat的6种全局序列号实现方式

概述

在实现分库分表的情况下,数据库自增主键已无法保证自增主键的全局唯一。为此,MyCat 提供了全局sequence,并且提供了包含本地配置和数据库配置等多种实现方式。下面对这几种实现方式做一下介绍。

0225ef7033a184ddeb0ad28bd63e4d1f.png

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 中配置:

0

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

使用示例:

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

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

优点:本地加载,读取速度较快。


2、数据库方式

原理:

在数据库中建立一张表,存放 sequence 名称(name),sequence 当前值(current_value),步长(incrementint 类型每次读取多少个 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 配置):

1

注: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;– 插入一条 sequenceINSERT INTO MYCAT_SEQUENCE(name,current_value,increment) VALUES (‘GLOBAL’, 100000,100);

2) 创建相关 function

– 获取当前 sequence 的值 (返回当前值,增量)DROP FUNCTION IF EXISTS mycat_seq_currval;DELIMITERCREATE FUNCTION mycat_seq_currval(seq_name VARCHAR(50)) RETURNS varchar(64) CHARSET utf-8DETERMINISTIC BEGINDECLARE 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 值DROP FUNCTION IF EXISTS mycat_seq_setval; DELIMITERCREATE FUNCTION mycat_seq_setval(seq_name VARCHAR(50),value INTEGER) RETURNS varchar(64) CHARSET utf-8DETERMINISTIC BEGINUPDATE MYCAT_SEQUENCESET current_value = value WHERE name = seq_name;RETURN mycat_seq_currval(seq_name); ENDDELIMITER;​– 获取下一个 sequence 值DROP FUNCTION IF EXISTS mycat_seq_nextval; DELIMITERCREATE FUNCTION mycat_seq_nextval(seq_name VARCHAR(50)) RETURNS varchar(64) CHARSET utf-8DETERMINISTIC BEGINUPDATE MYCAT_SEQUENCESET current_value = current_value + increment WHERE name = seq_name; RETURN mycat_seq_currval(seq_name);END DELIMITER;

3)sequence_db_conf.properties 相关配置,指定 sequence 相关配置在哪个节点上:

例如:

USER_SEQ=test_dn1

注意:MYCAT_SEQUENCE 表和以上的 3 个 function,需要放在同一个节点上。function 请直接在具体节点的数据库上执行,如果执行的时候报:

you might want to use the less safe log_bin_trust_function_creators variable

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

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

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

使用示例:

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

2

b. 在 mycat 下配置:sequence_time_conf.properties

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

多个个 mycat 节点下每个 mycat 配置的 WORKID,DATAACENTERID 不同,组成唯一标识,总共支持32*32=1024 种组合。


4、分布式 ZK ID 生成器

3

Zk 的连接信息统一在 myid.properties 的 zkURL 属性中配置。

基于 ZK 与本地配置的分布式 ID 生成器(可以通过 ZK 获取集群(机房)唯一 InstanceID,也可以通过配置文件配置 InstanceID)

ID 结构:long 64 位,ID 最大可占 63 位* |current time millis(微秒时间戳 38 位,可以使用 17 年)|clusterId(机房或者 ZKid,通过配置文件配置 5位)|instanceId(实例 ID,可以通过 ZK 或者配置文件获取,5 位)|threadId(线程 ID,9 位)|increment(自增,6 位)* 一共 63 位,可以承受单机房单机器单线程 1000*(2^6)=640000 的并发。* 无悲观锁,无强竞争,吞吐量更高

配置文件:sequence_distributed_conf.properties,只要配置里面:INSTANCEID=ZK 就是从 ZK 上获取InstanceID。


5、Zk 递增方式

4

Zk 的连接信息统一在 myid.properties 的 zkURL 属性中配置,4 是 zookeeper 实现递增序列号

--配置文件:sequence_conf.properties, 只要配置好 ZK 地址和表名的如下属性* TABLE.MINID 某线程当前区间内最小值* TABLE.MAXID 某线程当前区间内最大值* TABLE.CURID 某线程当前区间内当前值-- 文件配置的 MAXID 以及 MINID 决定每次取得区间,这个对于每个线程或者进程都有效-- 文件中的这三个属性配置只对第一个进程的第一个线程有效,其他线程和进程会动态读取 ZK

6、自增长主键

6.1 MyCAT 自增长主键和返回生成主键 ID 的实现

说明:

1) mysql 本身对非自增长主键,使用 last_insert_id()是不会返回结果的,只会返回 0;

2) mysql只 会对定义自增长主键,可以用last_insert_id() 返 回 主 键 值 ;

MyCAT目前提供了自增长主键功能,但是如果对应的 mysql 节点上数据表,没有定义 auto_increment,那么在 MyCAT 层调用 last_insert_id()也是不会返回结果的。

正确配置方式如下:

1) mysql 定义自增主键

CREATE TABLE table1( 'id_' INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,  'name_' INT(10) UNSIGNED NOT NULL, PRIMARY KEY ('id_') ) ENGINE=MYISAM AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

2) mycat 定义主键自增

b23f51c79455ad639e1cd9949cba166d.png

3) mycat 对应 sequence_db_conf.properties 增加相应设置

TABLE1=dn1

4) 在数据库中 mycat_sequence 表中增加 TABLE1 表的 sequence 记录

测试使用:

127.0.0.1/root:[TESTDB> insert into tt2(name_) values(‘t1’);Query OK, 1 row affected (0.14 sec) 127.0.0.1/root:[TESTDB> select last_insert_id();+——————+| LAST_INSERT_ID() |+——————+| 100 |+——————+​1 row in set (0.01 sec) 127.0.0.1/root:[TESTDB> insert into tt2(name_) values(‘t2’); Query OK, 1 row affected (0.00 sec)  127.0.0.1/root:[TESTDB> select last_insert_id(); +——————+| LAST_INSERT_ID() |+——————+| 101 |+——————+1 row in set (0.00 sec)127.0.0.1/root:[TESTDB> insert into tt2(name_) values(‘t3’);Query OK, 1 row affected (0.00 sec) 127.0.0.1/root:[TESTDB> select last_insert_id();+——————+| LAST_INSERT_ID() |+——————+| 102 |+——————+1 row in set (0.00 sec)

Myibatis 中新增记录后获取 last_insert_id 的示例:

be4188bbe9c3778cea0ae810e4cef6c8.png

觉得有用的朋友多帮忙转发哦!后面会分享更多devops和DBA方面的内容,感兴趣的朋友可以关注下~

948c76feae040be6307d77834eb53f71.gif

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/371036.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

android.graphics.Paint方法setXfermode (Xfermode x...

[java] view plaincopymPaint new Paint(); mPaint.setXfermode(new PorterDuffXfermode(PorterDuff.Mode.SCREEN)); 常见的Xfermode(SRC为原图,DST为目标图),把代码中的SRC_IN换成下图指定的模式就会出现对应的效果图…

从零开始的全栈工程师——html篇1

全栈工程师也可以叫web 前端 H5主要是网站 app 小程序 公众号这一块 HTML篇 html(超文本标记语言,标记通用标记语言下的一个应用。) “超文本”就是指页面内可以包含图片、链接,甚至音乐、程序等非文字元素。 超文本标记语言的结构包括“头”部分&am…

苹果mp3软件_优秀的Apple音乐转换器,将任何iTunes M4P,AAX,AA转换为MP3

Macsome iTunes Converter是一款优秀的音频转换工具,这款音频转换软件能够帮助大家快速进行音频格式转换,使得您可以自由的播放和分享自己喜爱的音频文件。同时这款软件与大多数音频转换软件一样,将受到保护DRM的Apple音乐转换转换成MP3, AAC…

虚幻4毛发系统_虚幻引擎复活!苹果与Epic对决,有哪些游戏险些中枪?

最近,苹果和Epic的官司闹得沸沸扬扬。随着Epic旗下热门手游《堡垒之夜》遭苹果火速下架,两大巨头之间的冲突愈演愈烈。苹果似乎并不满足于此,由于Epic公开违反自家规定,苹果计划进一步封禁Epic维护虚幻引擎的开发者账户&#xff0…

01-JAVA语言基础

1.设计思想: 先以字符串的形式输入两个数字,然后将他们转化为int类型,再对两数进行相加,最后输出结果。 2.程序流程图: 3.源程序代码: import java.util.Scanner;public class Addition2 {public static vo…

php签名墙,肺功能检查质量控制网

2017年12月2日,由中华医学会呼吸病学分会/儿科分会、国家呼吸系统疾病临床医学研究中心、国家呼吸疾病医疗质量控制中心、中国肺功能联盟、中国儿童肺功能协作组主办,浙江省中医院承办的"2017年中国肺功能检查规范化培训及应用推广学习班暨肺功能检…

餐饮水单打印软件_开发一款餐饮手机app系统软件什么价格?有哪些方面需要考虑?...

开发一款餐饮手机app系统软件什么价格?有哪些方面需要考虑?近年来,餐饮类的APP如雨后春笋般快速增长,无论是上档次的酒店,还是各大餐厅,都有各自的专属APP。餐饮APP的开发能让大型酒店/餐厅获得更多盈利、销…

Spring-framework应用程序启动loadtime源码分析笔记(二)——@Transactional

Transactional标识类或方法,使方法被执行时使用事务方式执行,这里只讨论PROXY方法增强方法。使用EnableTransactionManagement,默认modelAdviceMode.PROXY,通过Import(TransactionManagementConfigurationSelector.class)来判断在…

具有Spring的简单工作流引擎

几个月前,在处理一个公司项目时,我们需要开发REST服务,该服务用于根据客户端应用程序发送的数据发送电子邮件。 在开发此服务期间,我们决定创建简单的工作流引擎,该引擎将为发送电子邮件收费,但该引擎也可用…

TypeScript学习笔记归纳(持续更新ing)

文章目录 前言 二、TypeScript的优势体现在哪里? 1、执行时间上的区别 2、基础数据类型区别 3、TS优势 三、TypeScript的关键特性 四、TypeScript的类型系统 1、什么是类型注释? 2、类型系统核心 - 常用类型 1) 基本类型&#xff0…

组态王 6.55 启停plc_永宏PLC在远程控制系统中的应用

一、行业介绍本远程控制系统是给石药集团的下属子公司设计的一个控制方案。主要是配套GPRS-DTU产品实现远程plc与plc之间的数据共享。从而达到远程无线数据写入控制和读取监控的目的。二、客户需求(1) 客户可以在监控室控制至少2-3公里外的井上两个水泵的启动和停止。(2) 客户可…

Vue表格中,对数据进行转换、处理

众所周知,后端从Mysql取出的数据,一般是很难单独处理某一个Key的数据的(需要处理的话,可能会浪费大量的性能。而且对页面加载时间有很大的影响),所以,从数据库取出的数据。只能由前端进行处理。…

Java应用程序中的SQL注入

在本文中,我们将讨论什么是SQL注入攻击。 以及它如何影响任何Web应用程序使用后端数据库。 在这里,我专注于Java Web应用程序。 开放Web应用程序安全项目(OWAP)列出了SQL注入是Web应用程序的主要漏洞攻击。 黑客将Web请求中的SQL代…

bluetooth射频已关闭请打开bluetooth射频_希杰大功率射频放大器烧了维修诊断步骤...

如果电阻值过低,说明电源内部存在短路,正常时其阻值应能达到100千欧以上;电容器应能够充放电,如果损坏,则表现为AC电源线两端阻值低,呈短路状态,否则可能是开关管击穿。然后检查直流输出部分脱开负载&#…

java中整数如何表示,在Java中如何在位级别上内部表示整数?

慕瓜9086354Java整数为32位,并且总是带符号的。这意味着,最高有效位(MSB)用作符号位。用an表示的整数int不过是位的加权和。权重分配如下:Bit# Weight31 -2^3130 2^3029 2^29... ...2 2^21 2^10 …

three.js制作3d模型工具_3D打印模型打磨抛光常用工具

对于追求更好模型品质的人来说,对3D打印模型进行后处理工作是必不可少的,而后处理,首要的便是对模型进行打磨、抛光,将不属于模型的耗材去除,提高表面光洁度。在此工作中,我们需要用到很多工具,…

为何要清除浮动?如何清除?

原因: 元素设置了float属性后,就会脱离文档流,当 包含框 的高度小于 浮动框 的时候,会出现高度塌陷。因此才需要清除浮动! 表现如图:包括框container已经包不住float的图片了! 清除浮动方法&a…

Spring MVC错误处理示例

这篇文章描述了在Spring MVC 3中执行错误处理的不同技术。该代码在GitHub上的Spring-MVC-Error-Handling目录中可用。 它基于带有注释的Spring MVC示例。 在Spring 3之前处理异常 在Spring 3之前,使用HandlerExceptionResolvers处理异常。 此接口定义一个方法&…

php数字取反,[转+自]关于PHP7的新特性(涉及取反和disabled_functions绕过)

PHP7和PHP5上的安全区别preg_replace()不再支持/e修饰符利用\e修饰符执行代码的后门大家也用了不少了,具体看官方的这段描述:如果设置了这个被弃用的修饰符, preg_replace() 在进行了对替换字符串的 后向引用替换之后, 将替换后的字符串作为php 代码评估…

如何关闭苹果手机自动扣费_教你关闭苹果手机系统的自动更新功能,旧手机还能再用几年!...

大家都知道,苹果手机在更新几个大版本后,手机不是变得非常卡,就是非常的耗电,大大的缩短了手机的使用寿命。所以,许多人都不会选择更新系统,但是手机只要连上WiFi并且在充电状态,就会在半夜自动…