上傳大文件-斷點續傳的一中方式的記錄

来源:https://www.cnblogs.com/wxh-bky/archive/2018/09/26/9705865.html
-Advertisement-
Play Games

客戶端對文件的分割： ind.IsBusy = true; ind.Text = "上傳中...."; string cs_str = "server=" + GlobalVars.g_ServerID + "&userid="+GlobalVars.g_userID; string url = G ...


客戶端對文件的分割：

ind.IsBusy = true;
ind.Text = "上傳中....";
string cs_str = "server=" + GlobalVars.g_ServerID + "&userid="+GlobalVars.g_userID;
string url = GlobalVars.upload_image_address + "/page/UploadProgramVedio.aspx";
ThreadPool.QueueUserWorkItem(new WaitCallback(obj =>
{
try
{
int bufferLength = 1048576;//設置每塊上傳大小為1M
byte[] buffer = new byte[bufferLength];

//已上傳的位元組數
long offset = 0;
int count = 1;//當前的塊號
int g_count = Convert.ToInt32(g_st.Length / bufferLength); //總的塊號
if (g_st.Length % bufferLength>0)
{
g_count++;
}
if (count == g_count)
{
bufferLength = Convert.ToInt32(g_st.Length);
buffer = new byte[bufferLength];
}
//開始上傳時間
int size = g_st.Read(buffer, 0, bufferLength);

while (size > 0)
{
if (close_flag)
{
return;
}
offset += size;
double pec = Math.Round(Convert.ToDouble(count*100 / g_count));
this.Dispatcher.BeginInvoke(new Action(() =>
{
ind.Text = "上傳中...." + pec + "%";
}));
//Stream st = new MemoryStream();
//st.Write(buffer, 0, bufferLength);
string ccc_str = cs_str +"&chunk=" +count+ "&chunks="+g_count;
string xx = GlobalVars.HttpUploadFile(url, ccc_str, "pic_upload", filename, buffer);
if (xx.Contains(fileExtension))
{
if (count==g_count)
{
int k = xx.IndexOf(fileExtension);
file_path = xx.Substring(0, k + fileExtension.Length);
this.Dispatcher.BeginInvoke(new Action(() =>
{
ind.IsBusy = false;
upload_flag = true;
MessageBox.Show("上傳成功！");
}));
}
}
else if (xx.Contains("200"))
{
int k = xx.IndexOf("200");
string str_count= xx.Substring(0, k + 3);
if (str_count.Contains(":"))//斷點續傳
{
string[] sstr = str_count.Split(':');
int new_chunk = 0;//斷點續傳後開始的第一塊
if (int.TryParse(sstr[0],out new_chunk))
{
new_chunk--; //保險起見防止最後一塊的問題，減一
if (count < new_chunk)
{
for (int i = count; i < new_chunk; i++)
{
count++;
size = g_st.Read(buffer, 0, bufferLength);
offset += size;
}
}
}
}
}
else
{
this.Dispatcher.BeginInvoke(new Action(() =>
{
ind.IsBusy = false;
MessageBox.Show("上傳失敗！");
}));
break;
}
//st.Close();
count++;
if (count == g_count)
{
bufferLength = Convert.ToInt32(g_st.Length - offset);
buffer = new byte[bufferLength];
size = g_st.Read(buffer, 0, bufferLength);
}
else
{
size = g_st.Read(buffer, 0, bufferLength);
}
}
g_st.Close();
}
catch (Exception ex)
{
this.Dispatcher.BeginInvoke(new Action(() =>
{
ind.IsBusy = false;
MessageBox.Show("上傳失敗！" + ex.ToString());
}));
}
finally
{
//imgFileBytes = null;
g_st.Close();
g_st = null;
}
}));

 

http 上傳文件的方法：

