使用C#进行点对点通讯和文件传输(通讯基类部分)

最近一个项目要用到点对点文件传输,俺就到处找资料写程序,最后终于完成了,为了让别人少走些弯路,俺决定将俺程序中最重要的部分贡献出来,希望对大家有所帮助。

俺的程序分三部分,包括发送部分、接受部分和一个两者共享的通讯基类,这个基类才是俺心血的结晶:)

一、通讯基类

using System;

using System.Net.Sockets;

using System.Net ;

using System.IO ;

using System.Windows.Forms;

using System.Text;

namespace BaseClass

{

///

1<summary>
2
3///  传送信息的格式为 给定长度的命令部分+给定长度的命令注释部分+可变长度的长度信息+可变长度的信息部分 
4
5///  </summary>

public class CommunClass

{

public CommunClass()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

///

1<summary>
2
3///  命令部分的长度 
4
5///  </summary>

private static readonly int CMDLEN = 50 ;

///

1<summary>
2
3///  命令注释部分的长度 
4
5///  </summary>

private static readonly int DESCLEN = 100 ;

///

1<summary>
2
3///  可变长度的长度信息部分所占的字节数 
4
5///  </summary>

private static readonly int DYNAMICLENGTHLEN = 10 ;

///

1<summary>
2
3///  每次处理可变信息部分的长度 
4
5///  </summary>

private static readonly int DEALLEN = 1024 ;

///

1<summary>
2
3///  /应答的最大长度 
4
5///  </summary>

private static readonly int RESPONLEN = 20 ;

///

1<summary>
2
3///  用于填充命令或注释不足长度部分的字符 
4
5///  </summary>

private static readonly char FILLCHAR = '^' ;

///

1<summary>
2
3///  成功发送一部分数据后的回调方法(也可以认为是触发的事件,但严格来说还不是) 
4
5///  </summary>

public delegate void OnSend( int iTotal, int iSending) ;

///

1<summary>
2
3///  根据给定的服务器和端口号建立连接 
4
5///  </summary>

///

1<param name="strHost"/>

服务器名

///

1<param name="iPort"/>

端口号

///

1<returns></returns>

public static Socket ConnectToServer( string strHost, int iPort)

{

try

{

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

IPEndPoint ipPoint = new IPEndPoint(ipAddress,iPort) ;

Socket s = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp) ;

s.Connect(ipPoint) ;

return s ;

}

catch (Exception e)

{

throw ( new Exception("建立到服务器的连接出错" + e.Message)) ;

}

}

///

1<summary>
2
3///  将文本写到Socket中 
4
5///  </summary>

///

1<param name="s"/>

要发送信息的Socket

///

1<param name="strInfo"/>

要发送的信息

///

1<returns> 是否成功  </returns>

public static bool WriteTextToSocket(Socket s, string strInfo)

{

byte [] buf = Encoding.UTF8.GetBytes(strInfo) ;

try

{

s.Send(buf,0,buf.Length,SocketFlags.None) ;

return true ;

}

catch (Exception err)

{

MessageBox.Show("发送文本失败!"+err.Message) ;

return false ;

}

}

///

1<summary>
2
3///  将命令文本写到Socket中 
4
5///  </summary>

///

1<param name="s"/>

要发送命令文本的Socket

///

1<param name="strInfo"/>

要发送的命令文本

///

1<returns> 是否成功  </returns>

public static bool WriteCommandToSocket(Socket s, string strCmd)

{

if (strCmd == "")

strCmd = "NOP" ;

strCmd = strCmd.PadRight(CMDLEN,FILLCHAR) ;

return WriteTextToSocket(s,strCmd) ;

}

///

1<summary>
2
3///  将命令注释写到Socket中 
4
5///  </summary>

///

1<param name="s"/>

要发送命令注释的Socket

///

1<param name="strInfo"/>

要发送的命令注释

///

1<returns> 是否成功  </returns>

public static bool WriteCommandDescToSocket(Socket s, string strDesc)

{

if (strDesc == "")

strDesc = "0" ;

strDesc = strDesc.PadRight(DESCLEN,FILLCHAR) ;

return WriteTextToSocket(s,strDesc) ;

}

///

1<summary>
2
3///  发送可变信息的字节数 
4
5///  </summary>

///

1<param name="s"/>

要发送字节数的Socket

///

1<param name="iLen"/>

字节数

///

1<returns> 是否成功  </returns>

<span sty

Published At
Categories with Web编程
Tagged with
comments powered by Disqus