FAST DFS 流上传

  @RequestMapping(value = "/fastDFSUpload", method = RequestMethod.POST)
    @ResponseBody
    public void fastDFSUpload(@RequestParam("file") MultipartFile file) throws IOException {
        try {// 初始化全局配置。加载一个配置文件。

            ClientGlobal.init("D:\dfs.conf");
            // 创建一个TrackerClient对象。
            TrackerClient trackerClient = new TrackerClient();
            // 创建一个TrackerServer对象。
            TrackerServer trackerServer = trackerClient.getConnection();
            // 声明一个StorageServer对象，null。
            StorageServer storageServer = null;
            // 获得StorageClient对象。
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);

            InputStream inputStream = file.getInputStream();
            String name=file.getOriginalFilename();
            String exatName=name.substring(name.lastIndexOf(".") + 1, name.length());
            int fileLength =inputStream.available();//获取文件大小
            NamevaluePair[] metaList = new NamevaluePair[3];
            metaList[0] = new NamevaluePair("fileName",name);
            metaList[1] = new NamevaluePair("fileExtName",exatName );
            metaList[2] = new NamevaluePair("fileLength", String.valueOf(fileLength));
            UploadFileSender us = new UploadFileSender(inputStream);
            String[] strings = storageClient.upload_file(null,fileLength,us, "txt", metaList);
            for (String string : strings) {
                System.out.println(string);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        }
    }

package com.bianq.learn.demo.message;

import org.csource.fastdfs.UploadCallback;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

class UploadFileSender implements UploadCallback {

    private InputStream inStream;

    public UploadFileSender(InputStream inStream) {
        this.inStream = inStream;
    }

    public int send(OutputStream out) throws IOException {
        byte[] bs = new byte[1024];
        int i=0;
        try{
            while ((i = inStream.read(bs)) != -1) {

                out.write(bs, 0, i);

            }
            out.flush();
        }catch (Exception e){
            e.printStackTrace();
        }

        return 0;
    }
}