c#中异步基于消息通信的完成端口的TCP/IP协议的组件实现(源代码)

异步|源代码

源代码:

客户端:

using System;
using System.IO;
using System.ComponentModel;
using System.Collections;
using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace MyKJ
{
?///
?/// MyTcpIpClient 提供在Net TCP_IP 协议上基于消息的客户端
?///
?public class MyTcpIpClient : System.ComponentModel.Component
?{
??private int bufferSize=2048;
??private string tcpIpServerIP="127.0.0.1";
??private int tcpIpServerPort=11000;
??private Socket ClientSocket=null;
??private ManualResetEvent connectDone = new ManualResetEvent(false);
??private ManualResetEvent sendDone = new ManualResetEvent(false);
??
??private void ConnectCallback(IAsyncResult ar)
??{
???try
???{
????Socket client = (Socket) ar.AsyncState;
????client.EndConnect(ar);
????
???}
???catch (Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
???}
???finally
???{
????connectDone.Set();
???}
??}
??private void SendCallback(IAsyncResult ar)
??{
???try
???{
????Socket client = (Socket) ar.AsyncState;
????int bytesSent = client.EndSend(ar);
????//Console.WriteLine(bytesSent);
???}
???catch (Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
???}
???finally
???{
????sendDone.Set();
???}
??}
??private void ReceiveCallback(IAsyncResult ar)
??{
???Socket handler=null;
???try
???{
????lock(ar)
????{
?????StateObject state = (StateObject) ar.AsyncState;
?????handler = state.workSocket;
?????
?????int bytesRead = handler.EndReceive(ar);
?????
?????if (bytesRead > 0)
?????{
??????int ReadPiont=0;?
??????while(ReadPiont??????{?
???????if(state.Cortrol==0 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<24)&0xff000000;
????????state.packSize=bi1;
????????ReadPiont++;
????????state.Cortrol=1;
???????}
??????
???????if(state.Cortrol==1 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<16)&0x00ff0000;
????????state.packSize=state.packSize+bi1;
????????ReadPiont++;
????????state.Cortrol=2;
???????}
??????
???????if(state.Cortrol==2 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<8)&0x0000ff00;
????????state.packSize=state.packSize+bi1;
????????ReadPiont++;
????????state.Cortrol=3;
???????}
???????
???????if(state.Cortrol==3 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=bi1&0xff;
????????state.packSize=state.packSize+bi1-4;
????????ReadPiont++;
????????state.Cortrol=4;
???????}
???????
???????if(state.Cortrol==4 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<24)&0xff000000;
????????state.residualSize=bi1;
????????ReadPiont++;
????????state.Cortrol=5;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==5 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<16)&0x00ff0000;
????????state.residualSize=state.residualSize+bi1;
????????ReadPiont++;
????????state.Cortrol=6;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==6 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<8)&0x0000ff00;
????????state.residualSize=state.residualSize+bi1;
????????ReadPiont++;
????????state.Cortrol=7;
????????state.packSize-=1;
???????}
???????if(state.Cortrol==7 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=bi1&0xff;
????????state.residualSize=state.residualSize+bi1;
????????state.Datastream.SetLength(0);
????????state.Datastream.Position=0;
????????
????????ReadPiont++;
????????state.Cortrol=8;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==8 && ReadPiont???????{
????????int bi1=bytesRead-ReadPiont;
????????int bi2=(int)(state.residualSize-state.Datastream.Length);
????????if(bi1>=bi2)
????????{
?????????state.Datastream.Write(state.buffer,ReadPiont,bi2);
?????????ReadPiont+=bi2;
?????????OnInceptEvent(new InceptEventArgs(state.Datastream,handler));
?????????state.Cortrol=9;
?????????state.packSize-=bi2;
?????????}
????????else
????????{
?????????state.Datastream.Write(state.buffer,ReadPiont,bi1);
?????????ReadPiont+=bi1;
?????????state.packSize-=bi1;
????????}
???????}
???????if(state.Cortrol==9 && ReadPiont???????{
????????int bi1=bytesRead-ReadPiont;
????????if(bi1????????{
?????????state.packSize=state.packSize-bi1;
?????????ReadPiont+=bi1;
????????}?
????????else
????????{
?????????state.Cortrol=0;
?????????ReadPiont+=(int)state.packSize;
????????}
???????}
??????}
?????}
?????else
?????{
??????throw(new Exception("读入的数据小于1bit"));
?????}
?????if(handler.Connected==true)
?????{
??????handler.BeginReceive(state.buffer,0,bufferSize,0,
???????new AsyncCallback(ReceiveCallback), state);
?????}
????}
???}
???catch (Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
????
???}
??}
??
??///
??/// 连接服务器
??///
??public void Conn()
??{
???try
???{
????ClientSocket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);?
????IPAddress ipAddress = IPAddress.Parse(tcpIpServerIP);
????IPEndPoint remoteEP = new IPEndPoint(ipAddress, tcpIpServerPort);
????connectDone.Reset();
????ClientSocket.BeginConnect(remoteEP,new AsyncCallback(ConnectCallback),ClientSocket);
????connectDone.WaitOne();
????StateObject state = new StateObject(bufferSize,ClientSocket);
????ClientSocket.BeginReceive(state.buffer,0,bufferSize,0,
?????new AsyncCallback(ReceiveCallback), state);?
???}
???catch(Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
???}
???
??}
??///
??/// 断开连接
??///
??public void Close()
??{
???try
???{
????ClientSocket.Shutdown(SocketShutdown.Both);
????ClientSocket.Close();
???}
???catch(Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
???}
???
??}
??///
??/// 发送一个流数据
??///
??/// 数据流
??public void Send(Stream Astream)
??{
???try
???{
????if(ClientSocket.Connected==false)
????{
?????throw(new Exception("没有连接服务器不可以发送信息!"));
????}
????Astream.Position=0;
????byte[] byteData=new byte[bufferSize];
????int bi1=(int)((Astream.Length+8)/bufferSize);
????int bi2=(int)Astream.Length;
????if(((Astream.Length+8)%bufferSize)>0)
????{
?????bi1=bi1+1;
????}
????bi1=bi1*bufferSize;
????
????byteData[0]=System.Convert.ToByte(bi1>>24);
????byteData[1]=System.Convert.ToByte((bi1&0x00ff0000)>>16);
????byteData[2]=System.Convert.ToByte((bi1&0x0000ff00)>>8);
????byteData[3]=System.Convert.ToByte((bi1&0x000000ff));
????
????byteData[4]=System.Convert.ToByte(bi2>>24);
????byteData[5]=System.Convert.ToByte((bi2&0x00ff0000)>>16);
????byteData[6]=System.Convert.ToByte((bi2&0x0000ff00)>>8);
????byteData[7]=System.Convert.ToByte((bi2&0x000000ff));
????
????int n = Astream.Read(byteData, 8, byteData.Length-8);
????
????while (n>0)
????{
?????ClientSocket.BeginSend(byteData, 0, byteData.Length, 0,?new AsyncCallback(SendCallback), ClientSocket);
?????sendDone.WaitOne();
?????byteData=new byte[bufferSize];
?????n = Astream.Read(byteData,0,byteData.Length);
????}
???}
???catch (Exception e)
???{
????OnErrorEvent(new ErrorEventArgs(e));
???}
??}
??
??///
??/// 构造
??///
??/// 父控件
??public MyTcpIpClient(System.ComponentModel.IContainer container)
??{
???container.Add(this);
???InitializeComponent();

???//
???// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
???//
??}
??///
??/// 构造
??///
??public MyTcpIpClient()
??{
???InitializeComponent();

???//
???// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
???//
??}

??#region Component Designer generated code
??///
??/// 设计器支持所需的方法 - 不要使用代码编辑器修改
??/// 此方法的内容。
??///
??private void InitializeComponent()
??{

??}
??#endregion

??///
??/// 要连接的服务器IP地址
??///
??public string TcpIpServerIP
??{
???get
???{
????return tcpIpServerIP;
???}
???set
???{
????tcpIpServerIP=value;
???}
??}

??///
??/// 要连接的服务器所使用的端口
??///
??public int TcpIpServerPort
??{
???get
???{
????return tcpIpServerPort;
???}
???set
???{
????tcpIpServerPort=value;
???}
??}

??///
??/// 缓冲器大小
??///
??public int BufferSize
??{
???get
???{
????return bufferSize;
???}
???set
???{
????bufferSize=value;
???}
??}
??
??///
??/// 连接的活动状态
??///
??public bool Activ
??{
???get
???{
????if(ClientSocket==null)
????{
?????return false;
????}
????return ClientSocket.Connected;
???}
??}
??///
??/// 接收到数据引发的事件
??///
??public event InceptEvent Incept;
??///
??/// 引发接收数据事件
??///
??/// 接收数据
??protected virtual void OnInceptEvent(InceptEventArgs e)
??{
???if (Incept != null)
???{
????Incept(this, e);
???}
??}
??///
??/// 发生错误引发的事件
??///
??public event ErrorEvent Error;
??///
??/// 引发错误事件
??///
??/// 错误数据
??protected virtual void OnErrorEvent(ErrorEventArgs e)
??{
???if (Error != null)
???{
????Error(this, e);
???}
??}
??
?}
?
?///
?/// 接收数据事件
?///
?public class InceptEventArgs : EventArgs
?{?
??private readonly Stream datastream;
??private readonly Socket clientSocket;
??///
??/// 构造
??///
??/// 接收到的数据
??/// 接收的插座
??public InceptEventArgs(Stream Astream,Socket ClientSocket)
??{
???datastream=Astream;
???clientSocket=ClientSocket;
??}
??///
??/// 接受的数据流
??///
??public Stream Astream
??{????
???get { return datastream;}?????
??}
??///
??/// 接收的插座
??///
??public Socket ClientSocket
??{????
???get { return clientSocket;}?????
??}
?}?
?///
?/// 定义接收委托
?///
?public delegate void InceptEvent(object sender, InceptEventArgs e);
?///
?/// 错处事件
?///
?public class ErrorEventArgs : EventArgs
?{?
??private readonly Exception error;
??///
??/// 构造
??///
??/// 错误信息对象
??public ErrorEventArgs(Exception Error)
??{
???error=Error;
??}
??///
??/// 错误信息对象
??///
??public Exception Error
??{????
???get { return error;}?????
??}
?}
?///
?/// 错误委托
?///
?public delegate void ErrorEvent(object sender, ErrorEventArgs e);
?
?
?
}

服务器端:

using System;
using System.IO;
using System.ComponentModel;
using System.Collections;
using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace MyKJ
{
?///
?/// MyTcpIpClient 提供在Net TCP_IP 协议上基于消息的服务端
?///
?public class MyTcpIpServer : System.ComponentModel.Component
?{
??private int bufferSize=2048;
??private string tcpIpServerIP="";
??private int tcpIpServerPort=11000;
??private Socket listener=null;
??private ManualResetEvent allDone = new ManualResetEvent(false);
??private ManualResetEvent sendDone = new ManualResetEvent(false);
??private Thread thread=null;
??
??private void StartListening()
??{
???try
???{
????listener = new Socket(AddressFamily.InterNetwork,
?????SocketType.Stream, ProtocolType.Tcp);
?????
????IPAddress ipAddress;
????if(tcpIpServerIP.Trim()=="")
????{
?????ipAddress=IPAddress.Any;?
????}
????else
????{
?????ipAddress=IPAddress.Parse(tcpIpServerIP);
????}
????IPEndPoint localEndPoint = new IPEndPoint(ipAddress, tcpIpServerPort);
????
????listener.Bind(localEndPoint);
????listener.Listen(10);
????while (true)
????{
?????allDone.Reset();
?????listener.BeginAccept(new AsyncCallback(AcceptCallback),listener);
?????allDone.WaitOne();
????}
???}
???catch (Exception e)
???{
????OnErrorServerEvent(new ErrorServerEventArgs(e,listener));?
???}
??}
??
??private void ReadCallback(IAsyncResult ar)
??{
???Socket handler=null;
???try
???{
????lock(ar)
????{
?????StateObject state = (StateObject) ar.AsyncState;
?????handler = state.workSocket;
?????
?????int bytesRead = handler.EndReceive(ar);
?????
?????if (bytesRead > 0)
?????{
??????int ReadPiont=0;?
??????while(ReadPiont??????{?
???????if(state.Cortrol==0 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<24)&0xff000000;
????????state.packSize=bi1;
????????ReadPiont++;
????????state.Cortrol=1;
???????}
??????
???????if(state.Cortrol==1 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<16)&0x00ff0000;
????????state.packSize=state.packSize+bi1;
????????ReadPiont++;
????????state.Cortrol=2;
???????}
??????
???????if(state.Cortrol==2 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<8)&0x0000ff00;
????????state.packSize=state.packSize+bi1;
????????ReadPiont++;
????????state.Cortrol=3;
???????}
???????
???????if(state.Cortrol==3 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=bi1&0xff;
????????state.packSize=state.packSize+bi1-4;
????????ReadPiont++;
????????state.Cortrol=4;
???????}
???????
???????if(state.Cortrol==4 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<24)&0xff000000;
????????state.residualSize=bi1;
????????ReadPiont++;
????????state.Cortrol=5;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==5 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<16)&0x00ff0000;
????????state.residualSize=state.residualSize+bi1;
????????ReadPiont++;
????????state.Cortrol=6;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==6 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=(bi1<<8)&0x0000ff00;
????????state.residualSize=state.residualSize+bi1;
????????ReadPiont++;
????????state.Cortrol=7;
????????state.packSize-=1;
???????}
???????if(state.Cortrol==7 && ReadPiont???????{
????????long bi1=state.buffer[ReadPiont];
????????bi1=bi1&0xff;
????????state.residualSize=state.residualSize+bi1;
????????state.Datastream.SetLength(0);
????????state.Datastream.Position=0;
????????
????????ReadPiont++;
????????state.Cortrol=8;
????????state.packSize-=1;
???????}
???????
???????if(state.Cortrol==8 && ReadPiont???????{
????????int bi1=bytesRead-ReadPiont;
????????int bi2=(int)(state.residualSize-state.Datastream.Length);
????????if(bi1>=bi2)
????????{
?????????state.Datastream.Write(state.buffer,ReadPiont,bi2);
?????????ReadPiont+=bi2;
?????????OnInceptServerEvent(new InceptServerEventArgs(state.Datastream,state.workSocket,this));
?????????state.Cortrol=9;
?????????state.packSize-=bi2;
?????????
?????????
????????}
????????else
????????{
?????????state.Datastream.Write(state.buffer,ReadPiont,bi1);
?????????ReadPiont+=bi1;
?????????state.packSize-=bi1;
????????}
???????}
???????if(state.Cortrol==9 && ReadPiont???????{
????????int bi1=bytesRead-ReadPiont;
????????if(bi1????????{
?????????state.packSize=state.packSize-bi1;
?????????ReadPiont+=bi1;
????????}?
????????else
????????{
?????????state.Cortrol=0;
?????????ReadPiont+=(int)state.packSize;
????????}
???????}
??????}
??????if(handler.Connected==true)
??????{
???????handler.BeginReceive(state.buffer,0,bufferSize,0,
????????new AsyncCallback(ReadCallback), state);
??????}
?????}
?????else
?????{
??????handler.Shutdown(SocketShutdown.Both);
??????handler.Close();
??????//throw(new Exception("读入的数据小于1bit"));
?????}
????}
???}
???catch (Exception e)
???{
????OnErrorServerEvent(new ErrorServerEventArgs(e,handler));
????
???}
??}
??
??private void SendCallback(IAsyncResult ar)
??{
???Socket client = (Socket) ar.AsyncState;
???try
???{
????int bytesSent = client.EndSend(ar);
???}
???catch (Exception e)
???{
????OnErrorServerEvent(new ErrorServerEventArgs(e,client));
???}
???finally
???{
????sendDone.Set();
???}
??}
??
??private void AcceptCallback(IAsyncResult ar)
??{
???Socket handler=null;
???try
???{
????Socket listener = (Socket) ar.AsyncState;
????handler= listener.EndAccept(ar);
????StateObject state = new StateObject(bufferSize,handler);
????state.workSocket = handler;
????handler.BeginReceive(state.buffer,0,bufferSize,0,
?????new AsyncCallback(ReadCallback), state);
???}
???catch (Exception e)
???{
????OnErrorServerEvent(new ErrorServerEventArgs(e,handler));
???}
???finally
???{
????allDone.Set();
???}
??}
??
??///
??/// 析构
??///
??/// 不知道
??protected override void Dispose(bool disposing)
??{
???Abort();
??}
??
??///
??/// 引发接收事件
??///
??/// 数据
??protected virtual void OnInceptServerEvent(InceptServerEventArgs e)
??{
???if (InceptServer != null)
???{
????InceptServer(this, e);
???}
??}
??///
??/// 引发错误事件
??///
??/// 数据
??protected virtual void OnErrorServerEvent(ErrorServerEventArgs e)
??{
???if (ErrorServer != null)
???{
????ErrorServer(this, e);
???}
??}
??
??///
??/// 开始监听访问
??///
??public void Listening()
??{
???//StartListening();
???thread=new Thread(new ThreadStart(StartListening));
???thread.Name="MyTcpIpServer.Listening";
???thread.Start();
??}
??///
??/// 异常中止服务
??///
??public void Abort()
??{
???if(thread!=null)
???{
????thread.Abort();
????listener.Close();
???}
??}
??
??///
??///构造
??///
??/// 父控件
??public MyTcpIpServer(System.ComponentModel.IContainer container)
??{
???container.Add(this);
???InitializeComponent();

???//
???// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
???//
??}

??///
??/// 构造
??///
??public MyTcpIpServer()
??{
???InitializeComponent();

???//
???// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
???//
??}

??#region Component Designer generated code
??///
??/// 设计器支持所需的方法 - 不要使用代码编辑器修改
??/// 此方法的内容。
??///
??private void InitializeComponent()
??{

??}
??#endregion

??///
??/// 要连接的服务器IP地址
??///
??public string TcpIpServerIP
??{
???get
???{
????return tcpIpServerIP;
???}
???set
???{
????tcpIpServerIP=value;
???}
??}

??///
??/// 要连接的服务器所使用的端口
??///
??public int TcpIpServerPort
??{
???get
???{
????return tcpIpServerPort;
???}
???set
???{
????tcpIpServerPort=value;
???}
??}

??///
??/// 缓冲器大小
??///
??public int BufferSize
??{
???get
???{
????return bufferSize;
???}
???set
???{
????bufferSize=value;
???}
??}
??
??///
??/// 连接的活动状态
??///
??public bool Activ
??{
???get
???{
????return listener.Connected;
???}
???//set
???//{
???//?activ=value;
???//}
??}

??///
??/// 发送一个流数据
??///
??public void Send(Socket ClientSocket,Stream Astream)
??{
???try
???{
????if(ClientSocket.Connected==false)
????{
?????throw(new Exception("没有连接客户端不可以发送信息!"));
????}
????Astream.Position=0;
????byte[] byteData=new byte[bufferSize];
????int bi1=(int)((Astream.Length+8)/bufferSize);
????int bi2=(int)Astream.Length;
????if(((Astream.Length+8)%bufferSize)>0)
????{
?????bi1=bi1+1;
????}
????bi1=bi1*bufferSize;
????
????byteData[0]=System.Convert.ToByte(bi1>>24);
????byteData[1]=System.Convert.ToByte((bi1&0x00ff0000)>>16);
????byteData[2]=System.Convert.ToByte((bi1&0x0000ff00)>>8);
????byteData[3]=System.Convert.ToByte((bi1&0x000000ff));
????
????byteData[4]=System.Convert.ToByte(bi2>>24);
????byteData[5]=System.Convert.ToByte((bi2&0x00ff0000)>>16);
????byteData[6]=System.Convert.ToByte((bi2&0x0000ff00)>>8);
????byteData[7]=System.Convert.ToByte((bi2&0x000000ff));
????
????int n = Astream.Read(byteData, 8, byteData.Length-8);
????
????while (n>0)
????{
?????ClientSocket.BeginSend(byteData, 0, byteData.Length, 0,?new AsyncCallback(SendCallback), ClientSocket);
?????sendDone.WaitOne();
?????byteData=new byte[bufferSize];
?????n = Astream.Read(byteData,0,byteData.Length);
????}
???}
???catch (Exception e)
???{
????OnErrorServerEvent(new ErrorServerEventArgs(e,ClientSocket));
???}
??}
??
??///
??/// 接收到数据事件
??///
??public event InceptServerEvent InceptServer;
??///
??/// 发生错误事件
??///
??public event ErrorServerEvent ErrorServer;
?}
?///
?/// 状态对象
?///
?public class StateObject
?{
??///
??/// 构造
??///
??/// 缓存
??/// 工作的插座
??public StateObject(int bufferSize,Socket WorkSocket)
??{
???buffer = new byte[bufferSize];
???workSocket=WorkSocket;
??}
??///
??/// 缓存
??///
??public byte[] buffer = null;
??///
??/// 工作插座
??///
??public Socket workSocket = null;?????????????
??///
??/// 数据流
??///
??public Stream Datastream=new MemoryStream();
??///
??/// 剩余大小
??///
??public long residualSize=0;
??///
??/// 数据包大小
??///
??public long packSize=0;
??///
??/// 计数器
??///
??public int Cortrol=0;
?}
?
?///
?/// 接收事件
?///
?public class InceptServerEventArgs : EventArgs
?{?
??private readonly Stream datastream;
??private readonly Socket serverSocket;
??private readonly MyTcpIpServer tcpIpServer;
??///
??/// 构造
??///
??/// 数据
??/// 工作插座
??/// 提供服务的TCP/IP对象
??public InceptServerEventArgs(Stream Astream,Socket ServerSocket,MyTcpIpServer TcpIpServer)
??{
???datastream=Astream;
???serverSocket=ServerSocket;
???tcpIpServer=TcpIpServer;
??}
??? ///
??? /// 数据
??? ///
??public Stream Astream
??{????
???get { return datastream;}?????
??}
??///
??/// 工作插座
??///
??public Socket ServerSocket
??{????
???get { return serverSocket;}?????
??}
??///
??/// 提供TCP/IP服务的服务器对象.
??///
??public MyTcpIpServer TcpIpServer
??{????
???get { return tcpIpServer;}?????
??}
?}
?///
?/// 接收数据委托
?///
? public delegate void InceptServerEvent(object sender, InceptServerEventArgs e);
?///
?/// 错误事件委托
?///
?public class ErrorServerEventArgs : EventArgs
?{?
??private readonly Exception error;
??private readonly Socket serverSocket;
??///
??/// 构造
??///
??/// 数据
??/// 问题插座
??public ErrorServerEventArgs(Exception Error,Socket ServerSocket)
??{
???error=Error;
???serverSocket=ServerSocket;
??}
??? ///
??? /// 数据
??? ///
??public Exception Error
??{????
???get { return error;}?????
??}
??///
??/// 问题插座
??///
??public Socket ServerSocket
??{????
???get { return serverSocket;}?????
??}
?}
?///
?///错误事件委托
?///
? public delegate void ErrorServerEvent(object sender, ErrorServerEventArgs e);
}

完成端口方式是NT目前最好的一种通信方式,它在大吞吐,大数量连接下,比其它方式有无法比拟的效率以及性能,因C#在的Socket在内部使用的完成端口方式,在程序实现上异常简单,请大家体会.

?

?

时间： 2024-04-18 21:54:02

c#中异步基于消息通信的完成端口的TCP/IP协议的组件实现(源代码)的相关文章

CSDN论坛左侧个人用户中的社区消息功能是怎么实现的?重要的是谁有类似源代码?

问题描述 CSDN论坛左侧个人用户中的社区消息功能是怎么实现的?重要的是谁有类似源代码?有的话,我留言.我的分当然可以更高.这二十分只是问谁有.

基于TCP/IP协议的C++网络编程（API函数版）

源代码:http://download.csdn.net/detail/nuptboyzhb/4169959 基于TCP/IP协议的网络编程 定义变量--获得WINSOCK版本--加载WINSOCK库--初始化--创建套接字 --设置套接字选项--关闭套接字--卸载WINSOCK库--释放所有资源 整个程序架构分为两大部分,服务器端客户端. 服务器SOCKET程序流程: socket()→bind()→listen→accept()→recv()/send()→closesocket() 客户端

怎么配置局域网中的TCP/IP协议

  xp系统下载SyGate安装好后,不能马上就使用,还必须对局域网内各机器的TCP/IP协议进行一些设定.首先需要对主机进行设定. 1.主机的TCP/IP设置 主机的TCP/IP设置如下: [1]假如本机的网卡为8029,如图所示,选择"指定IP地址"为192.168.0.1(注意后面这个1可以是1到255之间的任意一个数字),子网掩码为255.255.255.0. [2]对"DNS配置"进行设置,勾选"启用DNS",输入电脑在局域网中的编号.

标准C实现基于TCP/IP协议的文件传输

TCP/IP编程实现远程文件传输在LUNIX中一般都采用套接字(socket)系统调用. 采用客户/服务器模式,其程序编写步骤如下: 1.Socket系统调用  为了进行网络I/O,服务器和客户机两端的UNIX进程要做的第一件事是调用socket()系统调用,建立软插座,指明合适的通讯协议.格式为:  1 2 3 #include >sys/types.h> #include >sys/socket.h>    int socket(int family,int type,int 

监听器在游戏开发中的应用----消息回调

我一向是不太喜欢给一些东西强加上个名字.但为了随波逐流,我还是这样做了. 在我们的游戏开发中,通常会遇到两个模块之间的通信. 回调估计是最常用的方式了. 回调的设计思想很简单,就是两个对象相互注册,然后在需要的时候调用对方的函数. 如下: class B;   class A   {   public:       void RegisterCallback(B* pB)       {           m_pB = pB;       }       void ActiveA()     

JAVA通信编程（三）——TCP通讯

继上一篇小插曲之后继续回到正题,本篇讲述的是java的TCP通讯.TCP编程分为server端和client端,一般在网上都能搜到相关的例子,为了方便大家,我这里先整理下server端和client端的应用案例,然后再根据在本系列中第一篇串口通讯中的结构一样实现CommBuff接口. java tcp socket编程server端: import java.io.*; import java.net.*; import java.applet.Applet; public class Talk

udp-TCP/IP协议中的IP和UDP问题

问题描述 TCP/IP协议中的IP和UDP问题 * # 既然IP协议和UDP协议都是实现数据无连接的不可靠通信协议,为什么有了IP之后还需要UDP? 解决方案 1.ISO开放系统有以下几层: 7 应用层 6 表示层 5 会话层 4 传输层 3 网络层 2 数据链路层 1 物理层 2.TCP/IP 网络协议栈分为应用层(Application).......答案就在这里:TCP.UDP.IP协议---------------------- 解决方案二: IP是网络层的,主机到主机的连接:UDP是传

在Windows 2003中重置TCP/IP

在Windows Server 2003(简称Windows 2003)的连接属性对话框中,如果点击"Internet协议(TCP/IP)选项,"卸载"按钮为灰色,是不可用的.这是因为TCP/IP协议是Windows Server 2003的核心组件,不能删除. 如果我们需要将TCP/IP重置到原始状态,该怎么办呢?此时,我们可以借助"netsh"命令行工具来解决这一问题.在"运行"对话框中输入"cmd",打开&qu

Windows 2003中重置TCP/IP

  在Windows Server 2003(简称windows 2003)的连接属性对话框中,如果点击"Internet协议(TCP/IP)选项,"卸载"按钮为灰色,是不可用的.这是因为TCP/IP协议是Windows Server 2003的核心组件,不能删除. 如果我们需要将TCP/IP重置到原始状态,该怎么办呢?此时,我们可以借助"netsh"命令行工具来解决这一问题.在"运行"对话框中输入"cmd",打开&