C#在线更新程序[下载程序、解压缩程序、控制台程序]

【1】下载文件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;

namespace XuanWu.Software.EasyInfo.Interface.Update
{
    public class DownloadThread
    {
        #region DownLoadOneFile(下载单个文件)
        /// <summary>
        /// 下载文件
        /// </summary>
        /// <param name="url">下载地址</param>
        /// <param name="filePath">保存路径</param>
        /// <returns></returns>
        public bool DownLoadOneFile(string url, string filePath)
        {
            FileStream fstream = new FileStream(filePath, FileMode.Create, FileAccess.Write);
            WebRequest wRequest = WebRequest.Create(url);
            try
            {
                WebResponse wResponse = wRequest.GetResponse();
                int contentLength = (int)wResponse.ContentLength;

                byte[] buffer = new byte[Properties.Settings.Default.byte_size];

                ///备注：Properties.Settings.Default.byte_size是从配置文件中读取的
                int read_count = 0;
                int total_read_count = 0;
                bool complete = false;

                System.Console.WriteLine("开始下载文件....");

                while (!complete)
                {
                    read_count = wResponse.GetResponseStream().Read(buffer, 0, buffer.Length);
                    if (read_count > 0)
                    {
                        fstream.Write(buffer, 0, read_count);
                        total_read_count += read_count;
                        if (total_read_count <= contentLength)
                            System.Console.Write(".");
                    }
                    else
                    {
                        complete = true;
                        System.Console.WriteLine("");
                        System.Console.WriteLine("下载完成！开始安装！");

                    }
                }
                fstream.Flush();
                return true;
            }
           catch(Exception ex)
            {
                throw ex;
             }
            finally
            {
                fstream.Close();
                wRequest = null;
            }
        }
       #endregion

    }
}

【2】解压缩文件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using ICSharpCode.SharpZipLib.Zip;

namespace XuanWu.Software.EasyInfo.Interface.Update
{
    public class UnZipClass
    {
        private byte[] byffer = new byte[Properties.Settings.Default.byte_size];

         ///备注：Properties.Settings.Default.byte_size是从配置文件中读取的

        /// <summary>
        /// 有参构造函数
        /// </summary>
        /// <param name="buffserSize">缓冲大小</param>
        public UnZipClass(int buffserSize)
        { 
            byffer = new byte[buffserSize];
        }

        /// <summary>
        /// 无参构造函数
        /// </summary>
        public UnZipClass()
        { }

        /// <summary>
        /// 解压缩文件
        /// </summary>
        /// <param name="zipFilePath">压缩文件路径</param>
        /// <param name="unZipFilePath">解压缩文件路径</param>
        public void UnZipFile(string zipFilePath, string unZipFilePath)
        {
            using (ZipInputStream zipstream = new ZipInputStream(File.OpenRead(zipFilePath)))
            {
                ZipEntry zipEntry = null;
                while ((zipEntry = zipstream.GetNextEntry()) != null)
                {
                    string fileName = Path.GetFileName(zipEntry.Name);
                    if (!string.IsNullOrEmpty(fileName))
                    {
                        if (zipEntry.CompressedSize == 0)
                            break;

                        using (FileStream stream = File.Create(unZipFilePath + fileName))
                        {
                            while (true)
                            {
                                int size = zipstream.Read(byffer, 0, byffer.Length);
                                if (size > 0)
                                    stream.Write(byffer, 0, size);
                                else break;
                            }
                        }
                    }
                }
            }
        }

        /// <summary>
        /// 解压缩目录
        /// </解压缩目录summary>
        /// <param name="zipDirectoryPath">压缩目录路径</param>
        /// <param name="unZipDirectoryPath">解压缩目录路径</param>
        public void UnZipDirectory(string zipDirectoryPath, string unZipDirectoryPath)
        { 
            using(ZipInputStream zipStream = new ZipInputStream(File.OpenRead(zipDirectoryPath)))
            {
                ZipEntry zipentry = null;
                while ((zipentry = zipStream.GetNextEntry()) != null)
                {
                    string directoryName = Path.GetDirectoryName(zipentry.Name);
                    string fileName = Path.GetFileName(zipentry.Name);

                    if (!string.IsNullOrEmpty(directoryName))
                    {
                        Directory.CreateDirectory(directoryName);
                    }

                    if (!string.IsNullOrEmpty(fileName))
                    {
                        if (zipentry.CompressedSize == 0)
                            break;
                        if (zipentry.IsDirectory)
                        {
                            directoryName = Path.GetDirectoryName(unZipDirectoryPath + zipentry.Name);
                            Directory.CreateDirectory(directoryName);
                        }

                        using (FileStream stream = File.Create(unZipDirectoryPath + zipentry.Name))
                        {
                            while (true)
                            {
                                int size = zipStream.Read(byffer, 0, byffer.Length);
                                if (size > 0)
                                    stream.Write(byffer, 0, size);
                                else break;
                            }
                        }

                    }
                }
            }
        }

    }
}

