distribute后端系统怎么使用分布式常用工具组件

导读distributed-tool项目介绍这是一个分布式常用工具组件。其中包括但不限于：分布式List、分布式Set、分布式Long、分布式信号量、分布式缓存....distributed-tool

项目介绍

这是一个分布式常用工具组件。其中包括但不限于：

分布式List、分布式Set、分布式Long、分布式信号量、分布式缓存、分布式锁、分布式序列号生成器、分布式订阅发布模式等常用工具类

目前微服务开发的系统很多，这个就涉及到分布式集群问题。像以前如果是单机，那么这些解决方案都可以使用JVM的API来实现

但在分布式环境下，这些API都不可用，所以急需一套分布式的API来支持这种常用操作，那么我来提供了，后面持续添加各种分布式常用工具类

注意：所有组件目前都是线程不安全，如果多线程请使用多实例，或者自己加同步锁

软件架构

目前项目分两个module，distributed-tool和distributed-tool-test。前者是核心源码。后者是测试代码。

distributed-tool主要分如下模块：分布式List、分布式Set、分布式Long、分布式信号量等

1. core 提供基本分布式组件。（V1.3支持）
2. cache 简单的分布式缓存模块。（V1.3支持）
3. lock 分布式锁。（V1.3支持）
4. pubsub 分布式订阅发布组件。（V1.3支持）
5. sequence 分布式序列号生成器。（V1.3支持）

Maven引用

<dependency> <groupId>com.xuanner</groupId> <artifactId>distributed-tool</artifactId> <version>1.3</version></dependency>

使用教程

初始化（目前底层使用了Redis来实现，所以使用Redis方式初始化）

Dt.getInstance().initJedis("xxx", 8380, "xxx");

销毁（注意，在应用的结束生命周期上加上销毁代码，例如Spring的destroy周期）

Dt.getInstance().getDefaultJedisFactory().destroy();

一个分布式List使用例子

DtList list = Dt.newDtList("listName");list.pushLeft(new String[] { "a", "b" });list.popLeft();list.close();//使用完毕记得close

一个分布式缓存锁使用例子

DtLock lock = Dt.newDtLock("lockName");String kId = lock.tryLock();//你的临界资源操作逻辑lock.unLock(kId);lock.close();//使用完毕记得close

核心分布式集合使用

原理说明

很多有用的组件，都基于核心的分布式集合来实现。例如：分布式List、分布式Queue、分布式Set等等。我这里也实现了一些基本的分布式合集和原子类。

分布式DtList

支持基本的push、pop操作

DtList list = Dt.newDtList("listName");list.pushLeft(new String[] { "a", "b" });//从列表的左边push一个元素String element = list.pushPop();//从列表的右边pop一个元素，这里element==a//使用完后记得closelist.close();

分布式DtLong

支持分布式自增和自减去

DtLong dtLong = Dt.newDtLong("longName");long l = dtLong.incr(1);l = dtLong.decr(1L);l = dtLong.getValue();//使用完后记得closedtLong.close();

分布式DeQueue

支持尾部push，头部pop，很容易就可以基于整个Queue实现一个简单的分布式队列（生产者消费者模式）

DtQueue queue = Dt.newDtQueue("queueName");queue.push("eeee");String eeee = queue.pop();//使用完后记得closequeue.close();

下面是一个简单的生产者消费者实现案例

//消费者final DefaultDtQueue consumer = new DefaultDtQueue("testName3");consumer.setClientFactory(clientFactory);new Thread(() -> { while (true) { String e = consumer.pop(); sleep(1); System.out.println(e); }}).start();//生产者final DefaultDtQueue provider = new DefaultDtQueue("testName3");provider.setClientFactory(clientFactory);new Thread(() -> { while (true) { provider.push("来一个时间戳：" System.currentTimeMillis()); sleep(3); }}).start();

分布式Dtsemaphore（信号量）

JDK自带的信号量大家都熟悉吧，整个是分布式的信号量，可以很方便的基于整个组件来做分布式控资源访问。 里面使用了Lua实现，绝对高校可靠。

DtSemaphore semaphore = Dt.newDtSemaphore("semaphoreName", 3);//这里限制同时只能访问3个资源String sId1 = semaphore.acquire();String sId2 = semaphore.acquire();String sId3 = semaphore.acquire();String sId4 = semaphore.acquire();//第四个就返回null表示拿不到信号量semaphore.release(sId1);String sId5 = semaphore.acquire();//因为上面释放了一个信号量，所以这里又可以拿到了//这里注意，为了防止系统拿到信号量当机后无法释放信号量，每个背获取的信号量都有默认30S的超时时间//如果过了30S你还没有释放，那么这个信号量就会默认背释放,如果要自己设定这个超时时间，你可以这样新建//这里被设置成了60S，注意单位是：秒DtSemaphore semaphore = Dt.newDtSemaphore("semaphoreName", 3, 60);//使用完后记得closesemaphore.close();

分布式DtSortedSet（可排序Set）

首先他是一个Set集合，且他支持设置score进行排序

DtSortedSet set = Dt.newDtSortedSet("setName");set.add(1, "a1");set.add(20, "a20");set.add(99, "a99");//获取指定值的排位long rank = set.rank("a20");//这里rank==1//可以根据score的范围进行批量删除set.removeByScoreRange(1, 98);//这里值"a1"和"a20"会被删除 //使用完后记得closeset.close();

更多使用教程： https://gitee.com/xuan698400/distributed-tool/wikis/