fastDFS文件上傳簡單案例

基於fastDFS做了一個簡單的文件上傳案例（賊簡陋），文件上傳成功后將文件信息保存到MySQL數據庫中

pom.xml

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>2.0.1</version>
    </dependency>
    <!-- MySQL連接驅動 -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <dependency>
        <groupId>net.oschina.zcx7878</groupId>
        <artifactId>fastdfs-client-java</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-io</artifactId>
    </dependency>

springboot啟動類

@SpringBootApplication
public class FastDFSApplication {

    public static void main(String[] args) {
        SpringApplication.run(FastDFSApplication.class, args);
    }
}

Controller

import com.xuecheng.fastdfs.api.UserApi;
import com.xuecheng.fastdfs.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.util.Map;

@RestController
public class UserController implements UserApi {

    @Autowired
    UserService userService;

    @Override
    @PostMapping("/upload")
    public Map uploadPic(@RequestParam("file") MultipartFile file, String username) {
        return userService.uploadPic(file, username);

    }


}

 

文件上傳代碼實現部分

這里只寫了文件上傳的實現，文件的的刪除等功能可以通過 storageClient1調用方法實現

實際開發中，根據需要返回的參數和需要存入數據庫的參數可通過封裝實體類傳遞信息

service

import com.xuecheng.fastdfs.mapper.UserMapper;
import org.csource.fastdfs.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

@Service
public class UserService {

    @Autowired
    UserMapper userMapper;

    public Map uploadPic(MultipartFile file,String username) {
        Map map = new HashMap();
        try {
            //文件id
            String fileId = fdfs_upload(file);
            //文件直接存儲的url
            String fileUrl = queryFileUrl(fileId);
            //將文件的fileId和fileUrl存入數據庫，可供后面使用
            userMapper.saveFileId(username, fileId,fileUrl);
            map.put(true, fileId);
            return map;
        } catch (Exception e) {
            e.printStackTrace();
        }
        map.put(true, "上傳失敗");
        return map;

    }



    public String queryFileUrl(String fileId) {
        StorageClient1 storageClient1 = getstorageClient1();
        try {
            FileInfo fileInfo = storageClient1.query_file_info1(fileId);
            String sourceIpAddr = fileInfo.getSourceIpAddr();
            return sourceIpAddr + "/" + fileId;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    //上傳文件到fdfs，返回文件id 這里將文件上傳的過程抽取了
    public String fdfs_upload(MultipartFile file) {
        try {

            StorageClient1 storageClient1 = getstorageClient1();
            //上傳文件
            //文件字節
            byte[] bytes = file.getBytes();
            //文件原始名稱
            String originalFilename = file.getOriginalFilename();
            //文件擴展名
            String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
            //上傳文件返回文件id
            String file1 = storageClient1.upload_file1(bytes, extName, null);
            //返回文件id
            return file1;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }


    //獲取文件上傳對象storageClient1  這里單獨將此段代碼抽取出來復用
    public StorageClient1 getstorageClient1() {
        try {
            try {
                //加載fdfs的配置
                ClientGlobal.initByProperties("fastdfs-client.properties");
            } catch (IOException e) {
                throw new RuntimeException("初始化配置文件出錯");
            }
            //創建tracker client
            TrackerClient trackerClient = new TrackerClient();
            //獲取trackerServer
            TrackerServer trackerServer = trackerClient.getConnection();
            //獲取storage
            StorageServer storeStorage = trackerClient.getStoreStorage(trackerServer);
            //創建storage client
            StorageClient1 storageClient1 = new StorageClient1(trackerServer,storeStorage);
            return storageClient1;
        } catch (Exception e) {
            throw new RuntimeException("初始化StorageClient1出錯");
        }
    }
}

 

上面加載的文件上傳的配置文件 fastdfs-client.properties

fastdfs.connect_timeout_in_seconds = 5
fastdfs.network_timeout_in_seconds = 30
fastdfs.charset = UTF-8
fastdfs.tracker_servers = 192.168.25.133:22122

#fastdfs.connect_timeout_in_seconds： http連接超時時間
#fastdfs.network_timeout_in_seconds： tracker與storage網絡通信超時時間
#fastdfs.charset：字符編碼
#fastdfs.tracker_servers：tracker服務器地址，多個地址中間用英文逗號分隔比如=192.168.25.133:22122,192.168.25.134:22122

 

持久層根據需要填寫，這里做了簡單的保存

 

配置文件application.yml

spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC
    username: root
    password: dacian821


mybatis:
  type-aliases-package: com.xuecheng.fastdfs.domain
  mapper-locations: classpath:mapper/*Mapper.xml

usermaper接口

@Mapper
public interface UserMapper {

    void saveFileId(String username,String fileId,String fileUrl);

}

usermaper.xml

<?xml version="1.0" encoding="utf-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.xuecheng.fastdfs.mapper.UserMapper">


    <update id="saveFileId">
        update user set fileId=#{fileId},fileUrl=#{fileUrl} where username=#{username}
    </update>
</mapper>