/// <summary>
/// http上傳文件
/// </summary>
/// <param name="url">url地址</param>
/// <param name="poststr">參數 user=eking&pass=123456</param>
/// <param name="fileformname">文件對應的參數名</param>
/// <param name="fileName">文件名字</param>
/// <param name="bt">文件流</param>
/// <returns></returns>
public static string HttpUploadFile(string url, string poststr, string fileformname, string fileName, byte[] bt,Stream stream = null )
{
try
{
// 這個可以是改變的，也可以是下麵這個固定的字元串
string boundary = "ceshi";

// 創建request對象
HttpWebRequest webrequest = (HttpWebRequest)WebRequest.Create(url);
webrequest.ContentType = "multipart/form-data;boundary=" + boundary;
webrequest.Method = "POST";

// 構造發送數據
StringBuilder sb = new StringBuilder();

// 文本域的數據，將user=eking&pass=123456 格式的文本域拆分 ，然後構造
if (poststr.Contains("&"))
{
foreach (string c in poststr.Split('&'))
{
string[] item = c.Split('=');
if (item.Length != 2)
{
break;
}
string name = item[0];
string value = item[1];
sb.Append("--" + boundary);
sb.Append("\r\n");
sb.Append("Content-Disposition: form-data; name=\"" + name + "\"");
sb.Append("\r\n\r\n");
sb.Append(value);
sb.Append("\r\n");
}
}
else
{
string[] item = poststr.Split('=');
if (item.Length != 2)
{
return "500";
}
string name = item[0];
string value = item[1];
sb.Append("--" + boundary);
sb.Append("\r\n");
sb.Append("Content-Disposition: form-data; name=\"" + name + "\"");
sb.Append("\r\n\r\n");
sb.Append(value);
sb.Append("\r\n");
}

// 文件域的數據
sb.Append("--" + boundary);
sb.Append("\r\n");
sb.Append("Content-Type:application/octet-stream");
sb.Append("\r\n");
sb.Append("Content-Disposition: form-data; name=\"" + fileformname + "\"; filename=\"" + fileName + "\"");
sb.Append("\r\n\r\n");

string postHeader = sb.ToString();
byte[] postHeaderBytes = Encoding.UTF8.GetBytes(postHeader);

//構造尾部數據
byte[] boundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");

//string filePath = @"C:/2.html";
//string fileName = "2.html";

//byte[] fileContentByte = new byte[1024]; // 文件內容二進位
if (bt != null && stream == null)
{
long length = postHeaderBytes.Length + bt.Length + boundaryBytes.Length;
webrequest.ContentLength = length;
}
else if (bt == null && stream != null)
{
long length = postHeaderBytes.Length + stream.Length + boundaryBytes.Length;
webrequest.ContentLength = length;
}

Stream requestStream = webrequest.GetRequestStream();

// 輸入頭部數據 要按順序
requestStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);

// 輸入文件流數據
if (bt != null && stream == null)
{
requestStream.Write(bt, 0, bt.Length);
}
else if (bt == null && stream != null)
{
stream.CopyTo(requestStream);
}

// 輸入尾部數據
requestStream.Write(boundaryBytes, 0, boundaryBytes.Length);
WebResponse responce = webrequest.GetResponse();
Stream s = responce.GetResponseStream();
StreamReader sr = new StreamReader(s);

// 返回數據流(源碼)
return sr.ReadToEnd();
}
catch (Exception ex)
{
GlobalFunc.LogError("HttpUploadFile錯誤：" + ex.Message + ex.StackTrace);
return "500";
}
finally
{
if (stream!=null)
{
stream.Close();
}
}
}

 

服務端方法：

