• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

c/s模式(C#)下Ftp的多文件上传及其上传进度

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

因为项目要求,制作的一个多文件上传,并显示进度条一段代码(vs2005环境)。
(只为粗略的实现,代码并不规范)

当多个文件上传的时候,需要依次队列形式一个个上传,当上传某个文件的时候,锁定进程,上传完毕再开启锁。

在主类中的上传按钮事件代码: 

     //获取openFileDialog控件选择的文件名数组(openFileDialog可多个文件选择)
        private void button1_Click(object sender, EventArgs e)
        {
            label1.Text = "";
            try
            {
                this.openFileDialog1.ShowDialog();
                path = this.openFileDialog1.FileNames;  //获取openFileDialog控件选择的文件名数组
                string strpath = "";
                for (int y = 0; y < path.Length; y++)
                {
                    strpath += path[y];
                }
                textBox1.Text = strpath;
            }
            catch
            {
                this.lbl_ftpStakt.Text = "请选择文件!";
            }
        }

 

 
     //上传按钮事件
        private void button2_Click(object sender, EventArgs e)
        {
            this.lbl_ftpStakt.Visible = true;   //设置上传信息标签可见
            this.lbl_ftpStakt.Text = "连接服务器...";            
            
            try
            {  
                for (i = 0; i < path.Length; i++)
                {
                    filename = path[i].ToString();

                    //实例化事件类
                    myTest fo = new myTest(filename);
                    fo.startUpEvent+=new myTest.myUpEventsHandler(this.RunsOnWorkerThread); //注册事件
                    fo.mythreadStart(); //调用类的方法
                   
                    FileInfo p = new FileInfo(path[i].ToString());
                    uploadSQL(p.Name);  //上传到库
                }
                //label1.Text = "上传成功";
            }
            catch
            {
                string s="";
                for (int x = i; x < path.Length; x++)
                {
                    FileInfo file = new FileInfo(path[i].ToString());
                    s += file.Name + " ";
                }
                    this.lbl_ftpStakt.Text = "上传失败";
                MessageBox.Show(s.ToString()+" 上传失败","提示");
            }
        }
     //连接ftp上传
        public void RunsOnWorkerThread(string _filename)
        {
            //阻塞线程
            mt.WaitOne();
            Interlocked.Increment(ref flag);    //状态值+1

            this.lbl_ftpStakt.Text = "连接服务器中...";
            FileInfo fileInf = new FileInfo(_filename);
            FtpWebRequest reqFTP;
            // 根据uri创建FtpWebRequest对象 
            reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://210.82.***.***/" + fileInf.Name));
            // ftp用户名和密码
            reqFTP.Credentials = new NetworkCredential("record", "files");
            // 默认为true,连接不会被关闭
            // 在一个命令之后被执行
            reqFTP.KeepAlive = false;
            // 指定执行什么命令
            reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
            // 指定数据传输类型
            reqFTP.UseBinary = true;
            // 上传文件时通知服务器文件的大小
            reqFTP.ContentLength = fileInf.Length;
            //long _length = fileInf.Length;  /////////
            // 缓冲大小设置为2kb
            int buffLength = 2048;  ////
            byte[] buff = new byte[buffLength];
            int contentLen;
            // 打开一个文件流 (System.IO.FileStream) 去读上传的文件
            FileStream fs = fileInf.OpenRead();

            try
            {
                // 把上传的文件写入流
                Stream strm = reqFTP.GetRequestStream();
                // 每次读文件流的2kb
                contentLen = fs.Read(buff, 0, buffLength);
                int allbye = (int)fileInf.Length;
                int startbye = 0;
                this.myProgressControl.Maximum = allbye;
                this.myProgressControl.Minimum = 0;
                this.myProgressControl.Visible = true;
                this.lbl_ftpStakt.Visible = true;
                this.lbl_ftpStakt.Text = "服务器连接中...";
                // 流内容没有结束
                while (contentLen != 0)
                {
                    // 把内容从file stream 写入 upload stream
                    strm.Write(buff, 0, contentLen);
                    contentLen = fs.Read(buff, 0, buffLength);
                    startbye += contentLen;
                    this.lbl_ftpStakt.Text = "已上传:" + (int)(startbye / 1024) + "KB/" + "总长度:" + (int)(allbye / 1024) + "KB" + " " + " 文件名:" + fileInf.Name;
                    myProgressControl.Value = startbye;
                }
                // 关闭两个流
                strm.Close();
                fs.Close();
                this.myProgressControl.Visible = false;
                this.lbl_ftpStakt.Text = "上传成功!";
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message, "Upload Error");
            }
            Interlocked.Decrement(ref flag);
            mt.ReleaseMutex();//释放线程
        }

 

处理上传线程的委托事件类

   /// <summary>
    /// 委托事件类
    /// </summary>
    class myTest
    {
        public string filename;
        public delegate void myUpEventsHandler(string _filename);
        public event myUpEventsHandler startUpEvent;

        public myTest()
        {
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="_filename">上传的文件名</param>
        public myTest(string _filename)
        {
            this.filename = _filename;
        }

        /// <summary>
        /// 开始一个线程,执行事件
        /// </summary>
        public void mythreadStart()
        {
            Thread thr = new Thread(new ThreadStart(this.mystart));
            thr.Start();
        }

        /// <summary>
        /// 开始事件
        /// </summary>
        public void mystart()
        {
            startUpEvent(this.filename);
        }
    }

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C#winform窗体在桌面右下角显示(任务栏上方)发布时间:2022-07-13
下一篇:
c++任意类型Any类的实现发布时间:2022-07-13
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap