使用C#进行点对点通讯和文件传输

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› c#›C#教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

<b>发送部分：</b>
　　发送咱们使用了多线程，可以同时进行多个任务，比如发送文件、发送文本等，互不影响：
　　
　　发送文本方法：
　　
　　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)) ;　　　　
　　
　　　　　 }
　　
　　<b>发送文件的类：</b>
　　
　　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)
　　
　　　　　　　　　{
　　
　　　　　　　　　　　 AddI