C# - DevExpress ProgressBarControl 을 활용한 FTP 서버 접속해서 다운 받는 AutoUpdate 프로그램.

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Drawing;
using System.Windows.Forms;
using System.Net;
using System.IO;
using System.Diagnostics;
 
namespace AutoUpdate
{
    public partial class Form1 : DevExpress.XtraEditors.XtraForm
    {
 
        #region Property
 
        private string id = "";
        private string pass = "";
        private string path = string.Format(@"ftp://{0}:{1}", "", "");//FTP IP, PORT 번호
        private string fullPath = string.Format(@"ftp://{0}:{1}/{2}/{3}/", "", "", "", "");//FTP IP,PORT,접속할 폴더
        private BackgroundWorker worker;
 
        #endregion
 
        public Form1()
        {
            InitializeComponent();
 
            #region BackgroundWorker 설정
 
            worker = new BackgroundWorker();
            worker.WorkerReportsProgress = true;
            worker.WorkerSupportsCancellation = true;
            worker.DoWork += new DoWorkEventHandler(worker_DoWork);
            worker.ProgressChanged += new ProgressChangedEventHandler(worker_ProgressChanged);
            worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(worker_RunWorkerCompleted);
 
            #endregion
        }
 
 
        #region Load Methods
        private void Update_Load(object sender, EventArgs e)
        {
            worker.RunWorkerAsync();
        }
 
        #endregion
 
        #region FTP 접속 메서드
 
        /// <summary>
        /// FTP 접속 시 Response 객체 반환
        /// </summary>
        /// <param name="path">FTP 경로</param>
        /// <param name="method">FTP 접속 시 할 작업방법</param>
        /// <returns></returns>
 
        private FtpWebResponse FTPConnection(string path, string method)
        {
            FtpWebResponse response = null;
            try
            {
                FtpWebRequest ftpRequest = (FtpWebRequest)WebRequest.Create(path);
                ftpRequest.KeepAlive = false;
                ftpRequest.UseBinary = true;
                ftpRequest.Method = method;
                ftpRequest.Credentials = new NetworkCredential(id, pass);
 
                response = (FtpWebResponse)ftpRequest.GetResponse();
 
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message.ToString(), "ERROR"); ;
            }
            return response;
        }
        #endregion
 
        #region 이벤트
 
