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>