asp.net实现 文件断点续传的功能

作者:袖梨 2022-06-25

asp教程.net实现 文件断点续传的功能
1.文件断点续传的功能由接收方管理。

2.在每次文件接收中断的时候,会创建一个等待续传的项目对象,使用resumedfileitem类来封装相关的信息。

 

   ///


    /// 有可能被续传的项目。
    ///

    public class resumedfileitem
    {
        #region senderid
        private string senderid;
        ///
        /// 发送者的id。
        ///

        public string senderid
        {
            get { return senderid; }
            set { senderid = value; }
        }
        #endregion

        #region originfilepath
        private string originfilepath;
        ///


        /// 发送方发送的文件的全路径。
        ///

        public string originfilepath
        {
            get { return originfilepath; }
            set { originfilepath = value; }
        }
        #endregion

        #region originfilesize
        private long originfilesize = 0;
        ///


        /// 发送方发送的文件的大小。
        ///

        public long originfilesize
        {
            get { return originfilesize; }
            set { originfilesize = value; }
        }
        #endregion

        #region originfilelastupdatetime
        private datetime originfilelastupdatetime;
        ///


        /// 发送方发送的文件的最后修改日期。
        ///

        public datetime originfilelastupdatetime
        {
            get { return originfilelastupdatetime; }
            set { originfilelastupdatetime = value; }
        }
        #endregion

        #region localtempfilesavepath
        private string localtempfilesavepath;
        ///


        /// 接收的临时文件的存储路径
        ///

        public string localtempfilesavepath
        {
            get { return localtempfilesavepath; }
            set { localtempfilesavepath = value; }
        }
        #endregion

        #region localfilesavepath
        private string localfilesavepath;
        ///


        /// 接收的文件存储路径
        ///

        public string localfilesavepath
        {
            get { return localfilesavepath; }
            set { localfilesavepath = value; }
        }
        #endregion

        #region receivedcount
        private long receivedcount = 0;
        ///


        /// 已经接收了多少字节数。
        ///

        public long receivedcount
        {
            get { return receivedcount; }
            set { receivedcount = value; }
        }
        #endregion

        #region disrupttedtime
        private datetime disrupttedtime = datetime.now;
        ///


        /// 接收中断的时间。
        ///

        public datetime disrupttedtime
        {
            get { return disrupttedtime; }
            set { disrupttedtime = value; }
        }
        #endregion
    }

 
    为何要记录如此多的信息了?这是为了当发送方再次发送同一文件给接收方时,接收方可以依据这些信息进行匹配,是否可以找到一个续传的项目,如果匹配成功,则表示可以进行续传。

      要记录的这些信息从哪里获取了?首先,是发送方在发送文件的时候,会将文件的相关信息告知接收方,如 被发送文件的全路径、被发送文件的大小、被发送的文件的最后修改日期等等;其次,当接收方接收文件时,就知道了临时文件的存储路径、正式文件的存储路径;再次,当文件传输中断的时刻,可以知道当前的文件已经被传递了多少字节。有了这些信息,断点续传才成为可能。  

 

3.使用iresumedfilemanager将所有的续传项目管理起来。

  

  public interface iresumedfilemanager
    {
        ///


        /// 当一个续传项超过多长时间没被使用,则将其移除,同时删除对应的临时文件。单位:秒。默认值:600。
        ///

        int ttl4resumedfileitem { get; set; }

        ///


        /// 是否启用文件的断点续传功能。默认值 true。
        ///

        bool enabled { get; set; }

        iagilelogger esflogger { set; }

        void initialize();

        void add(resumedfileitem resumedfileitem);

        ///


        /// 当接收一个文件之前,先看能否找到续传的匹配项(同时判断临时文件是否存在)。如果没有匹配,则返回null。
        ///

        resumedfileitem mapping4receive(transmittingfileinfo fileinfo);

        //


        /// 移除续传项。
        ///

        /// 要移除的续传项
        /// 是否同时删除临时文件
        void remove(resumedfileitem resumedfileitem, bool deletetempfile);       
    }
   

resumedfilemanager提供了定时删除过期的续传项目的功能,比如,一个续传项目在文件中断传输以后的10分钟内都没被激活,则视其为过期项目,将会被resumedfilemanager从内存中删除。这样就避免累积很多无效的续传项目对象,而浪费内存。

      resumedfilemanager的remove方法用于从内存中移除某个续传项目,其第二个参数表示是否删除临时文件,当某个续传项目因过期而被删除时,这时必须将临时文件也删除掉,以释放硬盘空间 -- 特别是对于作为文件服务器的服务端,这点更是重要的,否则,众多永远也不会被用到的临时文件将会浪费大量的硬盘空间。如果是因为找到匹配项而从管理器中移除续传项时,则不能删除临时文件,因为接下来临时文件会被继续使用。

 

4.当接收方在接收一个文件之前,首先调用iresumedfilemanager的mapping4receive方法寻找续传匹配项。当同时满足三个条件时(即originfilepath、originfilesize、originfilelastupdatetime),匹配才算成功。

if (item.originfilepath == fileinfo.originfilepath && item.originfilesize == fileinfo.filesize && item.originfilelastupdatetime == fileinfo.originfilelastupdatetime)
                    {
                        return item;
                    }

      如此,可以保证续传的文件与上次传输中断的文件是同一个文件。

 

5.当找到匹配项时,可以询问用户是否接受续传,esplus通过回调ifilebusinesshandler.readytoacceptfileasyn方法得到回复。

 string readytoacceptfileasyn(string senderid, string filename, long filelength, string comment, string fileid, resumedfileitem resumedfileitem);            
      如果返回值为null,表示拒绝接收;如果返回的存储路径与上次的存储路径相同,则表示同意续传;如果返回新的路径,则表示要求发送方重新发送整个文件。框架根据该方法的返回值而决定是否在后台启动续传。

 

 

6.如果同意续传,则接收方会告知发送方已接收的字节数,发送方可以从文件的对应偏移处开始发送后续数据。

rejectoracceptfilecontract协议说明了这一点。

    public class rejectoracceptfilecontract
    {
        #region fileid
        private string fileid;
        public string fileid
        {
            get { return fileid; }
            set { fileid = value; }
        }
        #endregion

        #region agree
        private bool agree;
        public bool agree
        {
            get { return agree; }
            set { agree = value; }
        }
        #endregion     

        #region receivedcount4resumefile
        private long receivedcount4resumefile = 0;
        ///


        /// 如果值非0,则表示续传,指示已经传递了多少字节。
        ///

        public long receivedcount4resumefile
        {
            get { return receivedcount4resumefile; }
            set { receivedcount4resumefile = value; }
        }
        #endregion
    }
 

7.如果续传开始,则接收方首先需要打开原始的临时文件,并寻址到正确的偏移处。

 this.fstream = new filestream(this.tempfilepath, filemode.open);
 this.fstream.seek(item.receivedcount, seekorigin.begin);


 

8.接下来就和以前一样进行正常的文件传输了。这样的设计,可以支持同一文件的无限次断点续传,也就是说,你在传送一个巨大文件的时候,哪怕中途断网很多次,也没关系,你不需要额外地重复传递哪怕一个字节。

 

相关文章

精彩推荐