        #region 비동기로 실행할 작업
        private void worker_DoWork(object sender, DoWorkEventArgs e)
        {
            try
            {
                #region 서버에 접속 가능한지 먼저 체크.
 
                FtpWebResponse ConResult = FTPConnection(path, WebRequestMethods.Ftp.ListDirectory);
 
                if (ConResult != null)
                {
 
                    #region 서버 접속 확인 후 접근할 폴더로 접근후 폴더,파일목록 저장
 
                    List<string> list = new List<string>();//폴더내의 목록 저장할 변수
 
                    using (FtpWebResponse response = FTPConnection(fullPath, WebRequestMethods.Ftp.ListDirectory))
                    {
                        using (Stream ftpStream = response.GetResponseStream())
                        {
                            using (StreamReader reader = new StreamReader(ftpStream))
                            {
                                while (true)//존재하는 모든 폴더와 파일목록 저장.
                                {
                                    string line = reader.ReadLine();
 
                                    if (string.IsNullOrWhiteSpace(line)) break;
 
                                    list.Add(line);
                                }
                            }
                        }
                    }
                    #endregion
 
 
                    #region 저장해온 폴더,파일 체크 후 다운로드
 
                    #region 전체 파일용량 구하기
 
                    float totalSize = 0;
 
                    foreach (string item in list)
                    {
                        if (item.Contains("."))
                        {
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.GetFileSize))
                            {
                                using (Stream ftpStream = response.GetResponseStream())
                                {
                                    totalSize += response.ContentLength;
                                }
                            }
                        }
                        else
                        {
                            #region 폴더일 경우 한번 더 아래로 진입 후 하위목록 가져오기
 
                            List<string> lowList = new List<string>();//폴더일 경우 한번더 들어가서 하위의 파일들을 저장하기 위한 변수
 
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.ListDirectory))
                            {
                                using (Stream ftpStream = response.GetResponseStream())
                                {
                                    using (StreamReader reader = new StreamReader(ftpStream))
                                    {
                                        while (true)//존재하는 모든 폴더와 파일목록 저장.
                                        {
                                            string line = reader.ReadLine();
 
                                            if (string.IsNullOrWhiteSpace(line)) break;
 
                                            lowList.Add(line);
                                        }
                                    }
                                }
                            }
 
                            #endregion
 
                            foreach (string lowItem in lowList)
                            {
                                using (FtpWebResponse response = FTPConnection(fullPath + item + "/" + lowItem, WebRequestMethods.Ftp.GetFileSize))
                                {
                                    using (Stream ftpStream = response.GetResponseStream())
                                    {
                                        totalSize += response.ContentLength;
                                    }
                                }
                            }
 
                        }
                    }
 
                    #endregion
 
                    foreach (string item in list)
                    {
 
                        if (item.Contains("."))//폴더가 아닌 파일일 경우 로컬로 다운로드.
                        {
 
                            #region 해당 파일의 사이즈와 수정시간 저장
                            float fileSize;//FTP서버의 해당 파일사이즈를 저장하기 위한 변수.
 
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.GetFileSize))
                            {
                                using (Stream ftpStream = response.GetResponseStream())
                                {
                                    fileSize = response.ContentLength;
                                }
                            }
 
                            DateTime ftpDt;//해당 파일의 마지막 수정시간을 저장하기 위한 변수.
 
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.GetDateTimestamp))
                            {
                                ftpDt = response.LastModified;
                            }
 
                            #endregion
 
                            //다운로드 시작.
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.DownloadFile))
                            {
 
                                DateTime localDt = DateTime.Parse("2000-01-01");//해당 파일이 없을 경우 DateTime입력. 새로운 파일을 다운로드하기위함.
 
                                FileInfo fi = new FileInfo(Application.StartupPath + "\\" + item);
 
                                if (fi.Exists)
                                {
                                    localDt = Directory.GetLastWriteTime(Application.StartupPath + "\\" + item);//LOCAL의 파일의 마지막 수정시간
                                }
 
                                if (0 < DateTime.Compare(ftpDt, localDt))//수정한 시간이 FTP서버파일이 더 최신이면 다운로드
                                {
                                    using (Stream ftpStream = response.GetResponseStream())
                                    {
                                        using (FileStream fs = new FileStream(Application.StartupPath + "\\" + item, FileMode.Create,
                                                                            FileAccess.Write, FileShare.None))
                                        {
                                            byte[] buffer = new byte[(int)fileSize];
                                            int readBytes = 0;
                                            while ((readBytes = ftpStream.Read(buffer, 0, buffer.Length)) > 0)
                                            {
                                                fs.Write(buffer, 0, readBytes);
                                                int progress = (int)((fileSize / totalSize) * 100);
                                                worker.ReportProgress(progress);
                                            }
 
                                            //ftpStream.CopyTo(fs);
                                        }
                                    }
 
                                }
                                else//수정시간이 같으면 다음 파일 검사.
                                {
                                    worker.ReportProgress(1);
                                    continue;
                                }
                            }
                        }
                        else//파일이 아닌 폴더일 경우 한번 더 접근 후 하위 파일들 얻고 로컬로 다운로드.
                        {
 
                            #region Local에서 폴더가 있는지 체크 후 폴더 생성
 
                            DirectoryInfo di = new DirectoryInfo(Application.StartupPath + "\\" + item);
                            if (!di.Exists)
                            {
                                di.Create();
                            }
 
                            #endregion
 
                            #region 폴더일 경우 한번 더 아래로 진입 후 하위목록 가져오기
                            List<string> lowList = new List<string>();//폴더일 경우 한번더 들어가서 하위의 파일들을 저장하기 위한 변수
 
                            using (FtpWebResponse response = FTPConnection(fullPath + item, WebRequestMethods.Ftp.ListDirectory))
                            {
                                using (Stream ftpStream = response.GetResponseStream())
                                {
                                    using (StreamReader reader = new StreamReader(ftpStream))
                                    {
                                        while (true)//존재하는 모든 폴더와 파일목록 저장.
                                        {
                                            string line = reader.ReadLine();
 
                                            if (string.IsNullOrWhiteSpace(line)) break;
 
                                            lowList.Add(line);
                                        }
                                            
                                    }
                                }
                            }
 
                            #endregion
 
 
                            foreach (string lowItem in lowList)
                            {
 
                                #region 해당 파일의 사이즈와 수정시간 저장
                                float fileSize;//FTP서버의 해당 파일사이즈를 저장하기 위한 변수.
 
                                using (FtpWebResponse response = FTPConnection(fullPath + item + "/" + lowItem, WebRequestMethods.Ftp.GetFileSize))
                                {
                                    using (Stream ftpStream = response.GetResponseStream())
                                    {
                                        fileSize = response.ContentLength;//FTP 서버의 파일의 용량
                                    }
                                }
 
                                DateTime ftpDt;//해당 파일의 마지막 수정시간을 저장하기 위한 변수.
 
                                using (FtpWebResponse response = FTPConnection(fullPath + item + "/" + lowItem, WebRequestMethods.Ftp.GetDateTimestamp))
                                {
                                    ftpDt = response.LastModified;//FTP 서버의 파일의 마지막 수정시간
                                }
 
                                #endregion
 
                                //다운로드 시작.
                                using (FtpWebResponse response = FTPConnection(fullPath + item + "/" + lowItem, WebRequestMethods.Ftp.DownloadFile))
                                {
                                    DateTime localDt = DateTime.Parse("2000-01-01");//해당 파일이 없을 경우 DateTime입력. 새로운 파일을 다운로드하기위함.
 
                                    FileInfo fi = new FileInfo(Application.StartupPath + "\\" + item + "\\" + lowItem);
 
                                    if (fi.Exists)
                                    {
                                        localDt = Directory.GetLastWriteTime(Application.StartupPath + "\\" + item + "\\" + lowItem);//LOCAL의 파일의 마지막 수정시간
                                    }
 
                                    if (0 < DateTime.Compare(ftpDt, localDt))//수정한 시간이 FTP서버파일이 더 최신이면 다운로드
                                    {
                                        using (Stream ftpStream = response.GetResponseStream())
                                        {
                                            using (FileStream fs = new FileStream(Application.StartupPath + "\\" + item + "\\" + lowItem, FileMode.Create,
                                                                                FileAccess.Write, FileShare.None))
                                            {
                                                byte[] buffer = new byte[(int)fileSize];
                                                int readBytes = 0;
                                                while ((readBytes = ftpStream.Read(buffer, 0, buffer.Length)) > 0)
                                                {
                                                    fs.Write(buffer, 0, readBytes);
                                                    int progress = (int)((fileSize / totalSize) * 100);
                                                    worker.ReportProgress(progress);
                                                }
 
                                                //ftpStream.CopyTo(fs);그냥 한번에 복사하는 방법.
                                            }
                                        }
 
                                    }
                                    else//수정시간이 같으면 다음 파일 검사.
                                    {
                                        worker.ReportProgress(1);
                                        continue;
                                    }
                                }
                            }
                        }
 
                    }
                    #endregion
 
                }
 
                worker.ReportProgress(100);
 
 
 
                #endregion
 
            }
            catch (Exception ex)
            {
 
                MessageBox.Show(ex.Message.ToString(), "ERROR",MessageBoxButtons.OK,MessageBoxIcon.Error);
 
                worker.CancelAsync();
                worker.Dispose();
 
                //자동업데이트 오류 발생 시 업데이트 하지 않고 오류메세지 출력 후 프로그램 실행.
 
                string mainPrg = Application.StartupPath + "";//Main 프로그램 명 입력.확장자포함
                Process main = new Process();
                main.StartInfo = new ProcessStartInfo(mainPrg);
                main.Start();
 
                Application.Exit();
                Environment.Exit(0);
 
 
            }
 
        }
 
        #endregion
 
        #region ProgressbarControl 상태 변화 이벤트
        private void worker_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            progressBarControl1.Increment( e.ProgressPercentage);
        }
 
        #endregion
 
        #region 비동기 작업 완료시 발생 이벤트
        private void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            if (e.Error == null)
            {
                MessageBox.Show("업데이트 완료", "성공");
            }
 
            worker.CancelAsync();
            worker.Dispose();
 
            string mainPrg = Application.StartupPath + "";//Main 프로그램 명 입력.확장자포함
            Process main = new Process();
            main.StartInfo = new ProcessStartInfo(mainPrg);
            main.Start();
 
            Application.Exit();
            Environment.Exit(0);
 
 
        }
        #endregion
 
        #endregion
 
 
 
 
 
    }
}
 

 

