?? requeststream.cs
字號(hào):
#region License
#endregion
using System;
using System.Collections;
using System.IO;
using System.Text;
using System.Web;
namespace WUSGControl.Web.Upload
{
internal class RequestStream
{
#region Fields
private ArrayList contentBody;
private FileStatus fileStatus;
private FileStream fs;
private ArrayList readBody;
private ReadStatus readStatus;
private string originalFileName;
#endregion
// Nested Types
public enum FileStatus : byte
{
// Fields
Close = 1,
Open = 0
}
public enum ReadStatus : byte
{
// Fields
NoRead = 0,
Read = 1
}
#region Properties
/// <summary>
///
/// </summary>
public ArrayList ContentBody
{
get { return this.contentBody; }
}
/// <summary>
///
/// </summary>
public FileStream FileStream
{
get { return this.fs; }
}
/// <summary>
///
/// </summary>
public FileStatus FStatus
{
get { return this.fileStatus; }
}
/// <summary>
///
/// </summary>
public string OriginalFileName
{
get { return this.originalFileName; }
}
/// <summary>
///
/// </summary>
public ArrayList ReadBody
{
get { return this.readBody; }
}
/// <summary>
///
/// </summary>
public ReadStatus RStatus
{
get { return this.readStatus; }
}
#endregion
/// <summary>
///
/// </summary>
/// <param name="preloadBytes"></param>
/// <param name="boundaryBytes"></param>
/// <param name="fileStream"></param>
/// <param name="fileStatus"></param>
/// <param name="readStatus"></param>
/// <param name="uploadFolder"></param>
/// <param name="writeToDisk"></param>
/// <param name="context"></param>
/// <param name="currFileName"></param>
public RequestStream(byte[] preloadBytes, byte[] boundaryBytes, FileStream fileStream,
FileStatus fileStatus, ReadStatus readStatus, string uploadFolder, bool writeToDisk,
HttpContext context, string currFileName)
{
this.readBody = new ArrayList();
this.contentBody = new ArrayList();
this.fs = null;
this.originalFileName = string.Empty;
this.fileStatus = FileStatus.Close;
this.readStatus = ReadStatus.NoRead;
this.originalFileName = currFileName;
this.fs = fileStream;
this.fileStatus = fileStatus;
this.readStatus = readStatus;
//關(guān)心ReadBody是怎么變化的。
int preloadPosition = 0; //又一次從頭檢測(cè)，好像算法有點(diǎn)問題,每次都從第一個(gè)字節(jié)處判斷
////Utils.2writem("("preloadBytes的內(nèi)容是 is" + Utils.GetContext().Request.ContentEncoding.GetString(preloadBytes) + "長(zhǎng)度為 " + preloadBytes.Length);
//Utils.2writem("("preloadBytes的長(zhǎng)度為 " + preloadBytes.Length);
while ((preloadPosition < preloadBytes.Length))//循環(huán)判斷各節(jié)字符串，分別作處理
{
ArrayList list1 = new ArrayList();//這里面存什么呢
//byte[] a = Encoding.ASCII.GetString(new byte(){13});
byte[] a = new byte[]{10};
//If char is \r
#region ifchar 換行符
if (preloadBytes[preloadPosition] == 13)
{
int boundaryPosition = 0;
//這個(gè)while檢測(cè)是什么意圖呢
while (((preloadPosition < preloadBytes.Length) && (boundaryPosition < boundaryBytes.Length)))
{
if (preloadBytes[preloadPosition] != boundaryBytes[boundaryPosition])
{
break;
}
list1.Add(preloadBytes[preloadPosition]);
boundaryPosition++;
}
#region if 邦定字符的位置如果等行邦定字節(jié)的長(zhǎng)度, 說明到了分界線了
if (boundaryPosition == boundaryBytes.Length)//如果相等說明可以讀取其內(nèi)容了,其內(nèi)容為 "-----------------------------7d7280128049a\r\nContent-Disposition: form-data; name=\"__VIEWSTATE\"\r\n\r\ndDwxNjk4Njk0NTk0Ozs+9KBJXRpZpdzppfF8bpovAWWEL4w=\r\n-----------------------------7d7280128049a\r\nContent-Disposition: form-data; name=\"file1\"; filename=\"C:\\Documents and Settings\\Administrator\\桌面\\課題公關(guān).txt\"\r\nContent-Type: text/plain\r\n\r\n????\r\n?е?\r\n\r\n??\r\n塢asp.net?ajax\r\n-----------------------------7d7280128049a\r\nContent-Disposition: form-data; name=\"btnUpload\"\r\n\r\nUpload file\r\n-----------------------------7d7280128049a--\r\n
{
//Utils.2writem("("分界線一次 boundaryPosition == boundaryBytes.Length條件成立, this.contentBody開始賦值" + "preloadBytes 的長(zhǎng)度為 " + preloadBytes.Length);
if (this.fileStatus == FileStatus.Open)//當(dāng)解析到最后則關(guān)閉文件流
{
//Utils.2writem("("文件關(guān)閉");
this.fs.Flush();
this.fs.Close();
this.fileStatus = FileStatus.Close;
this.originalFileName = string.Empty;
}
else if (this.readStatus == ReadStatus.NoRead)
{
this.readStatus = ReadStatus.Read;
context.Items["Sunrise_Web_Upload_FileStatus"] = this.fileStatus;//第一次保存文件的開關(guān)狀態(tài)
}
if ((preloadPosition + 2) < preloadBytes.Length)
{
list1.Add(preloadBytes[preloadPosition]);
preloadPosition++;
list1.Add(preloadBytes[preloadPosition]);
preloadPosition++;
ArrayList list2 = new ArrayList();//Content-Disposition:
#region while2 //開始解析文件名等
while ((preloadPosition < preloadBytes.Length))
{
list1.Add(preloadBytes[preloadPosition]);
if (preloadBytes[preloadPosition] == 13)
{
byte[] buffer = new byte[list2.Count];
list2.CopyTo(buffer);
//Get request content from buffer
string requestContent = Utils.GetContext().Request.ContentEncoding.GetString(buffer);
//"Content-Disposition: form-data; name=\"__VIEWSTATE\""
//If this line is content head
if (requestContent.IndexOf("\"; filename=\"") > 0)
{
preloadPosition++;
ArrayList list3 = new ArrayList();
#region 4while
while ((preloadPosition < preloadBytes.Length))
{
list1.Add(preloadBytes[preloadPosition]);
if (preloadBytes[preloadPosition] == 13)
{
if ((preloadPosition + 3) < preloadBytes.Length)
{
char[] spliter = new char[1]{';'};
string[] contentArray = requestContent.Split(spliter);
string fileNameString = contentArray[2].Trim();
fileNameString = fileNameString.Substring(10, (fileNameString.Length - 11));//@"C:\Documents and Settings\Administrator\桌面\課題公關(guān).txt"
#region if
if ((writeToDisk && (fileNameString != null)) && (fileNameString != string.Empty))
{
this.originalFileName = Path.GetFileName(fileNameString);//"課題公關(guān).txt"
preloadPosition += 3;
byte[] buffer2 = new byte[list3.Count];
list3.CopyTo(buffer2);
string contentType = Utils.GetContext().Request.ContentEncoding.GetString(buffer2);//"\nContent-Type: text/plain"
string guidFileName = (Guid.NewGuid().ToString() + Path.GetExtension(fileNameString));
string fileFullPath = uploadFolder;
//If upload folder deos not exist, use system temporary folder to hold the file.
if (fileFullPath == string.Empty)
{
fileFullPath = Path.GetTempPath();
}
fileFullPath = Path.Combine(fileFullPath, guidFileName);//@"C:\WINDOWS\TEMP\a383bb31-f5db-44b5-9113-4640e8f1ddeb.txt"
//Build the content head
StringBuilder sb = new StringBuilder();
string[] sbArray = new string[11];
sbArray[0] = "\r\n";
sbArray[1] = contentArray[0];
sbArray[2] = ";";
sbArray[3] = contentArray[1];
sbArray[4] = "\r\n\r\n";
sbArray[5] = contentType.Trim();
sbArray[6] = ";filename=\"";
sbArray[7] = fileNameString;
sbArray[8] = "\";filepath=\"";
sbArray[9] = guidFileName;
sbArray[10] = "\"";
sb.Append(string.Concat(sbArray));
//Save boundary bytes to server file //字節(jié)保存到服務(wù)器中
this.fs = new FileStream(fileFullPath, FileMode.Create);
//Utils.2writem("("創(chuàng)件文件："+fileFullPath);
context.Items["Sunrise_Web_Upload_FileStream"] = this.fs;
this.fileStatus = FileStatus.Open;
context.Items["Sunrise_Web_Upload_FileStatus"] = this.fileStatus;
Hashtable ht = ((Hashtable) context.Items["Sunrise_Web_Upload_FileList"]);
ht.Add(Path.GetFileNameWithoutExtension(guidFileName), fileFullPath);
context.Items["Sunrise_Web_Upload_FileList"] = ht;
this.readBody.AddRange(boundaryBytes);
this.readBody.AddRange(Encoding.UTF8.GetBytes(sb.ToString().ToCharArray()));
sb.Remove(0, sb.Length);
break;
}
#endregion
preloadPosition++;
break;
}
this.contentBody.AddRange(list1);
break;
}
list3.Add(preloadBytes[preloadPosition]);
preloadPosition++;
}
#endregion
break;
}
this.readStatus = ReadStatus.NoRead;
this.readBody.AddRange(list1);
break;
}
list2.Add(preloadBytes[preloadPosition]);
preloadPosition++;
}
#endregion while2
if (preloadPosition < preloadBytes.Length)
{
preloadPosition++;
continue;
}
this.contentBody.AddRange(list1);
preloadPosition++;
continue;
}
this.contentBody.AddRange(list1);
}
#endregion if
else if (preloadPosition < preloadBytes.Length)
{
if (this.fileStatus == FileStatus.Open)//包含/r但不是分界線
{
byte[] buffer4 = new byte[list1.Count];
for(int i = 0; i < list1.Count; i++)
{
buffer4[i] = ((byte) list1[i]);
}
this.fs.Write(buffer4, 0, buffer4.Length);//
//Utils.2writem("("寫文件流 第二層位置,流中包括元素 /r了" + preloadPosition);
}
else if (this.readStatus == ReadStatus.NoRead)
{
this.readBody.AddRange(list1);
}
preloadPosition --;
}
else
{
this.contentBody.AddRange(list1);
}
}
#endregion ifchar
else if (this.fileStatus == FileStatus.Open)
{
//if(preloadPosition == 49151)
//Utils.2writem("("寫字節(jié)到文件的字節(jié)位置preloadPosition is " + preloadPosition);
this.fs.WriteByte(preloadBytes[preloadPosition]);
}
else if (this.readStatus == ReadStatus.NoRead)
{
this.readBody.Add(preloadBytes[preloadPosition]);//Encoding.ASCII.GetString(this.readBody[0])
}
preloadPosition++;
}
}
/// <summary>
/// Destructor method, release all resource
/// </summary>
~ RequestStream()
{
this.readBody = null;
this.contentBody = null;
this.fs = null;
}
}
}?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -