• eyb：Java代码通过FastDFS实现文件上传

    目录：

    （1）常用API介绍

    （2）Demo环境初始化

    （3）FastDFS文件工具类 

    （4）文件上传 

     

     

    （1）常用API介绍

    现在使用Java操作一下FastDFS

    FastDFS JavaAPI里面有几个常用类：

     CLientGlobal：加载配置文件的

    TranckerServer：是连接FastDFS里面的trackerServer，是通过TrackerClient创建的 

    是一个连接对象 

     StorageServer：是连接FastDFS中的Storage Server它是通过trackerClient并通过传入trackerServer构建的

    所以构建存储服务对象的时候需依赖跟踪器服务对象

    是一个存储服务类型

    StorageClient：真正的操作文件的客户端类型，构建的时候通过TrackerServer和StorageSeerver 

    常规操作：比如上传啊，下载啊或者删除 

     （2）Demo环境初始化

    创建springboot项目：

     

    删除没用的文件：

    在pom.xml中引入FastDFS依赖：

    创建conf的配置文件，去初始化ClientGlobal对象

    fast.client.conf：配置文件 

    1. #连接超时
    2. connect_timeout = 2
    3. #网络超时
    4. network_timeout = 30
    5. #编码格式
    6. charset = UTF-8
    7. #tracker端口号
    8. http.tracker_http_port = 8080
    9. #防盗链功能
    10. http.anti_steal_token = no
    11. #秘钥
    12. http.secret_key = FastDFS1234567890
    13. #tracker ip：端口号
    14. tracker_server = 192.168.23.129:22122
    15. #连接池配置
    16. connection_pool.enabled = true
    17. connection_pool.max_count_per_entry = 500
    18. connection_pool.max_idle_time = 3600
    19. connection_pool.max_wait_time_in_ms = 1000

     准备一个FastDFS的对象：

    FastDFSFile：

    1. package com.xxxx.fastdfsdemo.pojo;
    2.  
    3. public class FastDFSFile {
    4.     private String name;
    5.     private byte[] content;
    6.     private String ext;
    7.     private String md5;
    8.     private String author;
    9.     private String height;
    10.  
    11.     public FastDFSFile() {
    12.     }
    13.  
    14.     public FastDFSFile(String name, byte[] content, String ext) {
    15.         this.name = name;
    16.         this.content = content;
    17.         this.ext = ext;
    18.     }
    19.  
    20.     public FastDFSFile(String name, byte[] content, String ext, String md5, String author, String height) {
    21.         this.name = name;
    22.         this.content = content;
    23.         this.ext = ext;
    24.         this.md5 = md5;
    25.         this.author = author;
    26.         this.height = height;
    27.     }
    28.  
    29.     public String getName() {
    30.         return name;
    31.     }
    32.  
    33.     public void setName(String name) {
    34.         this.name = name;
    35.     }
    36.  
    37.     public byte[] getContent() {
    38.         return content;
    39.     }
    40.  
    41.     public void setContent(byte[] content) {
    42.         this.content = content;
    43.     }
    44.  
    45.     public String getExt() {
    46.         return ext;
    47.     }
    48.  
    49.     public void setExt(String ext) {
    50.         this.ext = ext;
    51.     }
    52.  
    53.     public String getMd5() {
    54.         return md5;
    55.     }
    56.  
    57.     public void setMd5(String md5) {
    58.         this.md5 = md5;
    59.     }
    60.  
    61.     public String getAuthor() {
    62.         return author;
    63.     }
    64.  
    65.     public void setAuthor(String author) {
    66.         this.author = author;
    67.     }
    68.  
    69.     public String getHeight() {
    70.         return height;
    71.     }
    72.  
    73.     public void setHeight(String height) {
    74.         this.height = height;
    75.     }
    76.  
    77. }

     不在去写controller-service了，直接写一个上传文件的工具类，然后再service里面直接调用工具类

    FastDFSClient： 

    1. package com.xxxx.fastdfsdemo.utils;
    2.  
    3. import org.csource.fastdfs.ClientGlobal;
    4. import org.csource.fastdfs.StorageClient;
    5. import org.csource.fastdfs.TrackerClient;
    6. import org.csource.fastdfs.TrackerServer;
    7. import org.slf4j.LoggerFactory;
    8.  
    9. import org.slf4j.Logger;
    10. import org.springframework.core.io.ClassPathResource;
    11.  
    12. import java.io.IOException;
    13.  
    14. public class FastDFSClient {
    15.  
    16.     //准备logger日志
    17.     private static Logger logger= LoggerFactory.getLogger(FastDFSClient.class);
    18.  
    19.     //ClientGlobal.init会读取配置文件 并初始化对应的属性
    20.     static {
    21.         try {
    22.             String filePath=new ClassPathResource("fast_client.conf").getFile().getAbsolutePath();
    23.             ClientGlobal.init(filePath);
    24.         } catch (Exception e) {
    25.             logger.error("FastDFS初始化失败！",e.getMessage());
    26.         }
    27.     }
    28.  
    29.     /*
    30.     *
    31.     * 生成Storage客户端
    32.     * */
    33.     private static StorageClient getStorageClient() throws IOException {
    34.         //获取trackerServer
    35.         TrackerServer trackerServer=getTranckerServer();
    36.         return new StorageClient(trackerServer,null);
    37.     }
    38.  
    39.     /*
    40.     * 生成Trancker服务器端
    41.     * */
    42.     //trackerServer可以通过trackerClient拿到
    43.     private static TrackerServer getTranckerServer() throws IOException {
    44.         TrackerClient trackerClient=new TrackerClient();
    45.         return trackerClient.getTrackerServer();
    46.     }
    47. }

    （3）FastDFS文件工具类 

     

    1. package com.xxxx.fastdfsdemo.utils;
    2.  
    3. import com.xxxx.fastdfsdemo.pojo.FastDFSFile;
    4. import org.csource.common.NameValuePair;
    5. import org.csource.fastdfs.*;
    6.  
    7. import org.slf4j.LoggerFactory;
    8.  
    9. import org.slf4j.Logger;
    10. import org.springframework.core.io.ClassPathResource;
    11.  
    12. import java.io.ByteArrayInputStream;
    13. import java.io.IOException;
    14. import java.io.InputStream;
    15.  
    16. public class FastDFSClient {
    17.  
    18.     //准备logger日志
    19.     private static Logger logger= LoggerFactory.getLogger(FastDFSClient.class);
    20.  
    21.     //ClientGlobal.init会读取配置文件 并初始化对应的属性
    22.     static {
    23.         try {
    24.             String filePath=new ClassPathResource("fast_client.conf").getFile().getAbsolutePath();
    25.             ClientGlobal.init(filePath);
    26.         } catch (Exception e) {
    27.             logger.error("FastDFS初始化失败！",e.getMessage());
    28.         }
    29.     }
    30.  
    31.     //上传文件
    32.     public static String [] upload(FastDFSFile file){
    33.         logger.info("File Name:"+file.getName()+",File length:"+file.getContent().length);
    34.  
    35.         NameValuePair[] meta_list=new NameValuePair[1];
    36.         meta_list[0]=new NameValuePair("author",file.getAuthor());
    37.  
    38.         long startTime=System.currentTimeMillis();//现在的时间
    39.         String[]uploadResults=null;
    40.         StorageClient storageClient=null;
    41.         try {
    42.             //获取storage客户端
    43.             storageClient=getStorageClient();
    44.             //上传
    45.             uploadResults=storageClient.upload_file(file.getContent(),file.getExt(),meta_list);
    46.  
    47.         } catch (Exception e) {
    48.             logger.error("上传失败！，File Name："+file.getName(),e);
    49.         }
    50.         logger.info("上传时间："+(System.currentTimeMillis()-startTime)+"ms");
    51.         if (uploadResults==null && storageClient!=null){
    52.             logger.error("上传失败："+storageClient.getErrorCode());
    53.         }
    54.         //上传成功返回groupName
    55.         logger.info("上传传文件成功!!!" + "group_name:" + uploadResults[0] + ", remoteFileName:" + " " + uploadResults[1]);
    56.         return uploadResults;
    57.     }
    58.  
    59.     //下载文件
    60.     public static InputStream downFile(String groupName, String remoteFileName){
    61.         try {
    62.             StorageClient storageClient = getStorageClient();//客户端
    63.             byte[] bytes = storageClient.download_file(groupName, remoteFileName);//下载
    64.             InputStream inputStream = new ByteArrayInputStream(bytes);//将数组转换为流
    65.             return inputStream;
    66.         }catch (Exception e) {
    67.             logger.error("文件下载失败！！！", e);
    68.         }
    69.         return null;
    70.     }
    71.  
    72.     //删除文件
    73.     public static void deleteFile(String groupName,String remoteFileName) throws Exception {
    74.         StorageClient storageClient = null;
    75.         try{
    76.             storageClient=getStorageClient();
    77.             int i = storageClient.delete_file(groupName, remoteFileName);
    78.             logger.info("文件删除成功" + i);
    79.  
    80.         }catch (Exception e){
    81.             logger.info("文件删除失败" + e.getMessage());
    82.         }
    83.     }
    84.  
    85.  
    86.     //获取文件响应的信息
    87.     public static FileInfo getFileInfo(String groupName, String remoteFileName){
    88.         try {
    89.             StorageClient storageClient = getStorageClient();//客户端
    90.             return storageClient.get_file_info(groupName,remoteFileName);
    91.         }catch (Exception e) {
    92.             logger.error("文件获取失败！！", e);
    93.         }
    94.         return null;
    95.     }
    96.  
    97.  
    98.  
    99.     /*
    100.     * 获取文件路径：先获取IP地址+端口
    101.     * */
    102.     public static String getTrackerUrl() throws Exception {
    103.         TrackerClient trackerClient=new TrackerClient();
    104.         TrackerServer trackerServer=trackerClient.getTrackerServer();
    105.         StorageServer storageServer=trackerClient.getStoreStorage(trackerServer);
    106.         return "http://"+getTranckerServer().getInetSocketAddress().getHostString()+":8888/";
    107.     }
    108.  
    109.     /*
    110.     *
    111.     * 生成Storage客户端
    112.     * */
    113.     private static StorageClient getStorageClient() throws IOException {
    114.         //获取trackerServer
    115.         TrackerServer trackerServer=getTranckerServer();
    116.         return new StorageClient(trackerServer,null);
    117.     }
    118.  
    119.     /*
    120.     * 生成Trancker服务器端
    121.     * */
    122.     //trackerServer可以通过trackerClient拿到
    123.     private static TrackerServer getTranckerServer() throws IOException {
    124.         TrackerClient trackerClient=new TrackerClient();
    125.         return trackerClient.getTrackerServer();
    126.     }
    127. }

    （4）文件上传 

    编写控制类：FileController

    1. package com.xxxx.fastdfsdemo.controller;
    2.  
    3. import com.xxxx.fastdfsdemo.pojo.FastDFSFile;
    4. import com.xxxx.fastdfsdemo.utils.FastDFSClient;
    5. import org.slf4j.Logger;
    6. import org.slf4j.LoggerFactory;
    7. import org.springframework.stereotype.Controller;
    8. import org.springframework.web.bind.annotation.GetMapping;
    9. import org.springframework.web.bind.annotation.PostMapping;
    10. import org.springframework.web.bind.annotation.RequestParam;
    11. import org.springframework.web.multipart.MultipartFile;
    12. import org.springframework.web.servlet.mvc.support.RedirectAttributes;
    13.  
    14. import java.io.IOException;
    15. import java.io.InputStream;
    16.  
    17. @Controller
    18. public class FileController {
    19.     //准备logger日志
    20.     private static Logger logger= LoggerFactory.getLogger(FastDFSClient.class);
    21.  
    22.     //上传文件
    23.     @PostMapping("upload")
    24.     public String FileUpLoad(@RequestParam("file") MultipartFile file, RedirectAttributes redirectAttributes){
    25.         if (file.isEmpty()){
    26.             redirectAttributes.addFlashAttribute("message","请选择一个文件上传");
    27.             return "redirect:/uploadStatus";
    28.         }
    29.         try {
    30.             //上传文件拿到返回的文件路径
    31.             String path=saveFile(file);
    32.             redirectAttributes.addFlashAttribute("message","上传成功"+file.getOriginalFilename());
    33.             redirectAttributes.addFlashAttribute("path","路径："+path);
    34.         } catch (Exception e) {
    35.             e.printStackTrace();
    36.         }
    37.         return "redirect:/uploadStatus";
    38.     }
    39.  
    40.     //页面跳转
    41.     @GetMapping("/uploadStatus")
    42.     public String uploadStatus(){
    43.         return "uploadStatus";
    44.     }
    45.     //页面跳转
    46.     @GetMapping("/")
    47.     public String upload(){
    48.         return "upload";
    49.     }
    50.  
    51.  
    52.     public String saveFile(MultipartFile multipartFile) throws Exception {
    53.         //上传之后返回的数组
    54.         String [] fileAbsolutePath={};
    55.         String fileName=multipartFile.getOriginalFilename();
    56.         String ext = fileName.substring(fileName.lastIndexOf(".") + 1);//后缀
    57.         byte[] file_buff=null;
    58.         InputStream inputStream=multipartFile.getInputStream();
    59.         if (inputStream!=null){
    60.             int len1=inputStream.available();
    61.             file_buff=new byte[len1];
    62.             inputStream.read(file_buff);
    63.         }
    64.         inputStream.close();
    65.         FastDFSFile  file=new FastDFSFile(fileName,file_buff,ext);
    66.         fileAbsolutePath= FastDFSClient.upload(file);
    67.         if (fileAbsolutePath==null){
    68.             logger.error("上传失败");
    69.         }
    70.         //返回上传后的完整路径
    71.         String path=FastDFSClient.getTrackerUrl()+fileAbsolutePath[0]+"/"+fileAbsolutePath[1];
    72.         return path;
    73.     }
    74. }

    upload.html：

    1. <!DOCTYPE html>
    2. <html >
    3. <head>
    4.     <meta charset="UTF-8">
    5.     <title>Title</title>
    6. </head>
    7. <body>
    8. <h1>Spring Boot file upload example</h1>
    9. <form method="POST" action="/upload" enctype="multipart/form-data">
    10.     <input type="file" name="file"/><br><br>
    11.     <input type="submit" value="Submit"/>
    12. </form>
    13.  
    14. </body>
    15. </html>

    uploadStatus.html：

    1. <!DOCTYPE html>
    2. <html lang="en" xmlns:th="http://www.thymeleaf.org">
    3.  
    4. <body>
    5. <h1>Spring Boot-Upload Status</h1>
    6.  
    7. <div th:if="${message}">
    8.     <h2 th:text="${message}"/>
    9. </div>
    10.  
    11.  
    12. <div th:if="${path}">
    13.     <h2 th:text="${path}"/>
    14. </div>
    15. </body>
    16. </html>

    运行主启动类

    在浏览器输入：

    点击选择文件： 

     

     

     storage里面保存的图片：

    点击提交：

    发现里面多了图片： 

     

     通过返回的路径通过Nginx可以在浏览器直接访问：

     

     

  • 相关阅读:
    项目上线就炸，这谁受得了
    IB学生喜欢申请哪些英国院校？
    【附源码】计算机毕业设计SSM时事新闻管理系统
    vue基础语法
    pyspark连接mysql数据库报错
    一个字符串模式匹配开源库
    基于java的在线答疑网站系统——计算机毕业设计
    OpenCV计算机视觉学习（15）——浅谈图像处理的饱和运算和取模运算
    2022-08-19 mysql/stonedb聚合aggregate多线程并行化-概要设计
    ts中关于path使用RouteLocationRaw报错
  • 原文地址：https://blog.csdn.net/dengfengling999/article/details/126444021