文档章节

FastDFS的配置、部署与API使用解读(2)以字节方式上传文件的客户端代码

abcijkxyz
 abcijkxyz
发布于 2016/07/08 16:31
字数 673
阅读 2
收藏 0
点赞 0
评论 0
在阅读本文之前,请您先通过 《FastDFS的配置、部署与API使用解读(1)Get Started with FastDFS》 一文中给出的参考博文中的部署篇和测试篇来完成前期的准备工作。


1、下载FastDFS的API
FastDFS提供Java和PHP等语言的客户端API。可以到FastDFS在Google Code的项目主页 http://code.google.com/p/fastdfs/downloads/list 下载。本文以Java API为例。


2、调用API的上传接口
通过Servlet得到InputStream、文件名称和文件长度,然后通过调用FastDFS提供的Java API把文件上传到FastDFS服务器。下段代码中的getFileBuffer可参考本博客上一篇博文。(by Poechant)
  1. /** 
  2.  * Upload File to DFS. 
  3.  * @param fileBuff, file to be uploaded. 
  4.  * @param uploadFileName, the name of the file. 
  5.  * @param fileLength, the length of the file. 
  6.  * @return the file ID in DFS. 
  7.  * @throws IOException  
  8.  */  
  9. public String uploadFile(InputStream inStream, String uploadFileName, long fileLength) throws IOException {  
  10.     byte[] fileBuff = getFileBuffer(inStream, fileLength);  
  11.     String fileId = "";  
  12.     String fileExtName = "";  
  13.     if (uploadFileName.contains(".")) {  
  14.         fileExtName = uploadFileName.substring(uploadFileName.lastIndexOf(".") + 1);  
  15.     } else {  
  16.         logger.warn("Fail to upload file, because the format of filename is illegal.");  
  17.         return fileId;  
  18.     }  
  19.   
  20.   
  21.     //建立连接  
  22.     TrackerClient tracker = new TrackerClient();  
  23.     TrackerServer trackerServer = tracker.getConnection();  
  24.     StorageServer storageServer = null;  
  25.     StorageClient1 client = new StorageClient1(trackerServer, storageServer);  
  26.   
  27.   
  28.     //设置元信息  
  29.     NameValuePair[] metaList = new NameValuePair[3];  
  30.     metaList[0] = new NameValuePair("fileName", uploadFileName);  
  31.     metaList[1] = new NameValuePair("fileExtName", fileExtName);  
  32.     metaList[2] = new NameValuePair("fileLength", String.valueOf(fileLength));  
  33.   
  34.   
  35.     //上传文件  
  36.     try {  
  37.         fileId = client.upload_file1(fileBuff, fileExtName, metaList);  
  38.     } catch (Exception e) {  
  39.         logger.warn("Upload file \"" + uploadFileName + "\"fails");  
  40.     }  
  41.     trackerServer.close();  
  42.     return fileId;  
  43. }  

3、调用方式详解
(1)客户端与Tracker Server通信
根据《FastDFS的配置、部署与API使用解读(1)Get Started with FastDFS》一文中提供的FastDFS的工作原理,结合上面的代码,首先通过TrackerClient构造函数从全局配置中获取Tracker Servers的IP和端口初始化一个TrackerClient对象tracker,并与其建立连接,我们可以从API的源码中看到:
  1. /** 
  2. * constructor with global tracker group 
  3. */  
  4. public TrackerClient()  
  5. {  
  6.     this.tracker_group = ClientGlobal.g_tracker_group;  
  7. }     
  8. /** 
  9. * constructor with specified tracker group 
  10. * @param tracker_group the tracker group object 
  11. */  
  12. public TrackerClient(TrackerGroup tracker_group)  
  13. {  
  14.     this.tracker_group = tracker_group;  
  15. }  



上述代码中ClientGlobal是一个提供很多静态成员供外部读取的类。通过tracker这个TrackerClient建立的与Tracker Server的连接,实例化了一个trackerServer对象。


(2)客户端与Storage Server通信

通过trackerServer取得某一个可用的Storage Server的地址并用其实例化一个StorageClient1对象。这样就完成了FastDFS的客户端调用上传、下载、删除等所有操作的前期建立连接的工作。


(3)调用文件操作API
这些操作包括upload、download、append、delete等。上例中提供的是上传的实例。



本文来自 诗商·柳惊鸿 Poechant CSDN博客,转载请注明源地址:FastDFS的配置、部署与API使用解读(2)Java API:根据InputStream、文件名、文件长度上传文件

本文转载自:http://blog.csdn.net/yuwenruli/article/details/8469134

共有 人打赏支持
abcijkxyz
粉丝 60
博文 6196
码字总数 1876
作品 0
深圳
项目经理
FastDFS的配置、部署与API使用解读 (1)

1、背景 FastDFS是一款开源的、分布式文件系统(Distributed File System),由淘宝开发平台部资深架构师余庆开发。该开源项目的主页是 http://code.google.com/p/fastdfs 。可以通过fastdfs...

吾爱
2012/12/04
0
0
Fastdfs分布式文件存储系统架构剖析及分布式集群环境的配置

===============分布式文件存储系统Fastdfs架构解析======================== FastDFS是一款类Google FS的开源分布式文件系统,它用纯C语言实现,支持Linux、FreeBSD、AIX等UNIX系统。它只能...

xiejunbo
2015/06/30
0
0
分布式文件系统FastDFS架构剖析

文/余庆 FastDFS是一款类Google FS的开源分布式文件系统,它用纯C语言实现,支持Linux、FreeBSD、AIX等UNIX系统。它只能通过专有API对文件进行存取访问,不支持POSIX接口方式,不能mount使用...

