Bot releases are hidden (Show)
Published by Ahoo-Wang almost 2 years ago
Full Changelog: https://github.com/Ahoo-Wang/Simba/compare/v0.3.6...v0.5.0
Published by Ahoo-Wang over 2 years ago
Full Changelog: https://github.com/Ahoo-Wang/Simba/compare/v0.3.5...v0.3.6
Published by Ahoo-Wang over 2 years ago
Full Changelog: https://github.com/Ahoo-Wang/Simba/compare/v0.3.2...v0.3.5
Published by Ahoo-Wang over 2 years ago
simba-spring-redis
module.Published by Ahoo-Wang almost 3 years ago
io.codearte.nexus-staging
-> io.github.gradle-nexus.publish-plugin
simba-redis
)Published by Ahoo-Wang almost 3 years ago
Simba aims to provide easy-to-use and flexible distributed lock services and supports multiple storage implementations: relational databases, Redis, and Zookeeper.
Kotlin DSL
val simbaVersion = "0.2.0";
implementation("me.ahoo.simba:simba-spring-boot-starter:${simbaVersion}")
<?xml version="1.0" encoding="UTF-8"?>
<project 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">
<modelVersion>4.0.0</modelVersion>
<artifactId>demo</artifactId>
<properties>
<simba.version>0.2.0</simba.version>
</properties>
<dependencies>
<dependency>
<groupId>me.ahoo.simba</groupId>
<artifactId>simba-spring-boot-starter</artifactId>
<version>${simba.version}</version>
</dependency>
</dependencies>
</project>
simba:
jdbc:
enabled: true
# redis:
# enabled: true
spring:
datasource:
url: jdbc:mysql://localhost:3306/simba_db
username: root
password: root
Kotlin DSL
val simbaVersion = "0.2.0";
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
);
Kotlin DSL
val simbaVersion = "0.2.0";
implementation("me.ahoo.simba:simba-redis:${simbaVersion}")
Kotlin DSL
val simbaVersion = "0.2.0";
implementation("me.ahoo.simba:simba-zookeeper:${simbaVersion}")
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();
try (Locker locker = new SimbaLocker("mutex-locker", this.mutexContendServiceFactory)) {
locker.acquire(Duration.ofSeconds(1));
/**
* doSomething
*/
} catch (Exception e) {
log.error(e.getMessage(), e);
}
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!");
}
}
}