详解Spring Boot工程集成全局唯一ID生成器 UidGenerator的操作步骤

<dependencies>

   <dependency>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-starter-web</artifactid>

   </dependency>

   <dependency>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-starter-test</artifactid>

     <scope>test</scope>

   </dependency>

   <dependency>

     <groupid>org.mybatis.spring.boot</groupid>

     <artifactid>mybatis-spring-boot-starter</artifactid>

     <version> 1.3 . 2 </version>

   </dependency>

   <!-- for mysql-->

   <dependency>

     <groupid>mysql</groupid>

     <artifactid>mysql-connector-java</artifactid>

     <scope>runtime</scope>

     <version> 8.0 . 12 </version>

   </dependency>

   <!-- druid -->

   <dependency>

     <groupid>com.alibaba</groupid>

     <artifactid>druid-spring-boot-starter</artifactid>

     <version> 1.1 . 9 </version>

   </dependency>

   <!--必须放在最后-->

   <dependency>

     <groupid>cn.codesheep</groupid>

     <artifactid>uid-generator</artifactid>

     <version> 1.0 </version>

   </dependency>

</dependencies>

server.port= 9999

spring.datasource.url=jdbc:mysql: //xxx.xxx.xxx.xxx:3306/xxx?useunicode=true&characterencoding=utf-8&usessl=false

spring.datasource.username=root

spring.datasource.password=xxx

spring.datasource.driver- class -name=com.mysql.jdbc.driver

mybatis.mapper-locations=classpath:mapper/*.xml

mybatis.configuration.map-underscore-to-camel- case = true

drop table if exists worker_node;

create table worker_node

(

id bigint not null auto_increment comment 'auto increment id' ,

host_name varchar( 64 ) not null comment 'host name' ,

port varchar( 64 ) not null comment 'port' ,

type int not null comment 'node type: actual or container' ,

launch_date date not null comment 'launch date' ,

modified timestamp not null comment 'modified time' ,

created timestamp not null comment 'created time' ,

primary key(id)

)

  comment= 'db workerid assigner for uid generator' ,engine = innodb;

<?xml version= "1.0" encoding= "utf-8" ?>

<beans xmlns= "http://www.springframework.org/schema/beans" xmlns:xsi= "http://www.w3.org/2001/xmlschema-instance"

  xsi:schemalocation="

  http: //www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">

  <!-- uid generator -->

  <bean id= "disposableworkeridassigner" class = "com.baidu.fsg.uid.worker.disposableworkeridassigner" />

  <bean id= "cacheduidgenerator" class = "com.baidu.fsg.uid.impl.cacheduidgenerator" >

  <property name= "workeridassigner" ref= "disposableworkeridassigner" />

  <!-- 以下为可选配置, 如未指定将采用默认值 -->

  <!-- ringbuffer size扩容参数, 可提高uid生成的吞吐量. -->

  <!-- 默认: 3 ， 原buffersize= 8192 , 扩容后buffersize= 8192 << 3 = 65536 -->

  <!--<property name= "boostpower" value= "3" ></property>-->

  <!-- 指定何时向ringbuffer中填充uid, 取值为百分比( 0 , 100 ), 默认为 50 -->

  <!-- 举例: buffersize= 1024 , paddingfactor= 50 -> threshold= 1024 * 50 / 100 = 512 . -->

  <!-- 当环上可用uid数量 < 512 时, 将自动对ringbuffer进行填充补全 -->

  <!--<property name= "paddingfactor" value= "50" ></property>-->

  <!-- 另外一种ringbuffer填充时机, 在schedule线程中, 周期性检查填充 -->

  <!-- 默认:不配置此项, 即不实用schedule线程. 如需使用, 请指定schedule线程时间间隔, 单位:秒 -->

  <!--<property name= "scheduleinterval" value= "60" ></property>-->

  <!-- 拒绝策略: 当环已满, 无法继续填充时 -->

  <!-- 默认无需指定, 将丢弃put操作, 仅日志记录. 如有特殊需求, 请实现rejectedputbufferhandler接口(支持lambda表达式) -->

  <!--<property name= "rejectedputbufferhandler" ref= "xxxxyourputrejectpolicy" ></property>-->

  <!-- 拒绝策略: 当环已空, 无法继续获取时 -->

  <!-- 默认无需指定, 将记录日志, 并抛出uidgenerateexception异常. 如有特殊需求, 请实现rejectedtakebufferhandler接口(支持lambda表达式) -->

  <!--<property name= "rejectedputbufferhandler" ref= "xxxxyourputrejectpolicy" ></property>-->

  </bean>

</beans>

<?xml version= "1.0" encoding= "utf-8" ?>

<!doctype mapper public "-//mybatis.org//dtd mapper 3.0//en" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace= "com.baidu.fsg.uid.worker.dao.workernodedao" >

  <resultmap id= "workernoderes"

    type= "com.baidu.fsg.uid.worker.entity.workernodeentity" >

  <id column= "id" jdbctype= "bigint" property= "id" />

  <result column= "host_name" jdbctype= "varchar" property= "hostname" />

  <result column= "port" jdbctype= "varchar" property= "port" />

  <result column= "type" jdbctype= "integer" property= "type" />

  <result column= "launch_date" jdbctype= "date" property= "launchdate" />

  <result column= "modified" jdbctype= "timestamp" property= "modified" />

  <result column= "created" jdbctype= "timestamp" property= "created" />

  </resultmap>

  <insert id= "addworkernode" usegeneratedkeys= "true" keyproperty= "id"

  parametertype= "com.baidu.fsg.uid.worker.entity.workernodeentity" >

  insert into worker_node

  (host_name,

  port,

  type,

  launch_date,

  modified,

  created)

  values (

  #{hostname},

  #{port},

  #{type},

  #{launchdate},

  now(),

  now())

  </insert>

  <select id= "getworkernodebyhostport" resultmap= "workernoderes" >

  select

  id,

  host_name,

  port,

  type,

  launch_date,

  modified,

  created

  from

  worker_node

  where

  host_name = #{host} and port = #{port}

  </select>

</mapper>

@configuration

@importresource (locations = { "classpath:uid/cached-uid-spring.xml" })

public class uidconfig {

}

@service

public class uidgenservice {

   @resource

   private uidgenerator uidgenerator;

   public long getuid() {

     return uidgenerator.getuid();

   }

}

@restcontroller

public class uidtestcontroller {

   @autowired

   private uidgenservice uidgenservice;

   @getmapping ( "/testuid" )

   public string test() {

     return string.valueof( uidgenservice.getuid() );

   }

}