程式師世界 >> 編程語言 >> C語言 >> 關於C語言 >> 使用C#進行點對點通訊和文件傳輸（發送接收部分）

使用C#進行點對點通訊和文件傳輸（發送接收部分）

編輯：關於C語言

上面介紹了通訊的基類，下面就是使用那個類進行發送和接收的部分：

二、發送部分：

發送咱們使用了多線程，可以同時進行多個任務，比如發送文件、發送文本等，互不影響：

發送文本方法：

private void StartSendText(string strHost,int iPort,string strInfo)

{

SendText stText = new SendText(strHost,iPort,strInfo,new CommunClass.OnSend(OnSendDrawProgress)) ;

StartThread(new ThreadStart(stText.Send)) ;

}

下面是他調用用到的一些方法：

開始一個線程

private void StartThread(ThreadStart target)

{

Thread DOStep = new Thread(target) ;

DOStep.IsBackground = true ;

DOStep.Start() ;

}

發送一部分（本文設置的是1024字節）成功後的回調方法

public void OnSendDrawProgress(int iTotal,int iSending)

{

if (iTotal != pbMain.Maximum)

pbMain.Maximum = iTotal ;

pbMain.Value = iSending ;

}

因為使用的是線程，所以發送文本使用的是一個發送文本類的方法，該類如下：

public class SendText

{

private string Host ;

private int Port ;

private string Info ;

private CommunClass.OnSend onsend ;

public SendText(string strHost,int iPort,string strInfo,

CommunClass.OnSend onSend)

{

Host = strHost ;

Port = iPort ;

Info = strInfo ;

onsend = onSend ;

}

public void Send()

{

Socket s = null ;

try

{

s = CommunClass.ConnectToServer(Host,Port) ;

CommunClass.WriteCommandToSocket(s,"SENDTEXT") ;

CommunClass.WriteCommandDescToSocket(s,"") ;

CommunClass.WriteDynamicTextToSocket(s,Info,onsend) ;

}

catch (Exception e)

{

MessageBox.Show(e.Message) ;

}

finally

{

if (s != null)

s.Close() ;

}

}

}//end class

這樣就可以使用一個線程發送文本了。

發送文件的方法也類似：

private void StartSendFile(string strHost,int iPort,string strFile)

{

SendFile sfFile = new SendFile(strHost,iPort,strFile,this.pbMain) ;

pbMain.Value = 0 ;

StartThread(new ThreadStart(sfFile.Send)) ;

}

發送文件的類：

public class SendFile

{

private string Host ;

private int Port ;

private string FileToSend ;

private ProgressBar pbar;

public SendFile(string strHost,int iPort,string strFile,ProgressBar pbMain)

{

Host = strHost ;

Port = iPort ;

FileToSend = strFile ;

pbar = pbMain ;

}

public void Send()

{

Socket s = null ;

try

{

s = CommunClass.ConnectToServer(Host,Port) ;

CommunClass.WriteCommandToSocket(s,"SENDFILE") ;

CommunClass.WriteCommandDescToSocket(s,"") ;

CommunClass.WriteFileToSocket(s,FileToSend,new CommunClass.OnSend(OnSendDrawProgress)) ;

}

catch (Exception e)

{

MessageBox.Show(e.Message) ;

}

finally

{

if (s != null)

s.Close() ;

}

}

public void OnSendDrawProgress(int iTotal,int iSending)

{

if (iTotal != pbar.Maximum)

pbar.Maximum = iTotal ;

pbar.Value = iSending ;

}

}//end class

當然，你發送一個命令讓服務器端啟動一個程序（靠，這不成木馬了嗎？）也可以：

俺這裡只給出一部分代碼，其余的您自己可以發揮以下：

public class ExeCuteFile

{

private string Host ;

private int Port ;

private string FileName ;

private string cmdParam ;

public ExeCuteFile(string strHost,int iPort,string strFileName,string strCmdParam)

{

Host = strHost ;

Port = iPort ;

FileName = strFileName ;

cmdParam = strCmdParam ;

}

public void Send()

{

Socket s = null ;

try

{

s = CommunClass.ConnectToServer(Host,Port) ;

CommunClass.WriteCommandToSocket(s,"EXECUTEFILE") ;

CommunClass.WriteCommandDescToSocket(s,FileName) ;

CommunClass.WriteDynamicTextToSocket(s,"",null) ;

MessageBox.Show(CommunClass.ReadDynamicTextFromSocket(s)) ;

}

catch (Exception e)

{

MessageBox.Show(e.Message) ;

}

finally

{

if (s != null)

s.Close() ;

}

}

}

三、下面是服務器端接受信息的代碼：

創建監聽：

/// <summary>

/// 再給定的主機和端口上創建監聽程序

/// </summary>

/// <param name="strAddress"></param>

/// <param name="iPort"></param>

private void BuildingServer(string strAddress,int iPort)

{

IPAddress ipAddress = Dns.Resolve(strAddress).AddressList[0];

try

{

listener = new TcpListener(ipAddress, iPort);

}

catch ( Exception e)

{

AddInfo(e.Message) ;

}

}

開始監聽：

/// <summary>

/// 開始監聽

/// </summary>

private void StartListen()

{

bool done = false;

listener.Start();

while (!done)

{

Socket s = listener.AcceptSocket() ;

if(s != null)

{

DealWithSocket dws = new DealWithSocket(s,this.tbLog) ;

StartThread(new ThreadStart(dws.DealWith)) ;

}

}

}

private void StartThread(ThreadStart target)

{

Thread DOStep = new Thread(target) ;

DOStep.IsBackground = true ;

DOStep.Start() ;

}

開始監聽後，對於每一個監聽到的客戶端的連接都用一個單獨的線程來處理,處理通過類DealWithSocket來完成,下面是類代碼:

public class DealWithSocket

{

private Socket s = null ;

private TextBox tbLog = null ;

public DealWithSocket(Socket newSocket,TextBox tbInfo)

{

s = newSocket ;

tbLog = tbInfo ;

}

public void DealWith()

{

string strCmd = CommunClass.ReadCommandFromSocket(s) ;

string strDesc = CommunClass.ReadCommandDescFromSocket(s) ;

AddInfo(strCmd) ;

switch(strCmd)

{

case "SENDFILE" :

CommunClass.ReadDynamicFileFromSocket(s,"e:\\rrr.txt") ;

break ;

case "EXECUTEFILE" :

string strParam = CommunClass.ReadDynamicTextFromSocket(s) ;

string strResult = ExeCuteFile(strDesc,strParam) ;

CommunClass.WriteDynamicTextToSocket(s,strResult,null) ;

break ;

default:

string strDetail = CommunClass.ReadDynamicTextFromSocket(s) ;

AddInfo(strDetail) ;

break ;

}

try

{

s.Close() ;

}

catch (Exception e)

{

AddInfo(e.Message) ;

}

}

private void AddInfo(string strInfo)

{

string Info = DateTime.Now.ToLongTimeString() + " "+ strInfo +"\r\n" ;

tbLog.Text += Info ;

tbLog.Refresh() ;

}

private string ExeCuteFile(string strFileName,string strCmdParam)

{

System.Diagnostics.Process proc = new System.Diagnostics.Process() ;

proc.StartInfo.FileName = strFileName ;

proc.StartInfo.Arguments = strCmdParam ;

try

{

proc.Start() ;

return "OK" ;

}

catch(Exception err)

{

return err.Message ;

}

}

}//end class

以上就是所用的代碼,希望大家批判指正.