Browse Source

SnowflakeIdWorker

(cherry picked from commit f7726c166f2813226298b6902ca02daa97560be8)
xiongzhu 4 years ago
parent
commit
7ed3703d39

+ 2 - 0
src/main/java/com/izouma/nineth/config/GeneralProperties.java

@@ -24,4 +24,6 @@ public class GeneralProperties {
     private boolean notifyServer;
     private String  updateActivityStockGroup;
     private String  updateActivityStockTopic;
+    private int     dataCenterId;
+    private int     workerId;
 }

+ 2 - 2
src/main/java/com/izouma/nineth/config/SnowflakeIdWorkerConfig.java

@@ -7,7 +7,7 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class SnowflakeIdWorkerConfig {
     @Bean
-    public SnowflakeIdWorker snowflakeIdWorker() {
-        return new SnowflakeIdWorker(0, 0);
+    public SnowflakeIdWorker snowflakeIdWorker(GeneralProperties generalProperties) {
+        return new SnowflakeIdWorker(generalProperties.getWorkerId(), generalProperties.getDataCenterId());
     }
 }