【3】控制台应用程序

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Diagnostics;
using System.IO;
using XuanWu.Software.EasyInfo.Model;
using XuanWu.Software.EasyInfo.Service.elsp_da;

namespace XuanWu.Software.EasyInfo.Interface.Update
{
    class Program
    {
        static void Main(string[] args)
        {

            Protocol.ProtocolRegister.RegisterProcotols();

            string path = "http://" + Properties.Settings.Default.urlServerIP + ":" + Properties.Settings.Default.urlServerPort + "/soft/";

///备注：Properties.Settings.Default.urlServerIP和Properties.Settings.Default.urlServerPort 是从配置文件中读取的
            string Version = Properties.Settings.Default.Version;   ///版本号
            string buildno = Properties.Settings.Default.buildno;   ///版本状态
            string clienttypeno = Properties.Settings.Default.clienttypeno;  ///版本类型

///备注：上面3个变量的赋值都是从配置文件中取的。
            try
            {

                ///从本地文件中读取值，如果没有存在文件，报错跳出Try语句.Application.StartupPath + "//Version.bt");

                buildno = File.ReadAllText(System.Windows.Forms.Application.StartupPath + "//buildno.bt");

                clienttypeno = File.ReadAllText(System.Windows.Forms.Application.StartupPath + "//clienttypeno.bt");
            }
            catch { }
            updatesoftwareobj updatesfoj = getsoftwareobj(Convert.ToInt32(buildno), Convert.ToInt32(Version), Convert.ToInt32(clienttypeno));

///备注：updatesoftwareobj 实体对象
            if (updatesfoj != null)
            {
                path += updatesfoj.updateurl;
                int versionstatus = updatesfoj.versionstatus;
                string  serverVersion = updatesfoj.versionno.ToString();
                string serverbuildno = updatesfoj.buildno.ToString();
                string serverclienttypeno = updatesfoj.clienttypeno.ToString();
                try
                {
                    if (Convert.ToInt32(serverbuildno)> Convert.ToInt32(buildno))
                    {
                        System.Console.WriteLine("开始升级....");
                        System.Console.WriteLine("————————————————————————");
                        System.Console.WriteLine("开始下载......");
                        DownloadThread down = new DownloadThread();
                        down.DownLoadOneFile(path, System.Windows.Forms.Application.StartupPath + "//updata.zip");
                        System.Console.WriteLine("————————————————————————");
                        System.Console.WriteLine("开始更新......");
                        UnZipClass unzip = new UnZipClass();
                        unzip.UnZipFile(System.Windows.Forms.Application.StartupPath + "//updata.zip", System.Windows.Forms.Application.StartupPath + "//");
                        unzip.UnZipDirectory(System.Windows.Forms.Application.StartupPath + "//updata.zip", System.Windows.Forms.Application.StartupPath + "//");
                        File.Delete(System.Windows.Forms.Application.StartupPath + "//updata.zip");
                        System.Console.WriteLine("更新完成！");
                        System.Console.WriteLine("————————————————————————");
                        System.Console.WriteLine("启动服务程序！");
                        File.WriteAllText(System.Windows.Forms.Application.StartupPath + "//Version.bt", serverVersion);
                        File.WriteAllText(System.Windows.Forms.Application.StartupPath + "//buildno.bt", serverbuildno);
                        File.WriteAllText(System.Windows.Forms.Application.StartupPath + "//clienttypeno.bt", serverclienttypeno);
                        Process.Start(System.Windows.Forms.Application.StartupPath + "//某服务.exe");
                    }
                }
                catch (Exception ex)
                {
                    File.WriteAllText(System.Windows.Forms.Application.StartupPath + "//installLog.erroe", ex.ToString());
                    System.Console.WriteLine(ex.ToString());
                }
            }
        }

        /// <summary>
        ///端版本号及版本号获取是否有相应的更新信息
        /// </summary>
        /// <param name="buildno"></param>
        /// <param name="versionno"></param>
        /// <param name="clienttypeno"></param>
        /// <returns></returns>
        private static updatesoftwareobj getsoftwareobj(int buildno, int versionno, int clienttypeno)
        {
            DateSourceSystemService datasystesv = new DateSourceSystemService(IPAddress.Parse(Properties.Settings.Default.ServerIP), Properties.Settings.Default.ServerPort);
            updatesoftwareobj updatestobj = datasystesv.getbymodelversion(buildno,versionno,clienttypeno);
            return updatestobj;
        }
    }
}