搜尋
首頁後端開發C#.Net教程C# 快速手動建立檔案伺服器

今天分享一篇关于自己手动搭建文件服务器的文章,非常方便,想拥有属于自己的文件服务器的朋友可以学习一下。

如下图,下面是调用的一个测试使用的界面。

测试上传和下载的功能。

相关教程:C#视频教程

基本原理说一下

1.客户端上传file,转换成二进制流到服务器,服务器接收进行MD5加密,把文件及密码存入文件服务器库,文件根据MD5保存进本地文件夹,文件夹命名第一级取MD5前二位,第二级文件目录是MD5第3和4位,保存的文件重新命名,名称是当前加密的MD5。 当然,加密储存需要验证的,如果本地已经存了这个MD5就认为已经保存了相同的文件,就不需要再保存。

2.下载文件的时候 直接通过该MD5取文件即可。

 上图是基本流程,逻辑上还是有漏洞,实际上又有改动。基本流程是这样了,可以大概看看,懒得再划一个图了。

服务端结构:

 

 

FileService.asmx 提供服务,核心代码在FileCoreService.cs. 本项目用的Dapper,简单方便、实用。

WebApplication1 就是测试用的,客户端调用的了。

WFBPMFile 可以忽略了,我的一个转换功能,原先文件是文件流存入数据库里的,大概100G,然后转换成文件,放入文件服务器了。

核心代码 放出来吧,喜欢的可以拿去.


using FZ.File.Dapper;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Diagnostics;
using System.IO;
using System.Security.Cryptography;
using System.Text;

namespace FZ.File.Logic
{
    public class FileCoreService
    {
        /// <summary>
        /// 根据文件名和MD5检查是否存在, 检查文件名和MD5都存在 
        /// </summary>
        /// <param name="filename">文件名</param>
        /// <param name="md5str">文件流加密的MD5</param>
        /// <returns></returns>
        public bool CheckFilNameMD5(string filename, string md5str)
        {
            using (IDbConnection conn = DBConfig.GetSqlConnection())
            {
                try
                {
                    string sql = "SELECT COUNT(*) FROM BPM_tb_UploadFile WHERE [FileName]=@FileName AND FileMD5=@FileMD5 ";
                    //sql = String.Format(sql,filename,md5str);
                    //var count = conn.ExecuteScalar(sql, null, null, null, CommandType.Text);
                    var param = new DynamicParameters();
                    param.Add("@FileName", filename);
                    param.Add("@FileMD5", md5str);
                    var count = conn.ExecuteScalar(sql, param, null, 3600, CommandType.Text);
                    if ((int)count > 0)
                    {
                        return true;
                    }
                }
                catch (Exception ex)
                {
                    throw ex; 
                }
            }
            return false;
        }

