SpringBoot集成yitter

目录

场景

yitte童话歌词r-idgenerator 是基于雪花算法进行改造的分布式id自增算法，集成时需要为每个服务设置唯一的机器号，才能保证生成的id不会重复

实现方案

基于服务启动时指定唯一机器号

在程序服务启动时通过分布式锁 redisson（基于redis实现），对每台机器通过ip 对应一个 唯一的机器号（自增）映射，并保存在redis中。缓存一次后，下次启动直接读取缓存即可

基于注册中心指定唯一机器号

从注册中心读取服务，增加多一个机器号服务来统一分配

基于第一种实现方案

maven依赖

       <dependency>            <groupid>org.redisson</groupid>            <artifactid>redisson-spring-boot-starter</artifactid>            <version>3.10还是夫妻插曲.6</version>        </dependency> <dependency>    <groupid>cn.hutool</groupid>    <artifactid>hutool-core</artifactid>    <version>5.7.19</version></dependency>        <dependency>            <groupid>com.github.yitter</groupid>            <artifactid>yitter-idgenerator</artifactid>            <version>1.0.6</version>        </dependency>

关键部分代码

/** * redisson分布式锁工具类 */@componentpublic class redissonutil {    @autowired    private redissonclient redissonclient;    /**     * 加锁     * @param lockkey     * @return     */    public rlock lock(string lockkey) {        rlock lock = redissonclient.getlock(lockkey);        lock.lock();        return lock;    }    /**     * 带超时的锁     * @param lockkey     * @param timeout 超时时间 单位：秒     */    public rlock lock(string lockkey, long timeout) {        rlock lock = redissonclient.getlock(lockkey);        lock.lock(timeout, timeunit.conds);        return lock;    }    /**     * 带超时的锁     * @param lockkey     * @param unit 时间单位     * @param timeout 超时时间     */    public rlock lock(string lockkey, timeunit unit ,long timeout) {        rlock lock = redissonclient.getlock(lockkey);     成都市幼儿园   lock.lock(timeout, unit);        return lock;    }    /**     * 尝试获取锁     * @param lockkey     * @param waittime 最多等待时间     * @param unit timeunit时间单位     * @return     */    public  boolean trylock(string lockkey,long waittime, timeunit unit) {   多媒体信息     rlock lock = redissonclient.getlock(lockkey);        try {            return lock.trylock(waittime, unit);        } catch (interruptedexception e) {            return fal;        }    }    /**     * 尝试获取锁     * @param lockkey     * @param waittime 最多等待时间     * @param leatime 上锁后自动释放锁时间     * @return     */    public  boolean trylock(string lockkey, long waittime, long leatime) {        rlock lock = redissonclient.getlock(lockkey);        try {            return lock.trylock(waittime, leatime, timeunit.conds);        } catch (interruptedexception e) {            return fal;        }    }    /**     * 尝试获取锁     * @param lockkey     * @param unit 时间单位     * @param waittime 最多等待时间     * @param leatime 上锁后自动释放锁时间     * @return     */    public boolean trylock(string lockkey, timeunit unit, long waittime, long leatime) {        rlock lock = redissonclient.getlock(lockkey);        try {            return lock.trylock(waittime, leatime, unit);        } catch (interruptedexception e) {            return fal;        }    }    /**     * 释放锁     * @param lockkey     */    public void unlock(string lockkey) {        rlock lock = redissonclient.getlock(lockkey);        lock.unlock();    }    /**     * 若没用锁情况下，就不调用释放锁的代码，若有锁情况下才调用释放锁     * @param lockkey     */    publi教育漫话c void unlockignore(string lockkey) {        rlock lock = redissonclient.getlock(lockkey);        if ( !lock.islocked() ) {           return ;        }        lock.unlock();    }    /**     * 释放锁     * @param lock     */    public void unlock(rlock lock) {        lock.unlock();    }}

启动配置代码如下

 @slf4j@component@order(0)public class systeminitconfig implements commandlinerunner {    @autowired    private redissonutil redissonutil;    @autowired    private redistemplate redistemplate;    /**     * 分布式锁key     */    private static final string cache_id_generator = "lock_id_generator";    /**     * 最大机器号key     */    private static final string cache_workerid_maxid= "cache_workerid_maxid";    /**     * 已分配的机器号key     */    private static final string cache_id_ip = "cache_id_ip";    @override    public void run(string... args) throws exception {        //获取mac地址        string macaddress = netutil.getlocalhost().gethostaddress();        log.info("{} 配置分布式id work缓存========开始",macaddress);        boolean existworkerid =  redistemplate.opsforhash().haskey(cache_id_ip, macaddress);        //若已缓存在缓存中，直接跳过不设置        if (existworkerid) {            log.info("{} 已配置分布式id work...",macaddress);            return ;        }        try {            //分布式锁等待120秒，执行时长最大120秒            boolean  locked = redissonutil.trylock(cache_id_generator, 120, 120);            if (!locked) {                throw new runtimeexception(macaddress+"设置分布式id机器号失败");            }            valueoperations <string,integer> stringoperation = redistemplate.opsforvalue();            boolean initworkerid = stringoperation.tifabnt(cache_workerid_maxid, 1);            if( !initworkerid ) {                //若已存在key，对最大的机器号自增1                stringoperation.increment(cache_workerid_maxid);            }            integer workerid =   stringoperation.get(cache_workerid_maxid);            idgeneratoroptions options = new idgeneratoroptions( workerid.shortvalue());            yitidhelper.tidgenerator(options);            //设置mac地址 - workerid 到hash结构            redistemplate.opsforhash().put(cache_id_ip,macaddress,workerid);            log.info("已配置分布式id work,{} - {}",macaddress,workerid);        } finally {            redissonutil.unlock(cache_id_generator);            log.info("{} 配置分布式id work缓存========结束",macaddress);        }    }}

直接在代码使用即可

yitidhelper.nextid() 

到此这篇关于springboot集成yitter-idgenerator(雪花漂移)分布式id自增的实现的文章就介绍到这了,更多相关springboot 分布式id自增内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！