fastdfs文件上传下载

### FastDFS 文件上传与下载

#### Spring Boot 中集成 FastDFS 实现文件的上传和下载功能

为了在应用程序中实现文件管理的功能，可以利用 FastDFS 提供的服务接口来完成文件的存储以及获取。下面将介绍基于 Java 的 Spring Boot 应用程序如何整合并使用 FastDFS 完成这一目标。

#### 添加 Maven 依赖项

首先，在项目的 `pom.xml` 文件里加入必要的客户端库以便连接到 FastDFS 服务器：

<dependency>
    <groupId>org.csource</groupId>
    <artifactId>fastdfs-client-java</artifactId>
    <version>1.28</version>
</dependency>

#### 配置 application.yml

接着，在 `src/main/resources/application.yml` 或者其他指定位置创建配置文件用于设置 FastDFS 连接参数：

spring:
  fastdfs:
    so-timeout: 3000
    connect-timeout: 2000
    charset: UTF-8
    tracker-list: localhost:22122 # 替换成实际地址

以上配置指定了超时时间和字符编码方式，并提供了 Tracker Server 的 IP 地址列表[^4]。

#### 创建工具类封装核心逻辑

之后开发人员应当构建一个辅助性的工具类别，它内部包含了针对 FastDFS 执行具体操作的方法，比如上传图片资源或是读取已存档的数据流等。这里给出部分代码片段作为参考：

import org.csource.fastdfs.*;

public class FastDfsUtil {
    
    private static StorageClient storageClient;

    public static String[] uploadFile(String localFilePath){
        try{
            ClientGlobal.initByProperties("classpath:fdfs_client.conf");
            TrackerClient tracker = new TrackerClient();
            TrackerServer trackerServer = tracker.getConnection();
            StorageServer storageServer = null;
            
            storageClient = new StorageClient(trackerServer,storageServer);
            return storageClient.upload_file(localFilePath,"",null); // 返回组名+路径
            
        }catch(Exception e){
            throw new RuntimeException(e.getMessage());
        }
    }

    public static byte[] downloadFile(String groupName,String remoteFileName)throws Exception{
        ClientGlobal.initByProperties("classpath:fdfs_client.conf");
        TrackerClient tracker = new TrackerClient();
        TrackerServer trackerServer = tracker.getTrackerServer();
        
        storageClient = new StorageClient(trackerServer,null);
        return storageClient.download_file(groupName,remoteFileName);
    }
}

上述实现了两个静态函数分别负责处理文件上载请求(`uploadFile`) 和 下载 (`downloadFile`) 请求 。注意这里的 `fdfs_client.conf` 是 FastDFS 客户端所需的配置文档名称，通常放置于项目根目录下或 CLASSPATH 路径内。

#### 构建 RESTful API 控制器

最后一步就是设计 Web 层控制器接收来自前端用户的 HTTP POST/GET 请求并将它们转发给之前定义好的业务层组件去执行相应的动作:

@RestController
@RequestMapping("/api/files")
public class FileController {

    @PostMapping(value="/upload", consumes="multipart/form-data")
    public ResponseEntity<String> handleFileUpload(@RequestParam("file") MultipartFile file) throws IOException {
        if (!file.isEmpty()) {
            String fileName = StringUtils.cleanPath(file.getOriginalFilename());
            String result[]=FastDfsUtil.uploadFile(fileName);

            return ResponseEntity.ok().body(result[0]+"/"+result[1]);
        }else{
            return ResponseEntity.badRequest().build();
        }
    }

    @GetMapping("/{groupName}/{fileName}")
    public void serveFile(
      @PathVariable String groupName,
      @PathVariable String fileName,
      HttpServletResponse response) throws Exception {
      
          byte[] content=FastDfsUtil.downloadFile(groupName,fileName);
          
          ServletOutputStream outputStream=response.getOutputStream();
          IOUtils.copy(new ByteArrayInputStream(content),outputStream);
          outputStream.flush();
          outputStream.close();  
    }
}

这段代码展示了怎样通过 RestTemplate 来暴露对外部可调用的服务端点，允许外部系统提交多媒体资料或者查询特定条目的具体内容。