分类
使用C#进行点对点通讯和文件传输‖
| 发送咱们使用了多线程 ： | ，可以同时进行多个任务，比如 | 发送文件、发送文本等，互不影响 |
| 发送文本方法： |
| private void StartSe | ndText(string strHost,int iP | ort,string strInfo) |
| { |
| SendText CommunClass.OnSend(OnSen | stText = new SendText(strHos dDrawProgress)) ; | t,iPort,strInfo,new |
| StartThread(new Threa | dStart(stText.Send)) ; |
| } |
| 下面是他调用用到的一些方法： |
| 开始一个线程 |
| private void StartThread(ThreadS | tart target) |
| { |
| Thread do | Step = new Thread(target) ; | |
| doStep.IsBackground = true ; |
| doStep.Start() ; |
| } |
| 发送一部分（本文设置的是1024字节）成功后的回调方法 |
| public void OnSendDrawPr | ogress(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 Co | mmunClass.OnSend onsend ; |
| public Send | Text(string strHost,int iPor | t,string strInfo, |
| CommunClass.OnSend onSend) |
| { |
| Host = strHost ; |
| Port = iPort ; |
| Info = strInfo ; |
| onsend = onSend ; |
| } |
| public void Send() |
| { |
| Socket s = null ; |
| try |
| { |
| s | = CommunClass.ConnectToServ | er(Host,Port) ; |
| CommunClass.W | riteCommandToSocket(s,"SENDTEXT") ; |
| CommunClass.W | riteCommandDescToSocket(s,"") ; |
| C | ommunClass.WriteDynamicTextT | oSocket(s,Info,onsend) ; |
| } |
| catch (Exception e) |
| { |
| MessageBox.Show(e.Message) ; |
| } |
| finally |
| { |
| if (s != null) |
| s.Close() ; |
| } |
| } |
| }//end class |
| 这样就可以使用一个线程发送谋玖恕?nbsp; |
| 发送文件的方法也类似： |
| private void StartSe | ndFile(string strHost,int iP | ort,string strFile) |
| { |
| SendFile sfFile = new | SendFile(strHost,iPort,strFile,this.pbMain) ; |
| pbMain.Value = 0 ; |
| StartThre | ad(new ThreadStart(sfFile.Se | nd)) ; |
| } |
| <b>发送文件的类：</b> |
| public class SendFile |
| { |
| private string Host ; |
| private int Port ; |
| private string FileToSend ; |
| private ProgressBar pbar; |
| public Send pbMain) | File(string strHost,int iPor | t,string strFile,ProgressBar |
| { |
| Host = strHost ; |
| Port = iPort ; |
| FileToSend = strFile ; |
| pbar = pbMain ; |
| } |
| public void Send() |
| { |
| Socket s = null ; |
| try |
| { |
| s = CommunCla | ss.ConnectToServer(Host,Port) ; |
| C | ommunClass.WriteCommandToSoc | ket(s,"SENDFILE") ; |
| CommunClass.W | riteCommandDescToSocket(s,"") ; |
| C CommunClass.OnSend(OnSen | ommunClass.WriteFileToSocket dDrawProgress)) ; | (s,FileToSend,new |
| } |
| catch (Exception e) |
| { |
| MessageBox.Show(e.Message) ; |
| } |
| finally |
| { |
| if (s != null) |
| s.Close() ; |
| } |
| } |
| public void | OnSendDrawProgress(int iTot | al,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(stri strFileName,string strCmdParam) | ng strHost,int iPort,string |
| { |
| Host = strHost ; |
| Port = iPort ; |
| FileName = strFileName ; |
| cmdParam = strCmdParam ; |
| } |
| public void Send() |
| { |
| Socket s = null ; |
| try |
| { |
| s | = CommunClass.ConnectToServ | er(Host,Port) ; |
| CommunClass.W | riteCommandToSocket(s,"EXECUTEFILE") ; |
| CommunClass.W | riteCommandDescToSocket(s,FileName) ; |
| C | ommunClass.WriteDynamicTextT | oSocket(s,"",null) ; |
| M | essageBox.Show(CommunClass.R | eadDynamicTextFromSocket(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 BuildingS | erver(string strAddress,int iPort) |
| { |
| IPAddress ipAddres | s = Dns.Resolve(strAddress).AddressList[0]; |
| try |
| { |
| l | istener = new TcpListener(i | pAddress, iPort); |
| } |
| catch ( Exception e) |
| { |
| AddInfo(e.Message) ; |
| } |
| } |
| <b>开始监听：</b> |
| /// <summary> |
| /// 开始监听 |
| /// </summary> |
| private void StartListen() |
| { |
| bool done = false; |
| listener.Start(); |
| while (!done) |
| { |
| S | ocket s = listener.AcceptSoc | ket() ; |
| if(s != null) |
| { |
| ; | DealWithSocket dws = new | DealWithSocket(s,this.tbLog) |
| | StartThread(new ThreadSt | art(dws.DealWith)) ; |
| } |
| } |
| } |
| private void StartTh | read(ThreadStart target) |
| { |
| Thread doStep = ne | w Thread(target) ; |
| oStep.IsBackground = true ; |
| doStep.Start() ; |
| } |
| 开始监听后，对于每一 DealWithSocket来完成,下 | 个监听到的客户端的连接都用一 面是类代码: | 个单独的线程来处理,处理通过类 |
| public class DealWithSocket |
| { |
| private Socket s = null ; |
| private TextBox tbLog = null ; |
| public Deal | WithSocket(Socket newSocket, | TextBox tbInfo) |
| { |
| s = newSocket ; |
| tbLog = tbInfo ; |
| } |
| public void DealWith() |
| { |
| string strCmd = Co | mmunClass.ReadCommandFromSocket(s) ; |
| string | strDesc = CommunClass.ReadC | ommandDescFromSocket(s) ; |
| AddInfo(strCmd) ; |
| switch(strCmd) |
| { |
| case "SENDFILE" : |
| CommunCl ocket(s,"e:\rrr.txt") ; | ass.ReadDynamicFileFromS |
| break ; |
| case "EXECUTEFILE" : |
| TextFromSocket(s) ; | string strParam = CommunC | lass.ReadDynamic |
| | string strResult = ExeCut | eFile(strDesc,strParam) ; |
| CommunCl cket(s,strResult,null) ; | ass.WriteDynamicTextToSo |
| break ; |
| default: |
| cTextFromSocket(s) ; | string strDetail = Commun | Class.ReadDynami |
| AddInfo(strDetail) ; |
| break ; |
| } |
| try |
| { |
| s.Close() ; |
| } |
| catch (Exception e) |
| { |
| AddInfo(e.Message) ; |
| } |
| } |
| private void AddInfo(s | tring strInfo) |
| { |
| string Info = Date +"rn" ; | Time.Now.ToLongTimeString() + " "+ strInfo |
| tbLog.Text += Info ; |
| tbLog.Refresh() ; |
| } |
| private st | ring ExeCuteFile(string strF | ileName,string strCmdParam) |
| { |
| System.Diagnostics em.Diagnostics.Process() ; | .Process proc = new Syst |
| proc.StartInfo.Fil | eName = strFileName ; |
| proc.StartInfo.Arg | uments = strCmdParam ; |
| try |
| { |
| proc.Start() ; |
| return "OK" ; |
| } |
| catch(Exception err) |
| { |
| return err.Message ; |
| } |
| } |
| }//end class |