正好，淘淘商城講這一塊的時候，我又想起來當時老徐讓我寫過一個關於實現FastDFS實現檔案上傳下載的使用文件，當時結合我們的ITOO的視訊系統和畢業論文系統，整理了一下，有根據網上查到的知識，總結了一點東西，下面分享一下

一、FastDFS簡介：

        參見部落格：http://blog.csdn.net/liweizhong193516/article/details/53234486

二、FastDFS使用流程介紹：

       我們在itoo的dobbu+zk框架中使用fastdfs+nginx+mysql實現上傳附件的功能，主要原理就是將附件上傳到fastdfs得到一個檔案的連結路徑url，我們獲取到這個url將他以字串形式儲存到我們的mysql中，下載的時候獲取到這個url直接開啟或者下載附件。（url內容參見部落格：http://blog.csdn.net/liweizhong193516/article/details/52556526）

       

        預設的，我們就知道fastdfs後面還有一個nginx伺服器，當我們進行儲存檔案的時候，我們要通過fastdfs給我們生成一個儲存地址，也就是grounpID 和儲存地址，然後將檔案存在fastdfs伺服器中，fastdfs中有許多的16進制命名資料夾，資料夾中套資料夾；當我們進行讀取檔案的時候，我們要通過獲取mysql裡面的相應檔案的儲存地址去nginx伺服器中通過url路徑檔名，從fastdfs檔案中取出我們的檔案進行展示。（所以下載圖，有點問題，在這裡解釋一下）

三、實現流程：

1、配置依賴：因為我們使用的maven來管理工程，所以，我們需要去陪pom檔案

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
	<modelVersion>4.0.0</modelVersion>   
	<groupId>com.leech</groupId>  
	<artifactId>fastdfs-demo</artifactId>  
	<version>0.0.1-SNAPSHOT</version>  
	<packaging>jar</packaging>   
	<name>fastdfs-demo</name>  
	<url>http://maven.apache.org</url>   
	<properties>    
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
	</properties>   
	
	<dependencies>    
		<dependency>      
			<groupId>junit</groupId>      
			<artifactId>junit</artifactId>      
			<version>4.11</version>      
			<scope>test</scope>    
		</dependency>         
		<dependency>      
			<groupId>org.csource</groupId>      
			<artifactId>fastdfs-client-java</artifactId>      
			<version>1.25</version>    
		</dependency>         
		<dependency>        
			<groupId>commons-io</groupId>        
			<artifactId>commons-io</artifactId>        
			<version>2.4</version>    
			</dependency>       
		</dependencies>
	</project>
 

2、新建fdfs_client.conf檔案，在我們的itoo中，我們建立在（src/main/resources底下）

connect_timeout = 2
network_timeout = 30
charset = UTF-8
http.tracker_http_port = 80 
#沒什麼用
http.anti_steal_token = no
http.secret_key = FastDFS1234567890
tracker_server = 192.168.17.112:22122 
#tracker_server = 192.168.0.119:22122

