distribute后端系统怎么使用(分布式常用工具组件)
项目介绍
这是一个分布式常用工具组件。其中包括但不限于:
分布式List、分布式Set、分布式Long、分布式信号量、分布式缓存、分布式锁、分布式序列号生成器、分布式订阅发布模式等常用工具类
目前微服务开发的系统很多,这个就涉及到分布式集群问题。像以前如果是单机,那么这些解决方案都可以使用JVM的API来实现
但在分布式环境下,这些API都不可用,所以急需一套分布式的API来支持这种常用操作,那么我来提供了,后面持续添加各种分布式常用工具类
注意:所有组件目前都是线程不安全,如果多线程请使用多实例,或者自己加同步锁
软件架构
目前项目分两个module,distributed-tool和distributed-tool-test。前者是核心源码。后者是测试代码。
distributed-tool主要分如下模块:分布式List、分布式Set、分布式Long、分布式信号量等
- core 提供基本分布式组件。(V1.3支持)
- cache 简单的分布式缓存模块。(V1.3支持)
- lock 分布式锁。(V1.3支持)
- pubsub 分布式订阅发布组件。(V1.3支持)
- 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 //使用完后记得close list.close();
分布式DtLong
支持分布式自增和自减去
DtLong dtLong = Dt.newDtLong("longName"); long l = dtLong.incr(1); l = dtLong.decr(1L); l = dtLong.getValue(); //使用完后记得close dtLong.close();
分布式DeQueue
支持尾部push,头部pop,很容易就可以基于整个Queue实现一个简单的分布式队列(生产者消费者模式)
DtQueue queue = Dt.newDtQueue("queueName"); queue.push("eeee"); String eeee = queue.pop(); //使用完后记得close queue.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); //使用完后记得close semaphore.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"会被删除 //使用完后记得close set.close();
更多使用教程: https://gitee.com/xuan698400/distributed-tool/wikis/
,免责声明:本文仅代表文章作者的个人观点,与本站无关。其原创性、真实性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容文字的真实性、完整性和原创性本站不作任何保证或承诺,请读者仅作参考,并自行核实相关内容。文章投诉邮箱:anhduc.ph@yahoo.com