通過Fastdfs進行文件上傳服務（文件和圖片的統一處理）

来源:https://www.cnblogs.com/wanghj-15/archive/2019/08/23/11402962.html
-Advertisement-
Play Games

1、文件上傳簡單流程分析圖: 2、Fastdfs介紹： Fastdfs由兩個角色組成： Tracker（集群）:調度（幫你找到有空閑的Storage） Storage（集群）：文件存儲（幫你保存文件或獲取需要的文件） 流程： 1.Storage和tracker 發送心跳連接。 2.客戶端請求trac ...


1、文件上傳簡單流程分析圖:

 

 

2、Fastdfs介紹：

　　Fastdfs由兩個角色組成：

　　　　Tracker（集群）:調度（幫你找到有空閑的Storage）

　　　　Storage（集群）：文件存儲（幫你保存文件或獲取需要的文件）

　　流程：

　　　　1.Storage和tracker 發送心跳連接。

　　　　2.客戶端請求tracker,tracker調度一個Storage,返回Storage的ip和埠。

　　　　3.客戶端請求Storage，上傳文件。

　　　　4.Storage保存文件，生成file_id,並返回。

　　　　5.客戶端接收到file_id並保存。

3、上傳下載流程圖：

       上傳：

 

 

       下載：

 

 

 

4、Fastdfs上傳具體實現步驟：

　　1． 在伺服器上搭建好fastdfs環境：這個由運維人員操作，開發人員無需關心。

　　2． 在本地maven倉庫導入fastdfs的jar包（該jar包在maven中央倉庫中沒有，無法通過idea自動下載，只能手動導入到本地倉庫中去）

　　jar包下載地址（fastdfs_client_v1.20.jar）：https://sourceforge.net/projects/fastdfs/files/Java%20Client%20API%20Library/Java%20Client%20Library%20V1.20%20%28compiled%20by%20JDK%201.6%29/fastdfs_client_v1.20.jar/download?use_mirror=liquidtelecom&download=&failedmirror=jaist.dl.sourceforge.net

　　導入本地倉庫：

       　　在jar包所在的目錄打開cmd,然後輸入以下命令，執行後即可在maven本地倉庫導入jar包併在cmd顯示出jar包在倉庫中的路徑。

mvn install:install-file -DgroupId=org.csource.fastdfs -DartifactId=fastdfs  -Dversion=1.2 -Dpackaging=jar -Dfile= fastdfs_client_v1.20.jar

 

　　3． 項目中引入

<dependency>
        <groupId>org.csource.fastdfs</groupId>
        <artifactId>fastdfs</artifactId>
        <version>1.2</version>
</dependency>

　　

　　4、項目中引入以下工具類：

fdfs_client.conf  文件（用於保存指向 tracker 的IP+埠（預設））：

tracker_server=172.16.2.274:22122

 

工具類：

import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;

public class FastDfsApiOpr {
     
    public static String CONF_FILENAME  = FastDfsApiOpr.class.getResource("/fdfs_client.conf").getFile();

    /**
     * 上傳文件
     * @param file
     * @param extName
     * @return
     */
    public static  String upload(byte[] file,String extName) {
 
        try { 
            ClientGlobal.init(CONF_FILENAME);
 
            TrackerClient tracker = new TrackerClient(); 
            TrackerServer trackerServer = tracker.getConnection(); 
            StorageServer storageServer = null;
 
            StorageClient storageClient = new StorageClient(trackerServer, storageServer); 
            NameValuePair nvp [] = new NameValuePair[]{
                    new NameValuePair("age", "18"), 
                    new NameValuePair("sex", "male") 
            }; 
            String fileIds[] = storageClient.upload_file(file,extName,nvp);
             
            System.out.println(fileIds.length); 
            System.out.println("組名：" + fileIds[0]); 
            System.out.println("路徑: " + fileIds[1]);
            return  "/"+fileIds[0]+"/"+fileIds[1];
 
        } catch (Exception e) {
            e.printStackTrace();
            return  null;
        }
    }

