FastDFS Java Api 使用教程

绝地灬酷狼 2022-03-31 04:37 606阅读 0赞

## 前言 ##

上一篇文章[分布式文件管理系统FastDFS搭建教程（FastDFS+nginx+fastdfs-nginx-module）][FastDFS_FastDFS_nginx_fastdfs-nginx-module]已经讲解了环境的搭建，接下来这个，是讲FASTDFS JAVA API的使用，解决JAVA端的调用问题。

## MAVEN管理 ##

*  自己构建的话，官方项目地址是  
    [https://github.com/happyfish100/fastdfs-client-java][https_github.com_happyfish100_fastdfs-client-java]
 *  直接下载Jar包的话，Maven仓库地址是  
    [https://mvnrepository.com/artifact/org.csource/fastdfs-client-java/1.27-RELEASE][https_mvnrepository.com_artifact_org.csource_fastdfs-client-java_1.27-RELEASE]

可以看到几个大仓库官方是没有这个jar包的，用友云居然有，可是不能直接用到，还是乖乖下载并安装jar包到maven库吧，1.27是最新版本。

这是一个bat安装脚本，保存为"install jar fastdfs.bat"即可，或者执行红色部分命令行导入jar包到本地maven库。

> @echo off  
> echo [blog.csdn.net/moshowgame][blog.csdn.net_moshowgame]  
> `mvn install:install-file -DgroupId=org.csource -DartifactId=fastdfs-client-java -Dversion=1.27-RELEASE -Dpackaging=jar -Dfile=fastdfs-client-java-1.27-RELEASE.jar`  
> pause  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70]

然后再项目中引入依赖

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

## conf文件 ##

maven工程再项目的`\src\main\resources`目录下新建一个`fdfs_client.conf`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70 1]  
内容如下

> \#配置文件  
> connect\_timeout = 2  
> network\_timeout = 30  
> charset = UTF-8  
> http.tracker\_http\_port = `8080`  
> http.anti\_steal\_token = no  
> http.secret\_key = FastDFS1234567890  
> tracker\_server = `192.168.103.118:22122`

注：这里确实很奇葩，他就是要求这种配置，然后就`ClientGlobal.init()`来初始化，对于我们整合配置进yml里面等等的，支持不算特别友好，有待改进。

## controller调用 ##

1.  里面的ApiReturnUtil.success/error为自己封装的类，根据业务需求调整即可。
2.  conf\_filenames是根据项目的`\src\main\resources`目录自动获取的。
3.  只需要配置`tracker_server`即可。那些`http.secret_key`什么的可以暂时不管。
4.  `this.getClass().getClassLoader().getResource("fdfs_client.conf").getPath()`可以直接获得sources下的conf文件，再加`.replaceAll("%20"," ")`可以支持目录有空格的情况，默认是显示`%20`

@RestController
    @RequestMapping("/upload")
    @Log4j
    public class UploadController {
        @RequestMapping(value = "/upload", method = RequestMethod.POST)
        public Object upload(@RequestParam MultipartFile file) {
            try {
                if(file.isEmpty()){
                    return ApiReturnUtil.error("空上传");
                }else{
                	//blog.csdn.net/moshowgame
                    String conf_filename = this.getClass().getClassLoader().getResource("fdfs_client.conf").getPath().replaceAll("%20"," ");
                    System.out.println(conf_filename);
                    String tempFileName = file.getOriginalFilename();
                    //fastDFS方式
                    ClientGlobal.init(conf_filename);
    
                    byte[] fileBuff = file.getBytes();
                    String fileId = "";
                    String fileExtName = tempFileName.substring(tempFileName.lastIndexOf("."));
    
                    //建立连接
                    TrackerClient tracker = new TrackerClient();
                    TrackerServer trackerServer = tracker.getConnection();
                    StorageServer storageServer = tracker.getStoreStorage(trackerServer);
                    StorageClient1 client = new StorageClient1(trackerServer, storageServer);
    
                    //设置元信息
                    NameValuePair[] metaList = new NameValuePair[3];
                    metaList[0] = new NameValuePair("fileName", tempFileName);
                    metaList[1] = new NameValuePair("fileExtName", fileExtName);
                    metaList[2] = new NameValuePair("fileLength", String.valueOf(file.getSize()));
    
                    //上传文件，获得fileId
                    fileId = client.upload_file1(fileBuff, fileExtName, metaList);
    				//TODO 这里可以追加一些业务代码，例如上传成功后保存到upload_file表，统一进行上传文件管理之类
                    return ApiReturnUtil.success("文件上传成功",fileId);
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                return ApiReturnUtil.error("上传错误："+e.getMessage());
            }
        }
    }

## html网页 ##

<!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <title>Blog.Csdn.Net/MoshowGame</title>
        <meta charset="utf-8">
    </head>
     <form id="formData" enctype="multipart/form-data" method="post" action="http://localhost:8085/managesys/upload/upload">
            <input type="id" name="file"  type="mul" /><br/>
            <input type="file" name="file" value="" /><br/>
            <a class="weui-btn-area">
                <input class="weui-btn weui-btn_primary" type="submit" value="去支付"/>
            </a>
    
        </form>

## 效果展示 ##

![在这里插入图片描述][20190102162406274.png]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70 2]

[FastDFS_FastDFS_nginx_fastdfs-nginx-module]: https://blog.csdn.net/moshowgame/article/details/85341632
[https_github.com_happyfish100_fastdfs-client-java]: https://github.com/happyfish100/fastdfs-client-java
[https_mvnrepository.com_artifact_org.csource_fastdfs-client-java_1.27-RELEASE]: https://mvnrepository.com/artifact/org.csource/fastdfs-client-java/1.27-RELEASE
[blog.csdn.net_moshowgame]: http://blog.csdn.net/moshowgame
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70]: /images/20220331/5c941ab57c214ecbb7209b8ea9d8e72c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70 1]: /images/20220331/9f782326353a44a3a0dd05824b2edb9b.png
[20190102162406274.png]: /images/20220331/1f9eed8006a44956aec1d4612254c3a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21vc2hvd2dhbWU_size_16_color_FFFFFF_t_70 2]: /images/20220331/7ad4bb165ad64efb84d2554a2f715ec1.png