update reactive support

Author: cooperlyt

.idea/encodings.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.cooperlyt</groupId>
     <artifactId>uid-generator-spring-boot</artifactId>
-    <version>1.0.2-SNAPSHOT</version>
+    <version>1.0.5-SNAPSHOT</version>
     <packaging>pom</packaging>
 
     <name>uid-generator-spring-boot</name>
@@ -43,11 +43,12 @@
 
     <modules>
         <module>uid-generator</module>
-        <module>uid-worker-id-jdbc-spring-boot-starter</module>
+        <module>uid-worker-mybatis-jdbc-spring-boot-starter</module>
         <module>uid-generator-api</module>
-        <module>uid-worker-id-db-provider</module>
         <module>uid-generator-spring-boot-starter</module>
-        <module>uid-worker-id-r2dbc-spring-boot-starter</module>
+        <module>uid-worker-mybatis-r2dbc-spring-boot-starter</module>
+        <module>uid-worker-jpa-r2dbc-spring-boot-starter</module>
+        <module>uid-worker-jap-jdbc-spring-boot-starter</module>
     </modules>
 
     <properties>

.idea/misc.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>io.github.cooperlyt</groupId>
         <artifactId>uid-generator-spring-boot</artifactId>
-        <version>1.0.2-SNAPSHOT</version>
+        <version>1.0.5-SNAPSHOT</version>
     </parent>
 
     <artifactId>uid-generator-api</artifactId>
@@ -17,4 +17,23 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>commons-lang</groupId>
+            <artifactId>commons-lang</artifactId>
+            <version>2.6</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
 </project>

.idea/sqldialects.xml

@@ -8,13 +8,23 @@ public interface UidCachedProperties {
    */
   int getBoostPower();
 
+  void setBoostPower(int value);
+
   /**
    * 指定何时向RingBuffer中填充UID, 取值为百分比(0, 100), 默认为50
    * 举例: bufferSize=1024, paddingFactor=50 -> threshold=1024 * 50 / 100 = 512.
    * 当环上可用UID数量 < 512时, 将自动对RingBuffer进行填充补全
    */
   int getPaddingFactor();
 
+  void setPaddingFactor(int value);
+
+  /**
+   * 另外一种RingBuffer填充时机, 在Schedule线程中, 周期性检查填充
+   * 默认:不配置此项, 即不使用Schedule线程. 如需使用, 请指定Schedule线程时间间隔, 单位:秒
+   */
   Long getScheduleInterval();
 
+  void setScheduleInterval(long value);
+
 }

pom.xml

@@ -17,6 +17,7 @@
 
 
 import io.github.cooperlyt.cloud.uid.exception.UidGenerateException;
+import reactor.core.publisher.Mono;
 
 /**
  * Represents a unique id generator.
@@ -31,7 +32,7 @@ public interface UidGenerator {
      * @return UID
      * @throws UidGenerateException
      */
-    long getUID() throws UidGenerateException;
+    Mono<Long> getUID() throws UidGenerateException;
 
     /**
      * Parse the UID into elements which are used to generate the UID. <br>

uid-generator-api/pom.xml

@@ -2,34 +2,73 @@
 
 public interface UidProperties {
 
-  /**
-   * 时间增量值占用位数。当前时间相对于时间基点的增量值，单位为秒
-   */
+
   int getTimeBits();
 
   /**
-   * 工作机器ID占用的位数
+   * @param timeBits 时间增量值占用位数。当前时间相对于时间基点的增量值，单位为秒
    */
+  void setTimeBits(int timeBits);
+
+
   int getWorkerBits();
 
   /**
-   * 序列号占用的位数
+   * @param value 工作机器ID占用的位数
    */
+  void setWorkerBits(int value);
+
+
   int getSeqBits();
 
   /**
-   * 时间基点. 例如 2019-02-20 (毫秒: 1550592000000)
+   * @param value 序列号占用的位数
    */
+
+  void setSeqBits(int value);
+
+
   long getEpochSeconds();
 
   /**
-   * 是否容忍时钟回拨, 默认:true
+   * 发号起始时间
+   *
+   * @param value
+   * 时间基点. 例如 2019-02-20 (毫秒: 1550592000000)
+   *
+   */
+  void setEpochStr(String value);
+
+
+  long getMaxBackwardSeconds();
+
+  /**
+   * 系统时钟回拨和使用未来时间最长容忍时间（秒）
+   *
+   * @param value
+   *
+   * 设置为0时如果发生系统回拨会抛出异常并无法使用未来时间生成ID
+   *
+   *
    */
-  boolean isEnableBackward();
+  void setMaxBackwardSeconds(long value);
+
+  boolean isEnableFutureTime();
 
   /**
-   * 时钟回拨最长容忍时间（秒）
+   * 当前时间所生成的ID超出最大序列时和时钟回拨时是否允许使用未来时间的序列来生成ID
+   *
+   * 如果ID发号量巨大而经常需要使用到未来时间应当使用 {@link  CachedUidGenerator},
+   * 因持续使用未来时间而得不到回正会引起服务重启后生成重复的ID
+   *
+   * @param enable
+   *
+   * true: 会使用未来时间来生成ID会造成ID中的时间不准确,
+   * 可以使用多少未来时间由 maxBackwardSeconds 控制
+   *
+   * false: 会返回一下 Mono 等待到达当前时间后通知订阅者
+   *
    */
-  long getMaxBackwardSeconds();
+  void setEnableFutureTime(boolean enable);
 
 }