Introduce

Klein is a distributed collection tool library based on Paxos, including distributed Cache, distributed message queue, distributed List, distributed Map, distributed Lock and so on. What's interesting about this is that you can keep data consistent across members without relying on any middleware.

You can understand that Klein is a distributed tool that depends on your project through Maven. We hope it will replace your existing Redis, messaging middleware, registry, configuration center, etc.

If you are interested in distributed message queue, distributed List, distributed Map, distributed Lock, we can share the existing design, you can participate in the coding work. 😆 😆 😆

Look forward to your star⭐

Quick Start

dependence klein

<dependency>
    <groupId>com.ofcoder.klein.core</groupId>
    <artifactId>klein-core</artifactId>
    <version>{last-version}</version>
</dependency>

startup

Klein instance = Klein.startup();
instance.awaitInit();

KleinCache klein = KleinFactory.getInstance().createCache("klein");
klein.put("hello", "klein");

KleinCache lock = KleinFactory.getInstance().createLock("klein");
cache.acquire(1, TimeUnit.SECONDS);

set property

For all configurable parameters, see: com.ofcoder.klein.KleinProp

You can set it through System#setProperty or get the KleinProp object

System.setProperty("klein.id", "2")

// or

KleinProp prop = KleinProp.loadIfPresent();

Jepsen Test

Run on Gitpod