進(jìn)度的上傳使用

1.組件HttpUploadModule.cs,Progress.cs

2.頁面Default.* Progress.*


1.組件方面(HttpUploadModule.cs)
using System;
using System.Collections;
using System.Collections.Specialized;
using System.Globalization;
using System.IO;
using System.Text;
using System.Web;

using System.Reflection;

namespace Openlab.Web.Upload
{
	/// <summary>
	/// 給asp.net默認(rèn)的上傳組件加上進(jìn)度條反映
	/// </summary>
	/// <Author>寶玉 (http://www.webuc.net)</Author>
	/// <Links>
	/// http://www.cnforums.net
	/// http://www.communtiyserver.cn
	/// http://blog.joycode.com
	/// </Links>
	public class HttpUploadModule: IHttpModule
	{
		public HttpUploadModule()
		{
			
		}

		public void Init(HttpApplication application)
		{
			application.BeginRequest += new EventHandler(this.Application_BeginRequest);
			application.EndRequest += new EventHandler(this.Application_EndRequest);
			application.Error += new EventHandler(this.Application_Error);
		}

		public void Dispose()
		{
		}

		private void Application_BeginRequest(Object sender, EventArgs e)
		{
			HttpApplication app = sender as HttpApplication;
			HttpWorkerRequest request = GetWorkerRequest(app.Context);
			Encoding encoding = app.Context.Request.ContentEncoding;

			int bytesRead = 0; // 已讀數(shù)據(jù)大小
			int read; // 當(dāng)前讀取的塊的大小
			int count = 8192; // 分塊大小
			byte[] buffer; // 保存所有上傳的數(shù)據(jù)
			string uploadId; // 唯一標(biāo)志當(dāng)前上傳的ID
			Progress progress; // 記錄當(dāng)前上傳的進(jìn)度信息

			if (request != null)
			{
				// 返回 HTTP 請(qǐng)求正文已被讀取的部分。
				//
				byte[] tempBuff = request.GetPreloadedEntityBody();
				
				// 如果是附件上傳
				//
				if (
					tempBuff != null 
					&& IsUploadRequest(app.Request)
					)
				{
					// 獲取上傳大小
					// 
					long length = long.Parse(request.GetKnownRequestHeader(HttpWorkerRequest.HeaderContentLength));
					// 當(dāng)前上傳的ID，用來唯一標(biāo)志當(dāng)前的上傳
					// 用此UploadID，可以通過其他頁面獲取當(dāng)前上傳的進(jìn)度
					//
					uploadId = app.Context.Request.QueryString["UploadID"];
					
					// 開始記錄當(dāng)前上傳狀態(tài)
					//
					progress = new Progress(length, uploadId);
					progress.SetState(UploadState.ReceivingData);
					
					buffer = new byte[length];
					count = tempBuff.Length; // 分塊大小

					// 將已上傳數(shù)據(jù)復(fù)制過去
					//
					Buffer.BlockCopy(tempBuff, 0, buffer, bytesRead, count);

					// 開始記錄已上傳大小
					//
					bytesRead = tempBuff.Length;
					progress.SetBytesRead(bytesRead);
					SetProgress(uploadId, progress, app.Application);

					// 循環(huán)分塊讀取，直到所有數(shù)據(jù)讀取結(jié)束
					//
					while (request.IsClientConnected() &&
						!request.IsEntireEntityBodyIsPreloaded() &&
						bytesRead < length
						)
					{
						// 如果最后一塊大小小于分塊大小，則重新分塊
						//
						if (bytesRead + count > length)
						{
							count = (int)(length - bytesRead);
							tempBuff = new byte[count];
						}

						// 分塊讀取
						//
						read = request.ReadEntityBody(tempBuff, count);
						
						// 復(fù)制已讀數(shù)據(jù)塊
						//
						Buffer.BlockCopy(tempBuff, 0, buffer, bytesRead, read);
						
						// 記錄已上傳大小
						//
						bytesRead += read;
						progress.SetBytesRead(bytesRead);
						SetProgress(uploadId, progress, app.Application);

					}
					if (
						request.IsClientConnected() &&
						!request.IsEntireEntityBodyIsPreloaded()
						)
					{
				
						// 傳入已上傳完的數(shù)據(jù)
						//
						InjectTextParts(request, buffer);

						// 表示上傳已結(jié)束
						//
						progress.SetBytesRead(bytesRead);
						progress.SetState(UploadState.Complete);
						SetProgress(uploadId, progress, app.Application);

					}
				}
			}
		}

		/// <summary>
		/// 結(jié)束請(qǐng)求后移除進(jìn)度信息
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void Application_EndRequest(Object sender, EventArgs e)
		{
			HttpApplication app = sender as HttpApplication;

			if (IsUploadRequest(app.Request))
			{
				SetUploadState(app, UploadState.Complete);
				RemoveFrom(app);
			}

		}	

		/// <summary>
		/// 如果出錯(cuò)了設(shè)置進(jìn)度信息中狀態(tài)為“Error”
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void Application_Error(Object sender, EventArgs e)
		{
			HttpApplication app = sender as HttpApplication;

			if (IsUploadRequest(app.Request))
			{
				SetUploadState(app, UploadState.Error);
			}

		}

