[原创] 使用Tcp/Ip下载文件(图)

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

namespace VJSDN.Tech.TcpIpDownloader
{
   /// <summary>
   /// Tcp/ip下载器客户端
   /// </summary>
   public class UpgraderClient
   {
      private OutputInvoke _writeOutput = null;
      
      public UpgraderClient(OutputInvoke writeOutput)
      {
         _writeOutput = writeOutput;
      }
      
      /// <summary>
      /// 下载文件
      /// </summary>
      public bool DownloadFile(string file, string savePath)
      {
         string hostIp = "8.8.8.2"; //主机ip
         int hostPort = 12346; //主机端口
         
         try
         {
            TcpClient client = new TcpClient();
            client.ReceiveTimeout = 1000 * 60;
            
            if (client == null || file.Trim() == "") return false;
            
            TryConnect(client, hostIp, hostPort); //连接服务器
            if (!client.Connected) return false;//连线线失败,退出
            
            byte[] bs = Encoding.Unicode.GetBytes("GET_FILE|" + file);
            client.Client.Send(bs); //发送请求
            
            //开始接受数据....
            NetworkStream ns = client.GetStream();
            MemoryStream ms = new System.IO.MemoryStream();
            
            byte[] resBytes = new byte[256];
            int resSize;
            do
            {
               resSize = ns.Read(resBytes, 0, resBytes.Length);
               string msg = Byte2Str(resBytes);
               if (msg.Trim().ToUpper() == "FILE_NOT_FOUND")
               {
                  if (_writeOutput != null) _writeOutput("找不到文件:" + file);
                  break;
               }
               if (resSize == 0) break;
               
               ms.Write(resBytes, 0, resSize);
               } while (ns.DataAvailable);
               
               if (ms.Length > 0)
               {
                  FileStream fs = File.Open(savePath, FileMode.OpenOrCreate, FileAccess.Write);
                  fs.Write(ms.ToArray(), 0, (int)ms.Length);
                  fs.Flush();
                  fs.Close(); //关闭文件流
                  if (_writeOutput != null) _writeOutput("文件已下载:" + file);
               }
               
               ms.Close(); //关闭内存流
               client.Close();
               return true;
            }
            catch
            {
               return false;
            }
         }
         
         private string Byte2Str(byte[] buffer)
         {
            string msg = Encoding.Unicode.GetString(buffer).Replace("\0", "");
            return msg.Trim();
         }
         
         private void TryConnect(TcpClient client, string hostIP, int hostPort)
         {
            try
            {
               client.Connect(IPAddress.Parse(hostIP), hostPort); //连接服务器
            }
            catch
            {
               throw new Exception("主机已关闭或网络存在问题,不能建立连线!");
            }
         }
      }
   }
   
   

using System;
using System.Collections.Generic;
using System.Text;
using System.Net.Sockets;
using System.Threading;
using System.Net;
using System.Windows.Forms;
using System.IO;

namespace VJSDN.Tech.TcpIpDownloader
{
   public delegate void OutputInvoke(string msg);
   
   public class UpgraderServer
   {
      private TcpListener _ServerListener = null; //本地监听 
      private Thread _ServerListenerThread = null; //监听使用的线程
      private bool _ServerRunning = false;
      
      private Form _owner = null;
      private OutputInvoke _writeOutput = null;
      
      public UpgraderServer(Form owner, OutputInvoke method)
      {
         _owner = owner;
         _writeOutput = method;
      }
      
      //启动服务器程序. 参数说明 ip:本地消息服务器IP地址; port:端口
      public void StartListening(string ip, int port)
      {
         if (_ServerRunning) return;
         
         //构建监听
         _ServerListener = new TcpListener(IPAddress.Parse(ip), port);
         _ServerListener.Start(255);
         _ServerRunning = true;
         
         //启动线程
         _ServerListenerThread = new Thread(new ThreadStart(DoStartServerListener));
         _ServerListenerThread.IsBackground = true;
         _ServerListenerThread.Start();
      }
      
      //关闭服务器程序.
      public void Stop()
      {
         _ServerRunning = false;
         _ServerListenerThread.Abort(101);
         _ServerListenerThread = null;
         _ServerListener.Stop();
      }
      