        /// <summary>
        /// 验证数据的完整性(接收到的文件流MD5与接收到的MD5验证)
        /// </summary>
        /// <param name="md5str">接收的MD5</param>
        /// <param name="sourceStream">文件流</param>
        /// <returns></returns>
        public bool CheckMD5(string md5str, System.Byte[] sourceStream)
        {
            var jmd5 = GetMD5HashByByte(sourceStream);
            if (md5str == jmd5)
            {
                return true;
            }
            return false;
        }
        public bool InsertFile(System.Byte[] sourceStream,string md5str,string filename)
        {
            bool sf = SaveFileToDisk(sourceStream, "D:\\UploadFile\\", md5str);    //先保存文件
            if (sf)
            {
                //TO DO 插入数据库
                using (IDbConnection conn = DBConfig.GetSqlConnection())
                {
                    try
                    {
                        string sql = "INSERT INTO BPM_tb_UploadFile([FileName],[FileMD5],[FileSize],[Description]) VALUES(&#39;{0}&#39;,&#39;{1}&#39;,{2},&#39;{3}&#39;)";
                        sql = String.Format(sql, filename, md5str, sourceStream.Length, "");
                        var count = conn.Execute(sql, null, null, null, CommandType.Text);
                        //var param = new DynamicParameters();
                        //param.Add("@FileName", filename);
                        //param.Add("@FileMD5", md5str);
                        //var count = conn.Execute(sql, param, null, 3600, CommandType.Text);
                        if (count > 0)
                        {
                            return true;
                        }
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
            }
            return false;        
        }
        // 根据二进制流生成MD5
        private string GetMD5HashByByte(System.Byte[] sourceStream)
        {
            MD5 md5 = new MD5CryptoServiceProvider();
            byte[] result = md5.ComputeHash(sourceStream);
            String ret = "";
            for (int i = 0; i < result.Length; i++)
                ret += result[i].ToString("x").PadLeft(2, &#39;0&#39;);
            return ret;
        }

        // 根据文件流生成MD5(与上一方法生成结果相同)
        private string GetMD5HashByFile(string fileName)
        {
            FileStream file = new FileStream(fileName, FileMode.Open);
            MD5 md5 = new MD5CryptoServiceProvider();
            byte[] result = md5.ComputeHash(file);
            file.Close();
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < result.Length; i++)
            {
                sb.Append(result[i].ToString("x2"));
            }
            return sb.ToString();
        }

        // 保存文件流到服务器上指定位置
        private bool SaveFileToDisk(System.Byte[] sourceStream, string fileFullName)
        {
            bool result = false;
            try
            {
                //待保存的路径
                string savePath = Path.GetDirectoryName(fileFullName);
                if (!Directory.Exists(savePath))
                {
                    Directory.CreateDirectory(savePath);
                }

                using (FileStream fsTarget = new FileStream(fileFullName, FileMode.Create, FileAccess.Write, FileShare.None))
                {
                    fsTarget.Write(sourceStream, 0, sourceStream.Length);
                    fsTarget.Flush();
                    fsTarget.Close();
                    result = true;
                }
            }
            finally
            {
            }
            return result;
        }

        private bool SaveFileToDisk(System.Byte[] sourceStream, string filepath,string md5)
        {
            bool result = false;
            string fileFullName = filepath + md5.Substring(0, 2) + "\\" + md5.Substring(2, 2)+"\\" + md5;
            try
            {
                //待保存的路径
                string savePath = Path.GetDirectoryName(fileFullName);
                if (!Directory.Exists(savePath))
                {
                    Directory.CreateDirectory(savePath);
                }

                using (FileStream fsTarget = new FileStream(fileFullName, FileMode.Create, FileAccess.Write, FileShare.None))
                {
                    fsTarget.Write(sourceStream, 0, sourceStream.Length);
                    fsTarget.Flush();
                    fsTarget.Close();
                    result = true;
                }
            }
            finally
            {
            }
            return result;
        }

        public System.Byte[] ReadFileByte(string filename, string md5str)
        {
            var filepath = "D:\\UploadFile\\" + md5str.Substring(0, 2) + "\\" + md5str.Substring(2, 2) + "\\" + md5str;
            FileStream fileStream = new FileStream(filepath, FileMode.Open);
            byte[] bytes = new byte[fileStream.Length];
            fileStream.Read(bytes, 0, bytes.Length);
            fileStream.Close();
            return bytes;
        }
        public FileStream ReadFileStream(string filename, string md5str)
        {
            var filepath = "D:\\UploadFile\\" + md5str.Substring(0, 2) + "\\" + md5str.Substring(2, 2) + "\\" + md5str;
            FileStream fileStream = new FileStream(filepath, FileMode.Open);
            fileStream.Close();
            return fileStream;
        }
        
        
    }
}

上面保存的文件路径自己写入配置文件吧,还有日志文件路径,自己到配置文件改一下。代码写的很烂,各位高人忽略即可。

提供的服务代码


using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Services;
using FZ.File.Logic;
using System.IO;

namespace BPMFileService
{
    /// <summary>
    /// FileService 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务,请取消注释以下行。 
    // [System.Web.Script.Services.ScriptService]
    public class FileService : System.Web.Services.WebService
    {

        [WebMethod]
        public bool CheckMD5(string filename,string md5str)
        {
            FileCoreService fs = new FileCoreService();
            return fs.CheckFilNameMD5(filename, md5str);
        }
        [WebMethod]
        public bool InsertFile(System.Byte[] FileStream,string filename, string md5str)
        {
            FileCoreService fs = new FileCoreService();
            bool b = fs.CheckMD5(md5str, FileStream);  //验证MD5
            if (b)
            {
                b = fs.InsertFile(FileStream, md5str,filename); //保存文件,并更新到数据库
                if (b) { LocalLog.Write("插入文件成功,文件名:" + filename + " MD5:" + md5str); } 
                else { LocalLog.Write("插入文件失败,文件名:" + filename + " MD5:" + md5str); }
            }
            else
            {
                LocalLog.Write("接收的文件不完整,请检查!文件名:" + filename + " MD5:" + md5str);
            }
            return b;
        }
        [WebMethod]
        public Byte[] ReadFile(string filename, string md5str)
        {
            FileCoreService fs = new FileCoreService();
            Byte[] bytes = fs.ReadFileByte(filename, md5str);
            LocalLog.Write("读取文件 NAME:" + filename + " MD5:" + md5str);
            return bytes;
        }
    }
}

客户端上传调用的代码:


protected void btnUp_Click(object sender, EventArgs e)
        {
            FileServiceSoapClient fsclient = new FileServiceSoapClient();
            byte[] fb = FileUpload1.FileBytes;
            System.IO.Stream s = FileUpload1.PostedFile.InputStream;
            var md5str = GetMD5HashByByte(fb);
            var md5str2 = GetMD5HashByFile(s);

            var filename = FileUpload1.FileName;
            bool b = fsclient.CheckMD5(filename, md5str);
            if (!b)
            {                
                if (md5str == md5str2) {
                    b = fsclient.InsertFile(fb, filename, md5str);
                }                
            }
        }

客户端下载的代码:


protected void btndown_Click(object sender, EventArgs e)
        {
            FileServiceSoapClient fsclinent = new FileServiceSoapClient();
            var Dbytes = fsclinent.ReadFile("新建文本文档.txt", "450ccb8dc556e010ff95b787084d2c51");
            //byte[] bytes =byte.Parse(Dbytes.ToString()):
            Response.ContentType = "application/octet-stream;charset=gb2321";
            //通知浏览器下载文件而不是打开;对中文名称进行编码
            Response.AddHeader("Content-Disposition", "attachment; filename=" + HttpUtility.UrlEncode("新建文本文档.txt", System.Text.Encoding.UTF8));
            Response.BinaryWrite(Dbytes);
            Response.Flush();
            Response.End();

        }

