1、三個類，TcpCommon 主要實現(xiàn)了，發(fā)送接收消息，和文件hash的計算_blockLength =500 *1024string FilePath)new MD5CryptoServiceProvid【背景】最近做了一個雙機備份，就是服務器上有個文件夾，會接收客戶端傳來的文件，而我們要 做的就是同步這臺服務器和另一臺備用服務器上的文件為了實現(xiàn)這個功能我們使用的 tcp點對點傳輸.【開發(fā)環(huán)境】VS2005【實現(xiàn)原理】要實現(xiàn)同步要解決兩個問題，一個是獲取本地服務器上上傳上來的文件，二是實現(xiàn)兩臺機器間的文件傳輸.第一個問題我們用的 FileSystemWatcher這個可以監(jiān)視指定文件夾下的文件

2、變動，然后我們把變動的文件信息記錄到數(shù)據(jù)庫，在指定的時間間隔后同步兩臺機器的文件.第二個問題我們用的tcp文件傳輸，我們按照一定的原則通過傳輸消息來告知備份服務器的要傳輸?shù)奈募Q和大小，然后傳輸文件.【代碼】1:FileSystemWatcher監(jiān)視文件變動的就不介紹了，很簡單的winform 控件應用.2:為了完成文件傳輸，我做了一個TcpHelper類庫，其中包括TcpCommon,TcpClientHelper,TcpListenerHelper文件傳輸時用的一些公共的方法比如發(fā)送接收文件TcpCommon甌using System;using System.Collections.G