protected void doUpload()
{
int rand_flag = 0;//0為隨機名 1為預設值
string imageRoot = "";
if (ConfigurationManager.ConnectionStrings["upload_image_path"] != null)
{
imageRoot = ConfigurationManager.ConnectionStrings["upload_image_path"].ConnectionString;
if (imageRoot.EndsWith("/"))
{
imageRoot = imageRoot.Substring(0, imageRoot.Length - 1);
}
}

if (imageRoot == null || imageRoot == "")
{
Response.Write("<script language='javascript'>alert('請配置視頻目錄!'); window.location.reload();</script>");
Response.End();
}
server_id = Request["server"];
user_id = Request["userid"];
int chunk = Convert.ToInt32(Request["chunk"]); //當前分塊
int chunks = Convert.ToInt32(Request["chunks"]);//總的分塊數量
if (!int.TryParse(Request["rand_flag"],out rand_flag))
{

}
if (Request.Files["pic_upload"].ContentLength > 0)//驗證是否包含文件
{
string fileName = Request.Files["pic_upload"].FileName;
string newFileName = fileName;
if (chunks > 1)
{
newFileName = chunk + "_" + fileName; //按文件塊重命名塊文件
}
//取得文件的擴展名,並轉換成小寫
string fileExtension = Path.GetExtension(Request.Files["pic_upload"].FileName).ToLower();
//fileName += fileExtension;//完整文件名
//圖片目錄規則： 網站根目錄 +serverid(目錄名)+images(目錄名)+ userid(目錄名)+圖片文件名
string virtul_filepath = "/vedio/" + server_id + "/" + user_id+"/";//相對路徑
string filepath = imageRoot + virtul_filepath;//絕對路徑

if (Directory.Exists(filepath) == false)//如果不存在就創建file文件夾,及其縮略圖文件夾
{
try
{
Directory.CreateDirectory(filepath);
}
catch (Exception ex)
{
Response.Write("<script language='javascript'>alert('生成路徑出錯!" + ex.Message + "'); window.location.reload();</script>");
Response.End();
}
}

string virtual_allfileName = virtul_filepath + newFileName;// 包含相對路徑的文件名
string allfileName = filepath + newFileName;// 包含絕對路徑的文件名

if (chunks > 1&& System.IO.File.Exists(allfileName))
{
for (int i = 1; i < chunks; i++)
{
//檢測已存在磁碟的文件區塊
if (!System.IO.File.Exists(filepath + i.ToString() + "_" + fileName))
{
Response.Write(i+":200");
return;
}
}
}
string name = "";
Random rd = new Random();
name = DateTime.Now.ToString("yyyyMMddHHmmss") + rd.Next(1000, 9999)+ fileExtension;
if (chunks == 1)
{
if (rand_flag == 1)
{
allfileName = filepath + fileName;
virtual_allfileName = virtul_filepath + fileName;
}
else
{
allfileName = filepath + name;
virtual_allfileName = virtul_filepath + name;
}
}

Request.Files["pic_upload"].SaveAs(allfileName);//保存文件

//將保存的路徑,圖片備註等信息插入資料庫
try
{
if (chunks == 1)
{
Response.Write(virtual_allfileName);
}
else if (chunks > 1 && chunk == chunks) //判斷塊總數大於1 並且當前分塊==塊總數(指示是否為最後一個分塊)
{
if (rand_flag==1)
{
using (FileStream fsw = new FileStream(filepath + fileName, FileMode.Create, FileAccess.ReadWrite))
{
// 遍歷文件合併
for (int i = 1; i <= chunks; i++)
{
var data = System.IO.File.ReadAllBytes(filepath + i.ToString() + "_" + fileName);
fsw.Write(data, 0, data.Length);
System.IO.File.Delete(filepath + i.ToString() + "_" + fileName); //刪除指定文件信息
}

fsw.Position = 0;
Response.Write(virtul_filepath + fileName);
}
}
else
{
using (FileStream fsw = new FileStream(filepath + name, FileMode.Create, FileAccess.ReadWrite))
{
// 遍歷文件合併
for (int i = 1; i <= chunks; i++)
{
var data = System.IO.File.ReadAllBytes(filepath + i.ToString() + "_" + fileName);
fsw.Write(data, 0, data.Length);
System.IO.File.Delete(filepath + i.ToString() + "_" + fileName); //刪除指定文件信息
}
fsw.Position = 0;
Response.Write(virtul_filepath + name);
}
}

}
else
{
Response.Write("200");
}
}
catch (Exception ex)
{
Response.Write("<script language='javascript'>alert('上傳出錯!" + ex.Message + "'); window.location.reload();</script>");
Response.End();

}

}
else
{

Response.Write("<script language='javascript'>alert('請選擇要上傳的文件!'); window.location.reload();</script>");
Response.End();
}
}


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

