• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

ctjdfs: 一个java实现的分布式文件存储系统,可以实现文件分布存储在不同的服务器中, ...

原作者: [db:作者] 来自: 网络 收藏 邀请

开源软件名称:

ctjdfs

开源软件地址:

https://gitee.com/ygq/ctjdfs

开源软件介绍:

ctjdfs

介绍

ctjdfs是由java语言开发的一个开源的轻量级分布式文件系统,它对文件进行管理,功能包括:文件存储、文件访问(文件上传、文件下载)等,解决了大容量存储和负载均衡的问题。

官方网站

项目主页:http://www.caitaojun.com/ccblog/ArticleInfoServlet?aid=003fee02581e4f1a8a368b1e2dfd04ce

软件架构

安装教程

  1. 安装jre1.8环境
  2. 服务端下载地址:http://res.caitaojun.com/ctjdfs-server.jar,也可以下载ctjdfs-server代码进行打包。
  3. 分别配置一个tracker.properties的配置文件和一个storage.properties文件tracker.properties
#服务器角色 tracker、storagectjdfs.role=tracker#tracker 2688   storage 2689ctjdfs.port=2688#tracker数据文件存放路径ctjdfs.tracker.data.path=c:/ctjdfs_tracker#storage文件存储块大小(MB)ctjdfs.storage.block.size=20

storage.properties

#服务器角色 tracker、storagectjdfs.role=storage#tracker 2688   storage 2689ctjdfs.port=2689#tracker 地址、端口ctjdfs.tracker=127.0.0.1:2688#storage想tracker发送心跳间隔秒ctjdfs.heartbeat.interval=10#storage地址端口ctjdfs.storage=127.0.0.1:2689#storage上传文件存储路径ctjdfs.storage.file.path=c:/ctjdfs
  1. 启动服务上面下载了ctjdfs-server.jar服务程序,以及配置好配置文件后,然后我们分别来运行tracker服务和storage服务。首先打开命令窗口,切换到ctjdfs-server.jar所在的目录启动tracker服务启动storage服务

####客户端应用程序调用

​ 客户端应用程序需要导入ctjdfs-client的jar包,maven坐标如下:

<dependency>    <groupId>com.caitaojun.ctjdfs</groupId>    <artifactId>ctjdfs-client</artifactId>    <version>1.0</version></dependency>

​ 通过代码来实现对文件的上传、下载、删除,代码 如下:

@Testpublic void testUpload() throws Exception {    CtjDfsClient.init("127.0.0.1",2688);    File file = new File("c:/dog.jpg");    Map metaData = new HashMap<>();    metaData.put("author","ctj");    String fileId = CtjDfsClient.upload(file, metaData);    System.out.println(fileId);}@Testpublic void testDownload() throws Exception {    CtjDfsClient.init("127.0.0.1",2688);    String fileid = "c7637c97eed3bde8b64dd321c917aa89";    DownloadFile downloadFile = CtjDfsClient.download(fileid);    String fileName = downloadFile.getStorageFileInfo().getName();    FileInputStream fileInputStream = downloadFile.getFileInputStream();    FileUtils.copyInputStreamToFile(fileInputStream,new File("c:/"+fileName));}@Testpublic void testDelete() throws Exception {    CtjDfsClient.init("127.0.0.1",2688);    String fileid = "904d7ab95fe603eeabb45640a2cb6427";    boolean delete = CtjDfsClient.delete(fileid);    System.out.println(delete);}

欢迎各位大神一起能把这个系统搞好起来,后期代码我也继续进行优化更新中。

打赏赞助:http://www.caitaojun.com/ccblog/sponsor.html

讨论qq群:646224436


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap