最近一个项目要用到点对点文件传输,俺就到处找资料写程序,最后终于完成了,为了让别人少走些弯路,俺决定将俺程序中最重要的部分贡献出来,希望对大家有所帮助。
俺的程序分三部分,包括发送部分、接受部分和一个两者共享的通讯基类,这个基类才是俺心血的结晶:)
一、通讯基类
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