		/// <summary>
		/// 設(shè)置當(dāng)前上傳進(jìn)度信息的狀態(tài)
		/// </summary>
		/// <param name="app"></param>
		/// <param name="state"></param>
		void SetUploadState(HttpApplication app, UploadState state)
		{
			string uploadId = app.Request.QueryString["UploadID"];
			if (uploadId != null && uploadId.Length > 0)
			{
				Progress progress = GetProgress(uploadId, app.Application);
				if (progress != null)
				{
					progress.SetState(state);
					SetProgress(uploadId, progress, app.Application);
				}		
			}
		}

		/// <summary>
		/// 設(shè)置當(dāng)前上傳的進(jìn)度信息
		/// 根據(jù)UploadID記錄在Application中
		/// </summary>
		/// <param name="uploadId"></param>
		/// <param name="progress"></param>
		/// <param name="application"></param>
		void SetProgress(string uploadId, Progress progress, HttpApplicationState application)
		{
			if (uploadId == null || uploadId == string.Empty || progress == null)
				return;
			application.Lock();
			application["OpenlabUpload_" + uploadId] = progress;
			application.UnLock(); 
		}

		/// <summary>
		/// 從Application中移出進(jìn)度信息
		/// </summary>
		/// <param name="app"></param>
		void RemoveFrom(HttpApplication app)
		{
			string uploadId = app.Request.QueryString["UploadID"];
			HttpApplicationState application = app.Application;
			if (uploadId != null && uploadId.Length > 0)
			{
				application.Remove("OpenlabUpload_" + uploadId);
			}
		}

		/// <summary>
		/// 根據(jù)UploadID獲取上傳進(jìn)度信息
		/// </summary>
		/// <param name="uploadId"></param>
		/// <param name="application"></param>
		/// <returns></returns>
		public static Progress GetProgress(string uploadId, HttpApplicationState application)
		{
			Progress progress = application["OpenlabUpload_" + uploadId] as Progress;
			return progress;
		}

		HttpWorkerRequest GetWorkerRequest(HttpContext context)
		{

			IServiceProvider provider = (IServiceProvider)HttpContext.Current;
			return (HttpWorkerRequest)provider.GetService(typeof(HttpWorkerRequest));
		}

		/// <summary>
		/// 傳入已上傳完的數(shù)據(jù)
		/// </summary>
		/// <param name="request"></param>
		/// <param name="textParts"></param>
		void InjectTextParts(HttpWorkerRequest request, byte[] textParts)
		{
			BindingFlags bindingFlags = BindingFlags.Instance | BindingFlags.NonPublic; 
			
			Type type = request.GetType(); 
			
			while ((type != null) && (type.FullName != "System.Web.Hosting.ISAPIWorkerRequest"))
			{ 
				type = type.BaseType; 
			}

			if (type != null)
			{
				type.GetField("_contentAvailLength", bindingFlags).SetValue(request, textParts.Length); 
				type.GetField("_contentTotalLength", bindingFlags).SetValue(request, textParts.Length);
				type.GetField("_preloadedContent", bindingFlags).SetValue(request, textParts); 
				type.GetField("_preloadedContentRead", bindingFlags).SetValue(request, true);
			}
		}

		private static bool StringStartsWithAnotherIgnoreCase(string s1, string s2)
		{
			return (string.Compare(s1, 0, s2, 0, s2.Length, true, CultureInfo.InvariantCulture) == 0);
		}

		/// <summary>
		/// 是否為附件上傳
		/// 判斷的根據(jù)是ContentType中有無multipart/form-data
		/// </summary>
		/// <param name="request"></param>
		/// <returns></returns>
		bool IsUploadRequest(HttpRequest request)
		{
			return StringStartsWithAnotherIgnoreCase(request.ContentType, "multipart/form-data");
		}
	}
}

2.Progress.cs
using System;

namespace Openlab.Web.Upload
{
	/// <summary>
	/// 上傳狀態(tài)
	/// </summary>
	public enum UploadState
	{
		/// <summary>
		/// 正在接收數(shù)據(jù)
		/// </summary>
		ReceivingData,
		/// <summary>
		/// 已完成
		/// </summary>
		Complete,
		/// <summary>
		/// 上傳錯(cuò)誤.
		/// </summary>
		Error
	}

	/// <summary>
	/// 上傳進(jìn)度信息
	/// </summary>
	public class Progress
	{
		long contentLength = 0;
		long bytesRead;
		DateTime start;
		string uploadId = "";
		UploadState state;

		public Progress(long contentLength, string uploadId)
		{
			this.contentLength = contentLength;
			start = DateTime.Now;
			this.uploadId = uploadId;
		}

		public void SetBytesRead(long bytesRead)
		{
			lock (this)
			{
				this.bytesRead = bytesRead;
			}
		}


		public void SetState(UploadState state)
		{
			lock (this)
			{
				this.state = state;
			}
		}

		/// <summary>
		/// 總大小
		/// </summary>
		public long ContentLength
		{
			get
			{
				return contentLength;