项目介绍
一个分布式常用工具组件。例如:分布式缓存、分布式序列号生成器、分布式锁、分布式订阅发布等等。
软件架构目前项目分两个module,distributed-tool和distributed-tool-test。前者是核心源码。后者是测试代码。distributed-tool主要分如下组件:
cliet所有的核心组件依赖模块,主要提供了最简单的分布式set、get、del、icre等操作。(V1.0支持)
cache简单的分布式缓存模块。(V1.0支持)
sequece分布式序列号生成组件。(V1.0支持)
版本更新V1.0支持分布式缓存、分布式序列号生成组件
Mave引用<depedecy> <groupId>com.xuaer</groupId> <artifactId>distributed-tool</artifactId> <versio>1.0</versio></depedecy>使用说明(1)核心Cliet使用(一般不建议直接使用,但是后面的所有分布式组件都基于他来开发的,目前使用了Redis来做实现方案)
构建DtCliet
protected DtCliet buildCliet() { RedisCliet redisCliet = ew RedisCliet(); redisCliet.setHost("localhost"); redisCliet.setPort(1234); redisCliet.setAuth("1234"); redisCliet.iit(); retur redisCliet;}代码使用
protected DtCliet buildCliet() { DtCliet cliet = buildCliet(); cliet.set("key", "value", 10); cliet.get("key"); cliet.del("key"); cliet.exists("key");}(2)分布式缓存工具使用
构建CacheCliet
protected CacheCliet buildCacheCliet() { DefaultCacheCliet defaultCacheCliet = ew DefaultCacheCliet(); defaultCacheCliet.setCliet(buildCliet()); retur defaultCacheCliet;}代码使用
CacheCliet cacheCliet = buildCacheCliet();cacheCliet.set("key", "value", 60);cacheCliet.get("key");cacheCliet.del("key");cacheCliet.setBulk(map, 60);cacheCliet.getBulk(list);cacheCliet.del(list);(3)分布式序列号使用
构建Sequece
protected Sequece buildSequece() { DefaultSequece defaultSequece = ew DefaultSequece(); defaultSequece.setCliet(buildCliet()); defaultSequece.setStep(1000);//步长,如果需要严格连续序号可以设置:1 defaultSequece.setStepStart(0);//序列号开始位置 retur defaultSequece;}代码使用
Sequece sequece = buildSequece();sequece.extId();后续支持功能分布式订阅发布(通知功能)
分布式锁
联系方式姓名:徐安
邮箱:javaadswig@163.com
QQ:349309307
个人博客:xuaer.com







评论