C#에서 DevExpress UI를 활용하여서 Auto Update 프로그램을 만들어 보았다.

그리고 진행률을 표시하기 위해서 ProgressbarControl 을 사용하여서 다운로드가 될때마다 부드럽게 진행률이 올라가게 만들었다.  최대한 주석을 달아 놓아서 그대로 복사 붙여넣기해서 FTP서버접속 IP,ID,Password 만 입력하고 실행되어야하는 프로그램명을 확장자 포함해서 적고 배포만 하면 된다. 배포를 해도 되고 Form 으로 하나 만들어서 Form close를 사용하여 다음 Form 을 열어줘도 무방하다.주의할점은 배포 후 실행될 프로그램 폴더안에 같이 넣어야 한다. 시간에 쫓겨서 2일만에 만든거 치고는 깔끔하게 작동이 잘되어서 뿌듯하다. 고수분들이 보기엔 허접하겠지만 혼자 뿌듯하니 만족한다. BackgroundWorker를 사용하여 메인 쓰레드는 UI 를 보여주며 진행률을 표시하고 별도의 Background쓰레드가 파일을 다운로드 받으며 진행상황을 메인쓰레드에 보고한다. 굳이 BarckgroundWorker를 사용하여 쓰레드를 나눠 작업을 하냐면 메인쓰레드가 파일을 다운받으면서 동시에 진행률을 올리는 UI작업이 안되기 때문에 쓰레드를 나눠 사용하는 것이다.  BackgroundWorker를 사용할때는 주의할점이 크로스 쓰레드 현상이 일어날수있다. 쉽게 말하면 파일 다운로드만 받고 진행률만 보고해야지 메인 쓰레드가 작업하고 있는 UI 를 건들려고 하면 접근을 못하게 된다. 혼자 하면서 공부도 많이 되었고 재밌는 작업이였던것 같다. 마지막에 업데이트 성공 메세지박스는 필요없을 시 삭제하여도 무방하다. DevExpresss를 사용하지 않고 그냥 Winform 을 사용하면 ProgressBar를 사용하면 되고 진행률을 업그레이드 할때는 progressBar1.value=e.ProgressPercentage 이렇게 Change이벤트에서 선언해주면 된다. 나와 같은 다른 초보분들이 헤메지 않게 도움이 잘 되었으면 좋겠다. 작업환경은 VS2017 Enterprise 이고 .NET 4.6.1이다.