3、eneric;using System.Text;using System.Security.Cryptography;using System.IO;using System.Net.Sockets;namespace Xpwy.Backup.PTcpHelperinternal class TcpCommonprivate staticreadonly int/ summary/計算文件的hash值/ </summary>internal string CalcFileHash(MD5CryptoServiceProvider md5 = er()；byte 口 hash;us

4、ing (FileStream fs =new FileStream(FilePath, FileMode.Open, FileAccess.Read, FileShare.Read,4096 ) hash = md5.ComputeHash(fs); return BitConverter.ToString(hash); / summary / 發(fā)送文件 / /summary /param name="filePath"></param>/<param name="stream"></param>/<re

5、turns></returns>internalbool SendFile( string filePath, Networkstream stream) FileStream fs = File.Open(filePath, FileMode.Open); int readLength =0;/發(fā)送大小byte 口 length =BitConverter.GetBytes(To(length, 0);stream.Write(length,byte 口 data = new byte _blockLength;new byte 8;new FileInfo(filePat

6、h).Length).Copy0, 8);0)/發(fā)送文件while (readLength = fs.Read(data,0, _blockLength) >stream.Write(data,0, readLength); fs.Close(); return true ; / summary/接收文件/ </summary>/<param name="filePath">/param>/<param name="stream">/param>/ returns>/returns>int

7、ernal bool ReceiveFile(string filePath, Networkstream stream) trylong count = GetSize(stream); if (count =0) return false ;long index =0;byte 口 clientData =new byte _blockLength;if (File.Exists(filePath)File.Delete(filePath); string path= new FileInfo(filePath).Directory.FullName;if (!Directory.Exis

8、ts(path)Directory.CreateDirectory(path);FileStream fs = File.Open(filePath, FileMode.OpenOrCr eate);try/計算當前要讀取的塊的大小 int currentBlockLength =0;if (_blockLength < count - index) currentBlockLength = _blockLength;else currentBlockLength =(int )( count - index);int receivedBytesLen = stream.Read(cli

9、entData, 0, currentBlockLength);index += receivedBytesLen;fs.Write(clientData,0, receivedBytesLen);while (receivedBytesLen >0 && index < count) clientData =new byte _blockLength;receivedBytesLen =0;if (_blockLength < count - index)currentBlockLength = _blockLength; else currentBlock

10、Length = (int )(count - index); receivedBytesLen = stream.Read(clientData, 0, currentBlockLength);index += receivedBytesLen;fs.Write(clientData,0, receivedBytesLen); catch (Exception ex) return false ; finally fs.Close(); catch (Exception ex) return false ; return true ; / summary /發(fā)送消息/ /summary /p

11、aram name="message"></param>/<param name="stream"></param>/ <returns></returns>internal bool SendMessage(string message, Networkstream stream)byte 口 data = Encoding.UTF8.GetBytes(message);byte 口 resultData =new byte 8 + data.Length;BitConverter.Ge

12、tBytes(data.Length).CopyTo(resultData,0);data.CopyTo(resultData,8)；stream.Write(resultData,0, resultData.Length);return true ; / summary/讀取消息/ /summary/ param name="stream"></param>/ <returns></returns> internal string ReadMessage(NetworkStream stream) string result =&

13、quot;"int messageLength =0;byte 口 resultbyte =new byte 500 *1024 ;/讀取數(shù)據(jù)大小 int index =0;int count = GetSize(stream);byte 口 data = new byte count;while (index < count && (messageLength = stream.Read(dat a, 0, count - index) !=0)data.CopyTo(resultbyte, index);index += messageLength;0, i

14、ndex);result = Encoding.UTF8.GetString(resultbyte, return result;/ <summary>/獲取要讀取的數(shù)據(jù)的大小/ </summary>/ <param name="stream"></param>/ <returns></returns> private int GetSize(NetworkStream stream) int count =0;byte 口 countBytes =new byte 8;try0, 8) =8)if (

15、stream.Read(countBytes,0);count = BitConverter.ToInt32(countBytes, else return 0; catch (Exception ex) return count; TcpClientHelper EH using System; using System.Collections.Generic; using System.Text; using System.Net.Sockets; namespace Xpwy.Backup.PTcpHelper public class TcpClientHelper:IDisposab

16、le TcpClient client; NetworkStream netstream; string _serverip =""int _port =8080 ;TcpCommon tcpCommon =new TcpCommon();#region TcpClientHelper constructor public TcpClientHelper( string strServerIP, int serverPort) _serverip = strServerIP;_port = serverPort;#endregionpublic void

17、Start()client =new TcpClient(_serverip, _port);netstream = client.GetStream(); public void Stop() if (netstream != null ) netstream.Close(); if (client != null ) client.Close(); #region TcpCommon 所有方法public string CalcFileHash( string FilePath) return tcpCommon.CalcFileHash(FilePath);public bool Sen

18、dFile( string filePath) return tcpCommon.SendFile(filePath, netstream); public bool ReceiveFile( string filePath) return tcpCommon.ReceiveFile(filePath, netstream); public bool SendMessage( string message) return tcpCommon.SendMessage(message, netstream); public string ReadMessage()return tcpCommon.

19、ReadMessage(netstream);#endregion#region Disposable 成員public void Dispose。if (netstream != null )netstream.Close();if (client != null )client.Close();#endregionTcpListenerHelpersausing System;using System.Collections.Generic;using System.Text;using System.Net.Sockets;using System.Net;using System.Th

20、reading;namespace Xpwy.Backup.PTcpHelperpublic class TcpListenerHelper""0;privatestring _strServerIP =privateint _serverPort =TcpListener server;TcpClient client;Networkstream netstream;lAsyncResult asyncResult;new TcpCommon();TcpCommon tcpCommon =ManualResetEvent listenConnected =new Manu

21、alResetEvent(false)；bool _active = false ;public TcpListenerHelper(string strServerIP, int serverPort) _strServerIP = strServerIP;_serverPort = serverPort;server =new TcpListener(IPAddress.Parse(strServerIP), serverPort);server.Server.ReceiveTimeout =6000 ;server.Server.SendTimeout =6000 ;/ summary/

22、 啟動/ /summary public void Start() try _active =true ;server.Start(); catch (Exception ex) throw ex; / summary / 停止 / /summary public void Stop() try _active =false ;if (client != null ) client.Close();if (netstream !=null )netstream.Close(); server.Stop(); catch (Exception ex) throw ex;public void L

23、isten()new AsyncCallbalistenConnected.Reset();asyncResult = server.BeginAcceptTcpClient( ck(AsyncCall), server);public void AsyncCall(IAsyncResult ar) try TcpListener tlistener = (TcpListener)ar.AsyncState;if (_active) client = tlistener.EndAcceptTcpClient(ar); netstream = client.GetStream(); else c

24、lient =null ;netstream =null ;listenConnected.Set(); catch (Exception ex)throw ex;public bool WaitForConnect()listenConnected.WaitOne();if (client !=null && netstream !=nullelsereturn truereturn false#region TcpCommon 所有方法/ summary/計算文件的hash值/ /summarypublic string CalcFileHash( string FileP

25、ath)return tcpCommon.CalcFileHash(FilePath);/ summary/發(fā)送文件/ /summary/ <param name="filePath"/param/ returns/returnspublic bool SendFile( string filePath)return tcpCommon.SendFile(filePath, netstream);/ summary/接收文件/ /summary/ <param name="filePath"/param/ returns/returnspub

26、lic bool ReceiveFile( string filePath)return tcpCommon.ReceiveFile(filePath, netstream);/ summary/發(fā)送消息/ /summary/ param name="message"></param>/ <returns></returns>public bool SendMessage( string message) return tcpCommon.SendMessage(message, netstream); / summary/接收消息

27、/ /summary/ returns/returnspublic string ReadMessage() return tcpCommon.ReadMessage(netstream); #endregion#region IDisposable 成員public void Dispose。Stop()； #endregion 3:調(diào)用的代碼server 端:EEpublic void DoWork( object state)TcpListenerHelper tlistener = (TcpListenerHelper)state;tlistener.Listen();/ 監(jiān)聽/等待知

28、道監(jiān)聽到了連接while (tlistener.WaitForConnect()trystring firstMessage =""while (! string .IsNullOrEmpty(firstMessage = tlis tener.ReadMessage() if (firstMessage.ToLower() ="filebak" .ToLower()tlistener.SendMessage("filebakok" );#region 文件備份string filepath = Path.Combine(Enviro

29、nmen t.CurrentDirectory,"FileBak" + tlistener.ReadMessage().ToString();tlistener.ReceiveFile(filepath);if (tlistener.CalcFileHash(filepath) = t listener.ReadMessage() tlistener.SendMessage("ok");elsetlistener.SendMessage("wrong");#endregionif (firstMessage.ToLower() ="DBBak"elseLower()tlistener.SendMessage(#region 數(shù)據(jù)庫備份"dbbakok");stringfilename = tlistener.ReadMessage();stringfilepath = Path.Combine(System.Environment.CurrentDirectory,"DBBak" ) + ""+ filename;/接收文件tlistener.ReceiveFile(filepath);/驗證