      /// <summary>
      ///启动服务器程序.
      /// </summary>
      private void DoStartServerListener()
      {
         //监听客户连线请求
         while (_ServerRunning)
         {
            try
            {
               if (_ServerListener == null) return; //防止其它地方关闭监听 
               Application.DoEvents();
               Socket socket = _ServerListener.AcceptSocket(); //有客户请求连接
               if (socket == null) continue;
               
               byte[] buffer = new Byte[socket.ReceiveBufferSize];
               int i = socket.Receive(buffer); //接收请求数据.
               if (i <= 0) continue;
               
               string msg = Encoding.Unicode.GetString(buffer).Replace("\0", "");
               msg = msg.Trim();
               if (msg.ToUpper().StartsWith("GET_FILE")) //命令字符串:GET_FILE|.\a.dll
               {
                  string[] sps = msg.Split(new char[] { char.Parse("|") });
                  string file = sps[1]; //取出文件a.dll
                  this.SendFile(socket, file);
               }
               socket.Close();//
            }
            catch (Exception ex)
            {
               if (ex is ThreadAbortException)
               {
                  if ((ex as ThreadAbortException).ExceptionState.ToString() == "101")
                  {
                     _ServerRunning = false;
                     ShowMessage("用户关闭服务器.");
                  }
                  else
                  ShowMessage(ex.Message);
               }
               else
               {
                  ShowMessage(ex.Message);
               }
            }
         }
      }
      
      private void ShowMessage(string msg)
      {
         _owner.Invoke(this._writeOutput,msg);
      }
      
      private void SendFile(Socket socket, string file)
      {
         if (File.Exists(file))
         {
            ShowMessage("获取文件[" + file + "]....");
            socket.SendFile(file);
            ShowMessage("[" + file + "]已发送.");
         }
         else
         {
            socket.Send(Encoding.Unicode.GetBytes("FILE_NOT_FOUND")); //通知客户程序
            ShowMessage("[" + file + "]不存在.");
         }
      }
   }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net.Sockets;
using VJSDN.Tech.TcpIpDownloader;

namespace VJSDN.Tech.TcpIpDownloaderServer
{
   public partial class frmUpgraderServer : Form
   {
      private UpgraderServer _UpgradeListener = null;
      
      public frmUpgraderServer()
      {
         InitializeComponent();
      }
      
      private void frmUpgraderServer_Load(object sender, EventArgs e)
      {
         //
      }
      
      private void btnStart_Click(object sender, EventArgs e)
      {
         string hostIp = "8.8.8.2";
         int hostPort = 12346;
         
         _UpgradeListener = new UpgraderServer(this, this.Output);
         _UpgradeListener.StartListening(hostIp, hostPort);
         listBox1.Items.Add("已启动服务.");
      }
      
      private void btnStop_Click(object sender, EventArgs e)
      {
         if (_UpgradeListener != null)
         {
            _UpgradeListener.Stop();
            _UpgradeListener = null;
            listBox1.Items.Add("已关闭服务.");
         }
      }
      
      public void Output(string msg)
      {
         this.listBox1.Items.Add(msg);
      }
      
      private void frmUpgraderServer_FormClosing(object sender, FormClosingEventArgs e)
      {
         if (_UpgradeListener != null) _UpgradeListener.Stop();
      }
   }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using VJSDN.Tech.TcpIpDownloader;
using System.IO;

namespace TestProject
{
   public partial class frmDownloader : Form
   {
      public frmDownloader()
      {
         InitializeComponent();
      }
      
      private void button1_Click(object sender, EventArgs e)
      {
         string filename = Path.GetFileName(textBox1.Text);
         string local = textBox2.Text + @"\" + filename;
         bool ret = new UpgraderClient(this.ShowOutput).DownloadFile(textBox1.Text, local);
         if (ret)
         MessageBox.Show("下载完成!");
         else
         MessageBox.Show("下载失败!");
      }
      
      private void ShowOutput(string msg)
      {
         MessageBox.Show(msg);
      }
   }
}