文档章节

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

abcijkxyz
 abcijkxyz
发布于 2016/07/08 16:31
字数 673
阅读 2
收藏 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
粉丝 63
博文 6196
码字总数 1876
作品 0
深圳
项目经理
私信 提问
服务器后端开发系列——《实战FastDFS分布式文件系统》

1、FastDFS的配置、部署与API使用解读(1)Get Started with FastDFS 内容:讲解FastDFS的背景、基本原理,并讲述基本的配置、部署和测试的内容。 2、FastDFS的配置、部署与API使用解读(2)...

晨曦之光
2012/04/24
327
0
FastDFS的配置、部署与API使用解读(2)以字节方式上传文件的客户端代码

本文来自 诗商·柳惊鸿 Poechant CSDN博客,转载请注明源地址: FastDFS的配置、部署与API使用解读(2)上传文件到FastDFS分布式文件系统的客户端代码 在阅读本文之前,请您先通过 《FastDFS...

晨曦之光
2012/04/24
432
0
FastDFS的配置、部署与API使用解读(8)FastDFS多种文件上传接口详解

《Poechant的FastDFS的配置、部署与API使用教程》 FastDFS的配置、部署与API使用解读——(1)入门使用教程 FastDFS的配置、部署与API使用解读——(2)Java API:根据InputStream、文件名、...

晨曦之光
2012/04/24
2.9K
0
FastDFS的配置、部署与API使用解读(6)FastDFS配置详解之Storage配置

《Poechant的FastDFS的配置、部署与API使用教程》 FastDFS的配置、部署与API使用解读——(1)入门使用教程 FastDFS的配置、部署与API使用解读——(2)Java API:根据InputStream、文件名、...

晨曦之光
2012/04/24
448
0
FastDFS的配置、部署与API使用解读(5)FastDFS配置详解之Tracker配置

《Poechant的FastDFS的配置、部署与API使用教程》 FastDFS的配置、部署与API使用解读——(1)入门使用教程 FastDFS的配置、部署与API使用解读——(2)Java API:根据InputStream、文件名、...

晨曦之光
2012/04/24
375
0

没有更多内容

加载失败,请刷新页面

加载更多

day02:管道符、shell及环境变量

1、管道符:"|" 用于将前一个指令的输出作为后一个指令的输入,且管道符后面跟的是命令(针对文档的操作):cat less head tail grep cut sort wc uniq tee tr split sed awk等) [root@localho...

芬野de博客
1分钟前
0
0
Kubernetes系列——Kubernetes 组件、对象(二)

一、Kubernetes 组件 介绍了Kubernetes集群所需的各种二进制组件。 Master 组件 Master组件提供集群的管理控制中心。Master组件可以在集群中任何节点上运行。但是为了简单起见,通常在一...

吴伟祥
11分钟前
0
0
Flink-数据流编程模型

1、抽象等级 Flink提供了不同级别的抽象来开发流/批处理应用程序。 1) 低层级的抽象 最低层次的抽象仅仅提供有状态流。它通过Process函数嵌入到DataStream API中。它允许用户自由地处理来自一...

liwei2000
29分钟前
1
0
Java开发Swing实战JFrame和JTabbedPane容器的用法详细解析

概述: 项目是一个桌面程序,涉及标签和按钮组件、布局管理器组件、面板组件、列表框和下拉框组件等组件,以及Swing事件处理机制。 下面先从最基础的界面开始。 /** * @author: lishuai * @...

金铭鼎IT教育
34分钟前
10
0
flask 之旅

环境 为了正确地跑起来,你的应用需要依赖许多不同的软件。 就算是再怎么否认这一点的人,也无法否认至少需要依赖Flask本身。 你的应用的运行环境,在当你想要让它跑起来时,是至关重要的。 ...

hblt-j
34分钟前
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部