-Advertisement-
Play Games
更多相關文章
  • ASP.NET Core 中的配置
    前言 配置 在我們開發過程中必不可少， ASP.NET 中的配置在 中。也可配置在如：JSON、XML、資料庫等(但 ASP.NET 並沒提供相應的模塊和方法)。 在 ASP.NET Core 中 Web.config 已經不存在了(但如果托管到 IIS 的時候可以使用 web.config 配置 ...
  • C/S架構引用Lodop 如何在C#調用web列印控制項Lodop
    lodop是web列印控制項，引用安裝目錄下的ocx文件，可以在c/s架構中使用。 該文件所在路徑：C:\Program Files (x86)\MountTaiSoftware\Lodop 有32位和64位的，如下例子引用的是32位的：CAOSOFT_WEB_PRINT_lodop.ocx 使用的是 ...
  • C# 創建、讀取Excel公式
    對於數據量較大的表格，需要計算一些特殊數值時，我們通過運用公式能有效提高我們數據處理的速度和效率，對於後期數據的增刪改查等的批量操作也很方便。此外，對於某些數值的信息來源，我們也可以通過讀取數據中包含的公式來獲取。下麵的示例中將分享通過C# 來創建、讀取Excel公式的方法。 工具使用 Spire. ...
  • 個人對【依賴倒置(DIP)】、【控制反轉(IOC)】、【依賴註入(DI)】淺顯理解
    一、依賴倒置（Dependency Inversion Principle） 依賴倒置是面向對象設計領域的一種軟體設計原則。（其他的設計原則還有：單一職責原則、開放封閉原則、里式替換原則、介面分離原則，合稱SOLID） 話說設計原則有什麼用呢？ 設計原則是無數編程前輩總結下來的經驗，好似編程界的金科 ...
  • 未能載入文件或程式集“**********”或它的某一個依賴項。試圖載入格式不正確的程式。
    摘要:IIS配置成功後，系統一直提示無法載入應用程式集，iis已經進行過net frame重新註冊,bin文件夾也設置了everyone許可權，無論怎麼搗騰，都提示無法載入相應的程式，通過查閱網上N多資料，終於找到了相關設置方法，先記錄如下:錯誤信息: c_sharp_無法載入應用程式表現形式 處理方 ...
  • Winform生成安裝程式時配置自啟動
    1、右擊安裝編輯程式，在“視圖”菜單中，選擇“註冊表”。 2、創建“鍵”：HKCU\Software\Microsoft\Windows\CurrentVersion\Run 3、右鍵Run，新建“字元串值”。在屬性頁面設置name和value值（[TARGETDIR]Form1.exe）。 ...
  • NETCore調用AD域驗證
    一、添加引用 System.DirectoryServices System.DirectoryServices.AccountManagement 二、驗證代碼 聲明域 驗證代碼 三、開放埠 如果調用不通，需要防火牆開放389埠 ...
  • 在EF中使用Expression自動生成p=>new Entity(){X="",Y="",..}格式的Lambda表達式靈活實現按需更新
    一、基本介紹 回憶：最早接觸Expression是在學校接觸到EF的時候，發現where方法里的參數是Expression<Func<T,bool>>這麼一個類型，當初也只是看到了，也沒有過多的去探究，只是知道傳入lambda表達式使用即可，對於Expression和裡面的Func<T,bool>到 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類