電子發(fā)燒友網(wǎng)>電子資料下載>電子資料>Simba-Distributed-Mutex分布式鎖服務(wù)

Simba-Distributed-Mutex分布式鎖服務(wù)

2512922 2022-06-14 | zip | 0.26 MB | 次下載 | 2積分

普通下載普通下載

資料介紹

授權(quán)協(xié)議 Apache

開發(fā)語言 Java

操作系統(tǒng) 跨平臺

軟件類型開源軟件

所屬分類服務(wù)器軟件、分布式應(yīng)用/網(wǎng)格

軟件簡介

Simba 旨在提供易用、靈活的分布式鎖服務(wù)，支持多種存儲后端實現(xiàn)：關(guān)系型數(shù)據(jù)庫、Redis、Zookeeper。

安裝

Gradle

Kotlin DSL

    val simbaVersion = "0.3.2";
    implementation("me.ahoo.simba:simba-spring-boot-starter:${simbaVersion}")

Maven



 xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    4.0.0
    demo
    
        0.3.2
    

    
        
            me.ahoo.simba
            simba-spring-boot-starter
            ${simba.version}

application.yaml

simba:
  jdbc:
    enabled: true
#  redis:
#    enabled: true

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/simba_db
    username: root
    password: root

Optional-1: JdbcMutexContendService

Kotlin DSL

    val simbaVersion = "0.3.2";
    implementation("me.ahoo.simba:simba-jdbc:${simbaVersion}")

create table simba_mutex
(
    mutex             varchar(66)     not null primary key comment 'mutex name',
    acquired_at       bigint unsigned not null,
    ttl_at         bigint unsigned not null,
    transition_at bigint unsigned not null,
    owner_id          char(32)        not null,
    version           int unsigned    not null
);

Optional-2: RedisMutexContendService

Kotlin DSL

    val simbaVersion = "0.3.2";
    implementation("me.ahoo.simba:simba-redis:${simbaVersion}")

Optional-3: ZookeeperMutexContendService

Kotlin DSL

    val simbaVersion = "0.3.2";
    implementation("me.ahoo.simba:simba-zookeeper:${simbaVersion}")

Examples

Simba-Examples

使用入門

MutexContender

        MutexContendService contendService = contendServiceFactory.createMutexContendService(new AbstractMutexContender(mutex) {
            @Override
            public void onAcquired(MutexState mutexState) {
                    log.info("onAcquired");
            }
            
            @Override
            public void onReleased(MutexState mutexState) {
                    log.info("onReleased");
            }
        });
        contendService.start();

SimbaLocker

        try (Locker locker = new SimbaLocker("mutex-locker", this.mutexContendServiceFactory)) {
            locker.acquire(Duration.ofSeconds(1));
        /**
         * doSomething
         */
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }

Scheduler

public class ExampleScheduler extends AbstractScheduler implements SmartLifecycle {

    public ExampleScheduler(MutexContendServiceFactory contendServiceFactory) {
        super("example-scheduler", ScheduleConfig.ofDelay(Duration.ofSeconds(0), Duration.ofSeconds(10)), contendServiceFactory);
    }

    @Override
    protected String getWorker() {
        return "ExampleScheduler";
    }

    @Override
    protected void work() {
        if (log.isInfoEnabled()) {
            log.info("do some work!");
        }
    }
}