package com.xpl.fastdfs;

import org.csource.common.NameValuePair;

import org.csource.fastdfs.*;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.multipart.MultipartFile;

@RestController

@RequestMapping("/upload")

public class UploadController {

@RequestMapping(value = "/upload", method = RequestMethod.POST)

public Object upload(@RequestParam MultipartFile file) {

try {

if(file.isEmpty()){

return "空上传";

}else{

//blog.csdn.net/moshowgame

String conf_filename = this.getClass().getClassLoader().getResource("fast_dfs.conf").getPath().replaceAll("%20"," ");

System.out.println(conf_filename);

String tempFileName = file.getOriginalFilename();

//fastDFS方式

ClientGlobal.init(conf_filename);

byte[] fileBuff = file.getBytes();

String fileId = "";

String fileExtName = tempFileName.substring(tempFileName.lastIndexOf("."));

//建立连接

TrackerClient tracker = new TrackerClient();

TrackerServer trackerServer = tracker.getConnection();

StorageServer storageServer = tracker.getStoreStorage(trackerServer);

StorageClient1 client = new StorageClient1(trackerServer, storageServer);

//设置元信息

NameValuePair[] metaList = new NameValuePair[3];

metaList[0] = new NameValuePair("fileName", tempFileName);

metaList[1] = new NameValuePair("fileExtName", fileExtName);

metaList[2] = new NameValuePair("fileLength", String.valueOf(file.getSize()));

//上传文件，获得fileId

fileId = client.upload_file1(fileBuff, fileExtName, metaList);

//TODO 这里可以追加一些业务代码，例如上传成功后保存到upload_file表，统一进行上传文件管理之类

System.out.println(fileId);

return "文件上传成功";

}

} catch (Exception e) {

e.printStackTrace();

return "上传错误："+e.getMessage();

}

}

}