码迷,mamicode.com
首页 > 编程语言 > 详细

SpringBoot + FastDFS(只实现上传)

时间:2021-06-29 15:23:12      阅读:0      评论:0      收藏:0      [点我收藏+]

标签:build   support   wired   throws   extern   port   spring   java   环境   

SpringBoot + FastDFS(只实现上传)

搭建好FastDFS服务器后,使用Springboot集成fastdfs-client实现文件上传。

1、搭建FastDFS服务

为了简洁配置FastDFS服务,使用Docker搭建环境。

https://www.cnblogs.com/mjoe/p/14946238.html

2、SpringBoot环境搭建

技术图片

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.2</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.mjoe</groupId>
    <artifactId>FastDFS-SpringBoot</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>FastDFS-SpringBoot</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.github.tobato/fastdfs-client -->
        <dependency>
            <groupId>com.github.tobato</groupId>
            <artifactId>fastdfs-client</artifactId>
            <version>1.27.2</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

file.html 页面

<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml"
      xmlns:th="http://www.thymeleaf.org"
      xmlns:sec="http://www.thymeleaf.org/thymeleaf-extras-springsecurity3">
<head>
    
    <title>fileUpload page</title>
</head>
<body>
<h1 th:inlines="text">文件上传</h1>
<form action="uploadFileToFast" method="post" enctype="multipart/form-data">
    <p>
        选择文件: <input type="file" name="fileName" />
    </p>
    <p>
        <input type="submit" value="提交" />
    </p>
</form>
</body>
</html>

success.html页面

<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<head>
    <title>Thymeleaf+VUE+Element</title>
    
</head>

<body>
文件上传成功 !!!
</body>
</html>

application.yaml配置文件

fdfs:
  connect-timeout: 600
  so-timeout: 1500
  tracker-list: 82.156.203.105:22122
  thumb-image:
    height: 150
    width: 150
  pool:
    max-total: 200
  resHost: 82.156.203.105
  storagePort: 8001

spring:
  thymeleaf:
    cache: false

  servlet:
    multipart:
      max-file-size: 10MB
  jmx:
    enabled: false

接下来需要初始化fastdfs的相关配置,以便初始化的时候做全局加载,使配置生效,这里创建了两个类,FdfsConfig,FdfsConfiguration,FdfsConfig主要用以连接fastdfs,FdfsConfiguration使配置生效:

package com.mjoe.fastdfsspringboot.config;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @ClassName : FdfsConfig
 * @Description : 配置fdfs链接
 * @Author : MJoeBoyae
 * @Date: 2021-06-28 21:32
 */
@Component
@Data
public class FdfsConfig {

    @Value("${fdfs.resHost}")
    private String resHost;

    @Value("${fdfs.storagePort}")
    private String storagePort;

}
package com.mjoe.fastdfsspringboot.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableMBeanExport;
import org.springframework.jmx.support.RegistrationPolicy;

/**
 * @ClassName : FdfsConfiguration
 * @Description : fdfs配置生效
 * @Author : MJoeBoyae
 * @Date: 2021-06-28 21:34
 */
@Configuration
@EnableMBeanExport(registration= RegistrationPolicy.IGNORE_EXISTING)
public class FdfsConfiguration {

}

下面是关于使用fastdfs的客户端工具封装的几个操作fastdfs服务器的工具类,这里直接贴上代码,具体的意思可以参考官方文档,工具类在这个文件里,CommonFileUtil

package com.mjoe.fastdfsspringboot.util;


import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.exception.FdfsUnsupportStorePathException;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FilenameUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import java.io.*;
import java.nio.charset.Charset;

/**
 * @ClassName : CommonFileUtil
 * @Description : fdfs file tools
 * @Author : MJoeBoyae
 * @Date: 2021-06-28 21:35
 */
@Component
@Slf4j
public class CommonFileUtil {

    @Autowired
    private FastFileStorageClient storageClient;

    public String uploadFile(MultipartFile file) throws IOException {
        StorePath storePath = storageClient.uploadFile(file.getInputStream(), file.getSize(),
                FilenameUtils.getExtension(file.getOriginalFilename()), null);
        return getResAccessUrl(storePath);
    }

    /**
     * 普通的文件上传
     *
     * @param file
     * @return
     * @throws IOException
     */
    public String uploadFile(File file) throws IOException {
        FileInputStream inputStream = new FileInputStream(file);
        StorePath path = storageClient.uploadFile(inputStream, file.length(),
                FilenameUtils.getExtension(file.getName()), null);
        return getResAccessUrl(path);
    }

    /**
     * 带输入流形式的文件上传
     *
     * @param is
     * @param size
     * @param fileName
     * @return
     */
    public String uploadFileStream(InputStream is, long size, String fileName) {
        StorePath path = storageClient.uploadFile(is, size, fileName, null);
        return getResAccessUrl(path);
    }

    /**
     * 将一段文本文件写到fastdfs的服务器上
     *
     * @param content
     * @param fileExtension
     * @return
     */
    public String uploadFile(String content, String fileExtension) {
        byte[] buff = content.getBytes(Charset.forName("UTF-8"));
        ByteArrayInputStream stream = new ByteArrayInputStream(buff);
        StorePath path = storageClient.uploadFile(stream, buff.length, fileExtension, null);
        return getResAccessUrl(path);
    }

    /**
     * 返回文件上传成功后的地址名称?
     * @param storePath
     * @return
     */
    private String getResAccessUrl(StorePath storePath) {
        String fileUrl = storePath.getFullPath();
        return fileUrl;
    }

    /**
     * 删除文件
     * @param fileUrl
     */
    public void deleteFile(String fileUrl) {
        if (StringUtils.isEmpty(fileUrl)) {
            return;
        }
        try {
            StorePath storePath = StorePath.parseFromUrl(fileUrl);
            storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
        } catch (FdfsUnsupportStorePathException e) {
            log.warn(e.getMessage());
        }
    }

//    public String upfileImage(InputStream is, long size, String fileExtName, Set<MateData> metaData) {
//        StorePath path = storageClient.uploadImageAndCrtThumbImage(is, size, fileExtName, metaData);
//        return getResAccessUrl(path);
//    }
}

接下来写一个控制器,FileController,用以操作文件上传,这里模拟单文件上传,如果上传成功,fastdfs会返回给客户端一个地址,这个地址就是存放上传的文件的具体位置,下面看测试代码:

package com.mjoe.fastdfsspringboot.controller;

import com.mjoe.fastdfsspringboot.util.CommonFileUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;

/**
 * @ClassName : FileController
 * @Description : file
 * @Author : MJoeBoyae
 * @Date: 2021-06-28 21:41
 */
@Controller
@Slf4j
public class FileController {
    @Autowired
    private CommonFileUtil fileUtil;

    @RequestMapping("/goIndex")
    public String goIndex(){
        log.info("进入主页面");
        return "/file";
    }


    //使用fastdfs进行文件上传(这种写法比较简单)
    @RequestMapping("/uploadFileToFast")
    public String uoloadFileToFast(@RequestParam("fileName") MultipartFile file) throws IOException {

        if(file.isEmpty()){
            log.info("文件不存在");
        }
        String path = fileUtil.uploadFile(file);
        System.out.println(path);
        return "success";
    }
}

启动成功,测试

SpringBoot + FastDFS(只实现上传)

标签:build   support   wired   throws   extern   port   spring   java   环境   

原文地址:https://www.cnblogs.com/mjoe/p/14947709.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!