凯文加内特
2014/04/15
0
0
Ubuntu 14.04下部署FastDFS 5.08+Nginx 1.13.0

环境 Ubuntu 14.04 用户 admin 数据目录: /fastdfs 安装包:FastDFS v5.05 一、下载安装libfastcommon 1.1、上传或下载 libfastcommon-master.zip 到/usr/local/src 目录 1.2、解压 1.3、编...

paascloud
2017/05/29
0
0
FastDFS--扩展篇(Php&&Apache2&&Nginx)

FastDFS不是通用的文件系统,只能通过专用的API来访问,目前提供了C JAVA PHP的API,下面我们来安装php扩展。 让Fastdfs支持php,在FastDFS的源码包解压后里面有个php_client目录,进入此目录...

China_OS
2012/08/15
0
0
转载 分布式文件系统FastDFS架构剖析

(打算使用FastDFS来存储商城的图片,特意研究一下) 文/余庆 FastDFS是一款类Google FS的开源分布式文件系统,它用纯C语言实现,支持Linux、FreeBSD、AIX等UNIX系统。它只能通过专有API对文...

alex.wu
2012/08/06
0
0
FastDFS安装使用实战三(使用篇)

经过前面的安装、配置、启动,马上就可以看到FastDFS的效果了,我们先上传一个文件,然后再通过http下载。 相关阅读: FastDFS安装使用实战一(安装篇) http://www.linuxidc.com/Linux/2012...

凯文加内特
2015/03/30
0
0
centos搭建FastDFS服务器!

CentOS fastDFS结合nginx的配置以及php端的调用方法 2013-04-18 22:54:55| 分类: 默认分类 | 标签:centos fastdfs nginx php |字号 订阅 fastDFS的介绍就不说了 想了解的人直接百度。 源码...

求学ing
2013/09/10
0
0
【FastDFS】FastDFS分布式文件系统安装手册(单机版)

一、前言 FastDFS是用c语言编写的一款开源的分布式文件系统。FastDFS为互联网量身定制,充分考虑了冗余备份、负载均衡、线性扩容等机制,并注重高可用,高性能等指标。使用FastDFS很容易搭建...

qq_26545305
04/24
0
0
浅析FastDFS及所遇问题集锦

一、FastDFS简介 FastDFS(最新版本v3.04)是一个开源的轻量级分布式文件系统,它用纯C语言实现,支持Linux、FreeBSD、AIX等UNIX系统。它只能通过专有API对文件进行存取访问,不支持POSIX接口方...

Edwyn王
2015/11/04
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

1.14 救援模式

确保开机启动时连接镜像文件,如果是真机服务器,就需要:U盘或光盘镜像启动进入BIOS 不同主板进入bios按键不同,一般是F12或Esc 光标:移动到Boot(开机启动项) 减号移动:光标选中行,按-...

小丑鱼00
11分钟前
0
0
ES11-全文检索

高级别全文检索通常用于在全文本字段(如电子邮件正文)上运行全文检索。 他们了解如何分析被查询的字段,并在执行之前将每个字段的分析器(或search_analyzer)应用于查询字符串。 1.term查...

贾峰uk
15分钟前
0
0
java 复制对象有哪些方式

java 复制对象有哪些方式 Apache的 Common beanutils库 org.apache.commons.beanutils.BeanUtils.copyProperties(dest,origin); Springframework 的BeanUtil 依赖: <dependency> ......

黄威
30分钟前
1
0
jstack的简单使用

公司测试反应, 一个java应用的机器, 即使不做交易, cpu始终是30%多, 于是想到了jstack, 实践步骤记录一下: 1, 找出java应用的进程号 ps -ef|grep 应用名|grep -v grep 2, 找出pid下的cpu占用...

零二一七
37分钟前
1
0
崛起于Springboot2.X之项目war打包部署(18)

将springboot项目打包步骤: 1、启动类 extends SpringBootServletInitializer 2、启动类添加覆盖方法 @Overrideprotected SpringApplicationBuilder configure(SpringApplicationBuilder......

木九天
46分钟前
2
0
导入CSV文件就行数据整理分析

#-*-coding:utf-8-*-import csv,os,re,mathlocalPath=input("请输入所有群文件的根目录:") #所有QQ群文件的物理根目录路径def info(): info_dic=[] dirList=os.listdi...

Kefy
52分钟前
5
0
CoreText进阶(六)-内容大小计算和自动布局

CoreText进阶(六)-内容大小计算和自动布局 其它文章: CoreText 入门(一)-文本绘制 CoreText入门(二)-绘制图片 CoreText进阶(三)-事件处理 CoreText进阶(四)-文字行数限制和显示更...

aron1992
53分钟前
1
0
一个Unity高人的博客,涉猎范围很广,深度也很深。

https://blog.csdn.net/ecidevilin/article/list/

爽歪歪ES
55分钟前
0
0
Spring Cloud Config-Git后端

EnvironmentRepository的默认实现使用Git后端,这对于管理升级和物理环境以及审核更改非常方便。要更改存储库的位置,可以在Config Server中设置“spring.cloud.config.server.git.uri”配置...

itcloud
57分钟前
1
0
centos7 卸载mysql

[root@zyf ~]# rpm -qa|grep -i mysqlmysql-community-libs-5.6.34-2.el7.x86_64mysql-community-server-5.6.34-2.el7.x86_64mysql-community-release-el7-5.noarchmysql-community-......

Yao--靠自己
今天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部