广

ASP.NET

  • IOS开发
  • android开发
  • PHP编程
  • JavaScript
  • ASP.NET
  • ASP编程
  • JSP编程
  • Java编程
  • 易语言
  • Ruby编程
  • Perl编程
  • AJAX
  • 正则表达式
  • C语言
  • 编程开发

    HTTP协议下用Web Service上传大文件的解决方案

    2018-05-07 10:24:58 次阅读 稿源:互联网
    广告
    用HTTP协议上传大文件也许是个不好办的问题。主要是它的不连续性,使得上传文件感觉很“危险”。特别是很大的文件(几百MB甚至是上G的文件),心里总觉得不踏实,一不小心就会出现问题,而一但出现问题就无法继续上传,这是很郁闷的。

    后来在一些网站上找到一些上传文件的组件,但都是要用到一些COM组件。至于后来的ASP.net下上传大文件的解决方案,我也做过一个组件,后来发现根本就不用自己写什么组件,利用ASP.net自己的上传方法也可以解决大文件上传,真是郁闷的要死了。。。。

    回想之后,决定用Web service来做一个文件上传,还是利用HTTP协议,这样不用在服务器上做太多的变动,而客户端也简单。

    首先是解决方案的设计:因为Web service可以利用SOAP来传递数据,而且可以传递十进制数据,因此可以想到,在服务上公开一个方法,参数可以是byte数组,这样可以把文件分块的上传到服务器。这一解决方法我做过,但速度很慢。后来在MS上找到一些文章,用MS最新公开的服务组件上传文件,速度快了很多。而自己所要做的就是组织一些安全性的问题。

    部份代码:Upload Instance

    代码如下:

    using System; 
    using System.IO; 
    using Microsoft.Web.Services2; 
    using Microsoft.Web.Services2.Dime; 

    namespace Webb.WAVE.WinUpload 

    /**//// <summary> 
    /// Summary description for Controls. 
    /// </summary> 
    public class UploadInstance2 

    Fields#region Fields 
    private string m_GUID; 
    private DateTime m_uploadTime; 
    private long m_fileLength; 
    private long m_currentPoint; 
    private string m_pathOnserver; 
    private long m_userID; 
    #endregion 

    Properties#region Properties 
    public long UserID 

    get{return this.m_userID;} 
    set{this.m_userID=value;} 

    public string GUID 

    get{return this.m_GUID;} 
    set{this.m_GUID=value;} 

    public DateTime UploadTime 

    get{return this.m_uploadTime;} 
    set{} 

    public long FileLength 

    get{return this.m_fileLength;} 
    set{this.m_fileLength=value;} 

    public long CurrentPoing 

    get{return this.m_currentPoint;} 
    set{this.m_currentPoint=value;} 

    public string PathOnServer 

    get{return this.m_pathOnserver;} 
    set{this.m_pathOnserver=value;} 

    public string FullPathOnServer 

    get 

    if(this.m_GUID!=string.Empty&&this.m_pathOnserver!=string.Empty) 

    return Path.Combine(this.m_pathOnserver,this.m_GUID+".rem"); 

    else 

    return string.Empty; 



    public string FileName 

    get 

    if(this.m_GUID!=string.Empty) 

    return this.m_GUID+".rem"; 

    else 

    return string.Empty; 




    #endregion 

    public UploadInstance2() 

    this.m_GUID = System.Guid.NewGuid().ToString(); 
    this.m_uploadTime = System.DateTime.Now; 
    this.m_currentPoint = 0; 
    this.m_fileLength = 0; 
    this.m_pathOnserver = string.Empty; 

    public UploadInstance2(string i_path,string i_GUID,long i_fileLength) 

    string m_fullPath = Path.Combine(i_path,i_GUID); 
    if(!File.Exists(m_fullPath)) return; 
    this.m_GUID = i_GUID; 
    this.m_uploadTime = System.DateTime.Now; 
    this.m_pathOnserver = i_path; 
    FileInfo m_fileInfo = new FileInfo(m_fullPath); 
    this.m_currentPoint = m_fileInfo.Length; 
    this.m_fileLength = i_fileLength; 


    public bool UploadData(byte[] i_data, long i_currentPoint, int i_dataSize) 

    string m_fullPath = this.FullPathOnServer; 
    if(!File.Exists(m_fullPath)&&this.m_currentPoint!=0)return false; 
    long m_filePoint = new FileInfo(m_fullPath).Length; 
    if(m_filePoint!=i_currentPoint) return false; 
    FileStream m_fileStream = new FileStream(m_fullPath,FileMode.Append); 
    m_fileStream.Write(i_data,0,i_dataSize); 
    m_fileStream.Close(); 
    return true; 


    public void AbandantUpload() 

    string m_fullPath = this.FullPathOnServer; 
    try{File.Delete(m_fullPath);} 
    catch{} 


    public void CreateFile() 

    string m_fullPath = this.FullPathOnServer; 
    if(!File.Exists(m_fullPath)) 

    File.Create(m_fullPath).Close(); 

    else 

    try 

    File.Delete(m_fullPath); 
    }catch{} 
    File.Create(m_fullPath).Close(); 





    上传过程:
    代码如下:

    #region UploadProcess 
    public void UploadProcess() 

    DateTime m_start = DateTime.Now; 
    this.textBox_OutMsg.AppendText("Initialize upload/r/n"); 
    if(this.m_upload==null||this.m_uploadGUID==null||this.m_uploadGUID==string.Empty) 
    {  
    this.textBox_OutMsg.AppendText("Upload instance id error or login to the server faild/r/n"); 
    this.textBox_OutMsg.AppendText("Upload faild./r/n"); 
    return; 

    this.textBox_OutMsg.AppendText("Open file/r/n"); 
    if(this.m_filePath==null||this.m_filePath==string.Empty||!File.Exists(this.m_filePath)) 

    this.textBox_OutMsg.AppendText("Open file error/r/n"); 
    this.textBox_OutMsg.AppendText("Upload faild./r/n"); 
    return; 

    FileInfo m_fileInfo = new FileInfo(this.m_filePath); 
    FileStream m_fs = new FileStream(this.m_filePath, FileMode.Open, FileAccess.Read); 
    this.textBox_OutMsg.AppendText("Start upload file/r/n"); 
    int m_buffer = 10; //KBytes 
    long m_currentPoint = 0; 
    long m_fileLength = m_fileInfo.Length; 
    bool m_uploadResult = false; 
    byte[] m_data = new byte[m_buffer*1024]; 
    long m_readBytes = m_fs.Read(m_data, 0, m_buffer*1024); 
    this.UploadProcessBar.Maximum = 100; 
    this.UploadProcessBar.Minimum = 0; 
    while(m_readBytes>0) 

    MemoryStream m_memoryStream = new MemoryStream(m_data, 0,(int)m_readBytes); 
    DimeAttachment dimeAttach = new DimeAttachment("image/gif", TypeFormat.MediaType, m_memoryStream); 
    this.m_upload.RequestSoapContext.Attachments.Add(dimeAttach); 
    m_uploadResult = this.m_upload.UploadFileData(this.m_uploadInstance,m_currentPoint,m_readBytes); 
    if(m_uploadResult) 

    m_currentPoint +=m_readBytes; 
    m_readBytes = m_fs.Read(m_data,0,m_buffer*1024); 
    // this.textBox_OutMsg.AppendText("Uploading:"+m_currentPoint.ToString()+"/"+m_fileLength.ToString()+"/r/n"); 
    this.UploadProcessBar.Value = (int)(m_currentPoint*100/m_fileLength); 
    this.label_outPercent.Text = this.UploadProcessBar.Value.ToString()+"%"; 

    else 

    this.textBox_OutMsg.AppendText("Upload file error./r/n"); 
    m_fs.Close(); 
    this.m_upload.AbandantUpload(this.m_uploadInstance); 
    return; 


    this.textBox_OutMsg.AppendText("File upload finished./r/n"); 
    this.button_Cancel.Enabled = false; 
    m_fs.Close(); 
    this.ResetForm(); 

    #endregion 


    测试项目代码:
    http://test.0579fw.com/myfile/kiyeer/客户上传/webbwinupload.zip

    出现错误的解决方法:
    *****************************************************

     引用内容
    Error 1 'WinFormTest.localhost.WebbWinUpload' does not contain a definition for 'RequestSoapContext' D:/WebbWinUpload/WinFormTest/WebbWinUpload.cs 448 19 WinFormTest 

    当你更新Web引用的时候,.net自动生成的Web引用为: 
    public class WebbWinUpload : System.Web.Services.Protocols.SoapHttpClientProtocol 
    请转化为: 
    public class WebbWinUpload : Microsoft.Web.Services2.WebServicesClientProtocol 
    查找引用下自动生成的C#文件Reference.cs

    一起学吧部分文章转载自互联网,供读者交流和学习,若有涉及作者版权等问题请及时与我们联系,以便更正、删除或按规定办理。感谢所有提供资讯的网站,欢迎各类媒体与一起学吧进行文章共享合作。

    广告
    广告
    广告