    /**
     * 下載文件
     * @param groupName
     * @param fileName
     * @return
     */
    public static byte[] download(String groupName,String fileName) {
        try {
 
            ClientGlobal.init(CONF_FILENAME);
 
            TrackerClient tracker = new TrackerClient(); 
            TrackerServer trackerServer = tracker.getConnection(); 
            StorageServer storageServer = null;
 
            StorageClient storageClient = new StorageClient(trackerServer, storageServer); 
            byte[] b = storageClient.download_file(groupName, fileName);
            return  b;
        } catch (Exception e) {
            e.printStackTrace();
            return  null;
        } 
    }
     
//    @Test
//    public void testGetFileInfo(){
//        try {
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            TrackerServer trackerServer = tracker.getConnection();
//            StorageServer storageServer = null;
//
//            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//            FileInfo fi = storageClient.get_file_info("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");
//            System.out.println(fi.getSourceIpAddr());
//            System.out.println(fi.getFileSize());
//            System.out.println(fi.getCreateTimestamp());
//            System.out.println(fi.getCrc32());
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
     
//    @Test
//    public void testGetFileMate(){
//        try {
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            TrackerServer trackerServer = tracker.getConnection();
//            StorageServer storageServer = null;
//
//            StorageClient storageClient = new StorageClient(trackerServer,
//                    storageServer);
//            NameValuePair nvps [] = storageClient.get_metadata("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");
//            for(NameValuePair nvp : nvps){
//                System.out.println(nvp.getName() + ":" + nvp.getValue());
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }

    /**
     * 刪除文件
     * @param groupName
     * @param fileName
     */
    public static void delete(String groupName,String fileName){
        try { 
            ClientGlobal.init(CONF_FILENAME);
 
            TrackerClient tracker = new TrackerClient(); 
            TrackerServer trackerServer = tracker.getConnection(); 
            StorageServer storageServer = null;
 
            StorageClient storageClient = new StorageClient(trackerServer, 
                    storageServer); 
            int i = storageClient.delete_file(groupName,fileName);
            System.out.println( i==0 ? "刪除成功" : "刪除失敗:"+i);
        } catch (Exception e) {
            e.printStackTrace();
            throw  new RuntimeException("刪除異常,"+e.getMessage());
        } 
    }
}

 

　　5、在contorller中使用：

@RestController
public class FileController {

    /**
     * 文件上傳  MultipartFile 是SpringMVC封裝好的API方便操作上傳的文件的
     * @param file
     * @return
     */
    @PostMapping("/fastdfs")
    public AjaxResult upload(MultipartFile file){

        try {
            //獲取文件的擴展名
            String filename = file.getOriginalFilename();
            String extName = filename.substring(filename.lastIndexOf(".")+1);
            String file_id = FastDfsApiOpr.upload(file.getBytes(), extName);
            return AjaxResult.me().setSuccess(true).setMessage("上傳成功!").setRestObj(file_id);
        } catch (Exception e) {
            e.printStackTrace();
            return AjaxResult.me().setSuccess(false).setMessage("上傳失敗!"+e.getMessage());
        }


    }

    /**
     * 刪除文件
     * @param file_id
     * @return
     */
    @DeleteMapping("/fastdfs")
    public AjaxResult delete(String file_id){
        try {
            //     /group1/M00/00/01/rBACgF1euQiAEdrcAACbjnUEnrE193.jpg

            file_id = file_id.substring(1);//   group1/M00/00/01/rBACgF1euQiAEdrcAACbjnUEnrE193.jpg

            String groupName = file_id.substring(0, file_id.indexOf("/"));


            String fileName = file_id.substring(file_id.indexOf("/")+1);

            FastDfsApiOpr.delete(groupName, fileName);

            return AjaxResult.me().setSuccess(true).setMessage("刪除成功!");

        } catch (Exception e) {
            e.printStackTrace();

            return AjaxResult.me().setSuccess(false).setMessage("刪除失敗!");

        }


    }


}

 

　　5.1控制文件上傳的大小

　　　　為瞭解決有些文件因大於預設上傳文件大小的而無法上傳的問題，可以在網關模塊和引用Fastdfs的controller所在的模塊的啟動類上加上如下代碼：

 /**
     * 文件大小上傳配置
     * @return
     */
    @Bean
    public MultipartConfigElement multipartConfigElement() {
        MultipartConfigFactory factory = new MultipartConfigFactory();
        //單個文件最大
        factory.setMaxFileSize("10240KB"); //KB,MB
        /// 設置總上傳數據總大小
        factory.setMaxRequestSize("102400KB");
        return factory.createMultipartConfig();
    }

 