 数据库也比较简单:

 

日志:

 

以上是C# 快速手動建立檔案伺服器的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文轉載於:博客园。如有侵權,請聯絡admin@php.cn刪除
c#.net適合您嗎?評估其適用性c#.net適合您嗎?評估其適用性Apr 13, 2025 am 12:03 AM

c#.netissutableforenterprise-levelapplications withemofrosoftecosystemdueToItsStrongTyping,richlibraries,androbustperraries,androbustperformance.however,itmaynotbeidealfoross-platement forment forment forment forvepentment offependment dovelopment toveloperment toveloperment whenrawspeedsportor whenrawspeedseedpolitical politionalitable,

.NET中的C#代碼:探索編程過程.NET中的C#代碼:探索編程過程Apr 12, 2025 am 12:02 AM

C#在.NET中的編程過程包括以下步驟:1)編寫C#代碼,2)編譯為中間語言(IL),3)由.NET運行時(CLR)執行。 C#在.NET中的優勢在於其現代化語法、強大的類型系統和與.NET框架的緊密集成,適用於從桌面應用到Web服務的各種開發場景。

C#.NET:探索核心概念和編程基礎知識C#.NET:探索核心概念和編程基礎知識Apr 10, 2025 am 09:32 AM

C#是一種現代、面向對象的編程語言,由微軟開發並作為.NET框架的一部分。 1.C#支持面向對象編程(OOP),包括封裝、繼承和多態。 2.C#中的異步編程通過async和await關鍵字實現,提高應用的響應性。 3.使用LINQ可以簡潔地處理數據集合。 4.常見錯誤包括空引用異常和索引超出範圍異常,調試技巧包括使用調試器和異常處理。 5.性能優化包括使用StringBuilder和避免不必要的裝箱和拆箱。

測試C#.NET應用程序:單元,集成和端到端測試測試C#.NET應用程序:單元,集成和端到端測試Apr 09, 2025 am 12:04 AM

C#.NET應用的測試策略包括單元測試、集成測試和端到端測試。 1.單元測試確保代碼的最小單元獨立工作,使用MSTest、NUnit或xUnit框架。 2.集成測試驗證多個單元組合的功能,常用模擬數據和外部服務。 3.端到端測試模擬用戶完整操作流程,通常使用Selenium進行自動化測試。

高級C#.NET教程:ACE您的下一次高級開發人員面試高級C#.NET教程:ACE您的下一次高級開發人員面試Apr 08, 2025 am 12:06 AM

C#高級開發者面試需要掌握異步編程、LINQ、.NET框架內部工作原理等核心知識。 1.異步編程通過async和await簡化操作,提升應用響應性。 2.LINQ以SQL風格操作數據,需注意性能。 3..NET框架的CLR管理內存,垃圾回收需謹慎使用。

C#.NET面試問題和答案:提高您的專業知識C#.NET面試問題和答案:提高您的專業知識Apr 07, 2025 am 12:01 AM

C#.NET面試問題和答案包括基礎知識、核心概念和高級用法。 1)基礎知識:C#是微軟開發的面向對象語言,主要用於.NET框架。 2)核心概念:委託和事件允許動態綁定方法,LINQ提供強大查詢功能。 3)高級用法:異步編程提高響應性,表達式樹用於動態代碼構建。

使用C#.NET建築微服務:建築師實用指南使用C#.NET建築微服務:建築師實用指南Apr 06, 2025 am 12:08 AM

C#.NET是構建微服務的熱門選擇,因為其生態系統強大且支持豐富。 1)使用ASP.NETCore創建RESTfulAPI,處理訂單創建和查詢。 2)利用gRPC實現微服務間的高效通信,定義和實現訂單服務。 3)通過Docker容器化微服務,簡化部署和管理。

C#.NET安全性最佳實踐:防止常見漏洞C#.NET安全性最佳實踐:防止常見漏洞Apr 05, 2025 am 12:01 AM

C#和.NET的安全最佳實踐包括輸入驗證、輸出編碼、異常處理、以及身份驗證和授權。 1)使用正則表達式或內置方法驗證輸入,防止惡意數據進入系統。 2)輸出編碼防止XSS攻擊,使用HttpUtility.HtmlEncode方法。 3)異常處理避免信息洩露,記錄錯誤但不返回詳細信息給用戶。 4)使用ASP.NETIdentity和Claims-based授權保護應用免受未授權訪問。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您聽不到任何人,如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解鎖Myrise中的所有內容
4 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。

EditPlus 中文破解版

EditPlus 中文破解版

體積小,語法高亮,不支援程式碼提示功能

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

WebStorm Mac版

WebStorm Mac版

好用的JavaScript開發工具