增加tingid 分布式ID生成器

Author: chengxy-nds

springboot-sharding-jdbc/pom.xml

@@ -58,6 +58,12 @@
 			<version>1.14</version>
 		</dependency>
 
+		<dependency>
+			<groupId>com.xiaoju.uemc.tinyid</groupId>
+			<artifactId>tinyid-client</artifactId>
+			<version>0.1.0-SNAPSHOT</version>
+		</dependency>
+
 	</dependencies>
 
 	<build>

springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/contoller/TestController.java

@@ -42,7 +42,7 @@ public class TestController {
     @ResponseBody
     public String insertOrder() {
 
-        for (int i = 0; i < 3; i++) {
+        for (int i = 0; i < 5; i++) {
 //            HintManager.clear();
 //            HintManager hintManager = HintManager.getInstance();
 //            hintManager.setDatabaseShardingValue(1);

springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/key/TinyIdShardingKeyGenerator.java

@@ -0,0 +1,45 @@
+package com.xiaofu.sharding.key;
+
+import com.xiaoju.uemc.tinyid.client.utils.TinyId;
+import org.apache.shardingsphere.spi.keygen.ShardingKeyGenerator;
+import org.springframework.stereotype.Component;
+
+import java.util.Properties;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * @Author: xiaofu
+ * @Description: 自定义主键生成器
+ */
+@Component
+public class TinyIdShardingKeyGenerator implements ShardingKeyGenerator {
+
+    /**
+     * 自定义的生成方案类型
+     */
+    @Override
+    public String getType() {
+        return "tinyid";
+    }
+
+    /**
+     * 核心方法-生成主键ID
+     */
+    @Override
+    public Comparable<?> generateKey() {
+
+        Long id = TinyId.nextId("order");
+
+        return id;
+    }
+
+    @Override
+    public Properties getProperties() {
+        return null;
+    }
+
+    @Override
+    public void setProperties(Properties properties) {
+
+    }
+}

springboot-sharding-jdbc/src/main/resources/META-INF/services/org.apache.shardingsphere.spi.keygen.ShardingKeyGenerator

@@ -1 +1,2 @@
 com.xiaofu.sharding.key.MyShardingKeyGenerator
+com.xiaofu.sharding.key.TinyIdShardingKeyGenerator

springboot-sharding-jdbc/src/main/resources/application.properties

@@ -19,21 +19,22 @@ spring.shardingsphere.datasource.ds-1.password=xinzhifu521
 spring.shardingsphere.sharding.tables.t_order.actual-data-nodes=ds-$->{0..1}.t_order_$->{0..2}
 ### 分库策略
 # 分库分片健
-spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.sharding-column=user_id
+spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.sharding-column=order_id
 # 分库分片算法
-spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.algorithm-expression=ds-$->{user_id % 2}
+spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.algorithm-expression=ds-$->{order_id % 2}
 # 分表策略
 # 分表分片健
-spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column=user_id
+spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column=order_id
 # 分表算法
-spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression=t_order_$->{user_id % 3}
+spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression=t_order_$->{order_id % 3}
 # 自增主键字段
 spring.shardingsphere.sharding.tables.t_order.key-generator.column=order_id
 # 自增主键ID 生成方案
-spring.shardingsphere.sharding.tables.t_order.key-generator.type=XXX
+spring.shardingsphere.sharding.tables.t_order.key-generator.type=SNOWFLAKE
 # 工作机器唯一 id
 spring.shardingsphere.sharding.tables.t_order.key-generator.props.worker.id=0000
-
+#
+spring.shardingsphere.sharding.tables.t_order.key-generator.max.tolerate.time.difference.milliseconds=5
 
 # 配置分片表 t_order_item
 spring.shardingsphere.sharding.tables.t_order_item.actual-data-nodes=ds-$->{0..1}.t_order_item_$->{0..2}
@@ -63,3 +64,5 @@ mybatis-plus.map-underscore-to-camel-case=true
 spring.devtools.restart.enabled=true
 
 
+
+

springboot-sharding-jdbc/src/main/resources/tinyid_client.properties

@@ -0,0 +1,5 @@
+# tinyid ·Ö²¼Ê½ID
+# ·þÎñµØÖ·
+tinyid.server=127.0.0.1:9999
+# ÒµÎñtoken
+tinyid.token=0f673adf80504e2eaa552f5d791b644c