　　6、前端頁面代碼

　　　　　　　　　　<el-form-item label="logo">
                    <el-upload
                            class="upload-demo"
                            action="http://localhost:6001/services/common/fastdfs"
                            :file-list="addForm.logoList"
                            list-type="picture"
                            :on-success="logoUploadSuccess"
                            :before-upload="handleBeforeUpload"
                            :on-remove="handleLogoRemove">
                        <el-button size="small" type="primary">點擊上傳</el-button>
                    </el-upload>
                </el-form-item>
methods: {
            handleLogoRemove(file, fileList){
                //file 刪除的文件
                //調用刪除文件的介面
                let file_id = file.response.restObj
                this.$http.delete("/common/fastdfs?file_id="+file_id)
                    .then(res=>{
                        let {success,message,restObj} = res.data;
                        if(success){
                            //fileList 刪除後的文件列表
                            this.addForm.logoList = fileList;
                        }else{
                            this.$message({
                                message:message,
                                type:"error"
                            })
                        }
                    })
            },
            //圖片上傳之前的回調
            handleBeforeUpload(file){
                if(this.addForm.logoList.length>0){
                    this.$message({
                        message:"只能上傳一張圖片!",
                        type:"warning"
                    })
                    return false;
                }
            },
            //圖片上傳成功的回調
            logoUploadSuccess(response, file, fileList){
                //fileList = [{response:{success:true,restObj:''}},file,file]
                this.addForm.logoList = fileList;
                console.log(response)
            }
}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 成員變數的初始化過程
    23:59 2019/8/23 成員變數: 對象的成員變數,或者普通成員變數; 類的成員變數,或者靜態成員變數 下麵是source code和.class->.java(反編譯後)的source code ...
  • python--django for 迴圈中，獲取序號
    功能需求:在前端頁面中,for迴圈id會構不成連續的順序號,所以要找到一種偽列的方式來根據數據量定義序號 因此就用到了在前端頁面中的一個欄位 forloop.counter，完美解決 ...
  • 集合系列（一）：集合框架概述
    集合系列（一）：集合框架概述 Java 集合是 Java API 用得最頻繁的一類，掌握 Java 集合的原理以及繼承結構非常有必要。總的來說，Java 容器可以劃分為 4 個部分： List 集合 Set 集合 Queue 集合 Map 集合 除了上面 4 種集合之外，還有一個專門的工具類： 工具 ...
  • Python學習日記(十四) 正則表達式和re模塊
    正則表達式: 它是字元串的一種匹配模式,用來處理字元串,可以極大地減輕處理一些複雜字元串的代碼量 字元組:它是在同一位置可能出現的各種字元組成了一個字元組,用[]表示,但是它的結果只能是一個數字或者一個大寫字母或小寫字母等 下麵測試以該網站為例http://tool.chinaz.com/regex ...
  • 數據結構C線性表現實
    linearList.h linearList.c index.c ...
  • 華容道程式求解
    中國經典棋盤游戲 華容道，求解最小步數。利用面向對象的分析方法，拆解問題域使其各自可獨立擴展。項目分期計劃：一、實現對橫刀立馬佈局的求解，導出步驟快照。二、實現對標準華容道滑塊（卒、五虎上將、曹操）任意佈局的求解。三、實現對任意自定義滑塊、自定義棋盤的求解。 ...
  • 線程的start方法解析
    Thread是學習我們學習多線程接觸到的第一個有關多線程的類，相信每一個學習過或者瞭解過Java多線程的小伙伴都知道Thread類。這次分享主要對Thread的start方法進行講解。 相信大家都知道，start方法是啟動一個線程，並且該線程進入了可執行狀態。在實際的編碼中，我們是重寫run()方法 ...
  • Django 註意知識點（一）
    本篇概述 Django Admin後臺顯示 多對多欄位（如何） Django 模板 顯示 多對多欄位（如何） models代碼背景 一，Django Admin後臺顯示 多對多欄位 於admin.py文件中 二，Django 模板 顯示 多對多欄位 先與 視圖 views.py文件中 然後，（url ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類