3、實現檔案上傳：

       public void save(HttpServletRequest request,HttpServletResponse response){		
		String videoName=request.getParameter("videoName");
		String videoType=request.getParameter("videoType");
		String videoDesc=request.getParameter("videoDesc");
		String videoPath=request.getParameter("videoPath");
		String picturePath=request.getParameter("picturePath");

		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		Date uploadTime=null;
		try {
			uploadTime = formatter.parse(formatter.format(new Date()));
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		JacksonJsonUntil jackJsonUtil =new JacksonJsonUntil ();
		
		String dataBaseName = "itoo_video";
	
		Video video=new Video();
		video.setUserName("why");
		video.setUserID("why");		
		video.setVideoName(videoName);
		video.setVideoPath(videoPath);
		video.setVideoType(videoType);
		video.setVideoDesc(videoDesc);	
		video.setDataBaseName(dataBaseName);
		video.setPicturePath(picturePath);
		video.setUploadTime(uploadTime);
		
		uploadFileService.save(video);		
		
        jackJsonUtil.beanToJson(response,video);
		
	}
	
	/*
	 * 上傳檔案
	 */
	@RequestMapping(value={"/upload"})
	@ResponseBody
	public void upload( MultipartFile file, HttpServletRequest request,HttpServletResponse response){		
		
		String ext_Name = file.getOriginalFilename().split("\\.")[1];
		String videoName=file.getOriginalFilename().split("\\.")[0];
		
        byte[] bytes = null;
		try {
			bytes = file.getBytes();
		} catch (IOException e) {
			e.printStackTrace();
		}
		String videoPath=uploadFile(bytes,ext_Name);
		
		JacksonJsonUntil jackJsonUtil =new JacksonJsonUntil ();
		
		Video video=new Video();
		video.setVideoPath(videoPath);
		video.setVideoName(videoName);		
		
		jackJsonUtil.beanToJson(response,video);
	} 
	
	public String uploadFile(byte[] byteFile, String ext_file) {
		// 拼接服務區的檔案路徑
		StringBuffer sbPath = new StringBuffer();
		sbPath.append("http://192.168.22.252");
		try {
			// 初始化檔案資源
			ClientGlobal
					.init("C:\\Users\\alsr\\Desktop\\ITOO-5.0\\itoo-video-Test\\dmsd-itoo-video-parent\\dmsd-itoo-video-web\\src\\main\\resources\\fdfs_client.conf");

			// 連結FastDFS伺服器，建立tracker和Stroage
			TrackerClient trackerClient = new TrackerClient();
			TrackerServer trackerServer = trackerClient.getConnection();
			StorageServer storageServer = null;
			StorageClient storageClient = new StorageClient(trackerServer,
					storageServer);
			//利用位元組流上傳檔案
			String[] strings = storageClient.upload_file(byteFile, ext_file, null);

			for (String string : strings) {
				sbPath.append("/" + string);
				System.out.println(string);
			}
			// 全路徑
			System.out.println(sbPath);
		} catch (IOException | MyException e) {
			e.printStackTrace();
		}
		return sbPath.toString();
	}

4、FastDFS實現檔案下載：

public void testDownload() {        
		try {             
			ClientGlobal.init(conf_filename);             
			TrackerClient tracker = new TrackerClient();             
			TrackerServer trackerServer = tracker.getConnection();            
			StorageServer storageServer = null;             
			StorageClient storageClient = new StorageClient(trackerServer, storageServer);             
			byte[] b = storageClient.download_file("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");             
			System.out.println(b);             
			IOUtils.write(b, new FileOutputStream("D:/"+UUID.randomUUID().toString()+".conf"));        
			} 
		catch (Exception e) {             
			e.printStackTrace();         
		}     
	}       

5、FastDFS獲取將上傳檔案資訊：

public void testGetFileInfo(){         
		try {             
			ClientGlobal.init(conf_filename);             
			TrackerClient tracker = new TrackerClient();             
			TrackerServer trackerServer = tracker.getConnection();             
			StorageServer storageServer = null;             
			StorageClient storageClient = new StorageClient(trackerServer, storageServer);             
			FileInfo fi = storageClient.get_file_info("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");             
			System.out.println(fi.getSourceIpAddr());             System.out.println(fi.getFileSize());             
			System.out.println(fi.getCreateTimestamp());             System.out.println(fi.getCrc32());         
			} 	
		catch (Exception e) {             
			e.printStackTrace();         
			}     
		}       

6、FastDFS獲取檔名稱：

	public void testGetFileMate(){         
			try {            
				ClientGlobal.init(conf_filename);             
				TrackerClient tracker = new TrackerClient();             
				TrackerServer trackerServer = tracker.getConnection();             
				StorageServer storageServer = null;             
				StorageClient storageClient = new StorageClient(trackerServer,                     
				storageServer);             
				NameValuePair nvps [] = storageClient.get_metadata("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");             
				for(NameValuePair nvp : nvps){                 
					System.out.println(nvp.getName() + ":" + nvp.getValue());            
					}         
				} 
			catch (Exception e) {             
				e.printStackTrace();         
				}     
		}    

7、FastDFS實現刪除檔案：

             public void testDelete(){         
			try {             
				ClientGlobal.init(conf_filename);             
				TrackerClient tracker = new TrackerClient();             
				TrackerServer trackerServer = tracker.getConnection();             
				StorageServer storageServer = null;             
				StorageClient storageClient = new StorageClient(trackerServer,storageServer);             
				int i = storageClient.delete_file("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");             
				System.out.println( i==0 ? "刪除成功" : "刪除失敗:"+i);         
				} 
			catch (Exception e) {             
				e.printStackTrace();         
				}     
             }