SpringBoot2.X整合FastDFS,实现文件上传，删除。

接上一篇，docker搭建FastDFS文件系统。

这一篇实现SpringBoot2.0整合Fastdfs。

引入FastDfs依赖

<dependency>
   <groupId<com.github.tobato</groupId>
   <artifactId<fastdfs-client</artifactId>
   <version<1.26.2</version>
</dependency>

application.yml配置文件

fdfs:
  connect-timeout: 600
  so-timeout: 1500
  trackerList: 127.0.0.1:22122 
  thumb-image:  
    width: 150
    height: 150
  pool:
    max-total: 200

在启动类添加如下配置


@Configuration
@SpringBootApplication
@MapperScan("com.gbq.boot.web.mapper")
@EnableMBeanExport(registration= RegistrationPolicy.IGNORE_EXISTING)
@Import(FdfsClientConfig.class)
@EnableAsync
public class BootApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootApplication.class, args);
    }
}

controller 接口编写


package com.gbq.boot.web.controller;


import cn.hutool.core.lang.UUID;
import com.github.tobato.fastdfs.domain.StorePath;
import com.github.tobato.fastdfs.proto.storage.DownloadByteArray;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.velocity.shaded.commons.io.FilenameUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.net.URLEncoder;
import java.util.HashMap;

@RestController
@RequestMapping("/file")
public class FileController {

    @Resource
    private FastFileStorageClient fastFileStorageClient;
    @Resource
    private RedisTemplate redisTemplate;

    /**
     * 文件上传
     * @return result
     */
    @ResponseBody
    @PostMapping("/upload")
    public HashMap Object uploadImageByCover(MultipartFile file){
        HashMapObject result = new HashMap<();
        try {
            // 获取文件名称
            String originalFileName = file.getOriginalFilename();
            //fastDfs返回的路径名称
            String fastDfsGroup = redisTemplate.opsForValue().get(originalFileName);

            if(StringUtils.isNotBlank(fastDfsGroup)){
                result.put("msg",fastDfsGroup);
            }else {
                //上传
                StorePath path = fastFileStorageClient.
                        uploadFile(file.getInputStream(),file.getSize(),
                                FilenameUtils.getExtension(file.getOriginalFilename()),null);
                //获取路径加名称
                String picName = path.getFullPath();
                //把名称，路径存入redis
                redisTemplate.opsForValue().set(originalFileName,picName);

                result.put("msg",picName);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 文件删除
     * @param path
     * @return
     */
    @DeleteMapping("/delete")
    public HashMap Object delete(@RequestParam String path) {
        HashMapObject result = new HashMap<();
        // 第一种删除：参数：完整地址
        fastFileStorageClient.deleteFile(path);
        result.put("msg","恭喜恭喜，删除成功！");
        // 第二种删除：参数：组名加文件路径
        // fastFileStorageClient.deleteFile(group,path);
        return result;
    }

    /**
     * 文件下载
     * @param url 路径
     * @return
     */
    @GetMapping("/download")
    public void downLoad(@RequestParam String url, HttpServletResponse response) throws IOException {
        String group = url.substring(0, url.indexOf("/"));
        String path = url.substring(url.indexOf("/") + 1);
        //文件后缀
        String substring = url.substring(url.lastIndexOf(".") + 1);
        byte[] bytes = fastFileStorageClient.downloadFile(group, path, new DownloadByteArray());

        response.setCharacterEncoding("UTF-8");
        response.setHeader("Content-disposition", "attachment;filename=" + URLEncoder.encode(UUID.randomUUID().toString()+"."+substring, "UTF-8"));

        // 写出
        ServletOutputStream outputStream = response.getOutputStream();
        IOUtils.write(bytes, outputStream);
    }
}