FAST DFS 流上传

Posted 2022-02-05 IT的鱼

  @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();