开篇
本人由于关于收集编程的喜欢,经常性的运用c#编写各种服务器(e.g TCP服务器,UDP服务器),然则基本上都是搞着玩,网上也有许多讲c#收集编程的文章,固然我也参考了许多作者写的文章。看了这篇文章今后再也不必导出找材料了。
本系列文章会顺次引见运用Socket完成的异步TCP服务器、同步TCP服务器、异步UDP服务器、同步UDP服务器 and 运用TcpListener和UdpClient完成的异步TCP服务器、同步TCP服务器、异步UDP服务器、同步UDP服务器。
Socket异步TCP服务器
置信搞过收集编程的人来讲这个TCP一点也不生疏吧,在C#中微软已帮我们封装过了一个TcpListener和TcpClient这两个类了,完成了关于套接字的封装,然则呢实际上照样不怎么好用,所以我们用Socket来完成一个异步的TCP服务器。
在本文中我只给出服务器端代码,客户端代码本身能够找找别处,毕竟我只是为了写出一个好的服务器端
下面是代码
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; using System.Net; namespace NetFrame.Net.TCP.Sock.Asynchronous { /// <summary> /// Socket完成的异步TCP服务器 /// </summary> public class AsyncSocketTCPServer : IDisposable { #region Fields /// <summary> /// 服务器顺序许可的最大客户端衔接数 /// </summary> private int _maxClient; /// <summary> /// 当前的衔接的客户端数 /// </summary> private int _clientCount; /// <summary> /// 服务器运用的异步socket /// </summary> private Socket _serverSock; /// <summary> /// 客户端会话列表 /// </summary> private List<AsyncSocketState> _clients; private bool disposed = false; #endregion #region Properties /// <summary> /// 服务器是不是正在运转 /// </summary> public bool IsRunning { get; private set; } /// <summary> /// 监听的IP地点 /// </summary> public IPAddress Address { get; private set; } /// <summary> /// 监听的端口 /// </summary> public int Port { get; private set; } /// <summary> /// 通讯运用的编码 /// </summary> public Encoding Encoding { get; set; } #endregion #region 组织函数 /// <summary> /// 异步Socket TCP服务器 /// </summary> /// <param name="listenPort">监听的端口</param> public AsyncSocketTCPServer(int listenPort) : this(IPAddress.Any, listenPort,1024) { } /// <summary> /// 异步Socket TCP服务器 /// </summary> /// <param name="localEP">监听的终结点</param> public AsyncSocketTCPServer(IPEndPoint localEP) : this(localEP.Address, localEP.Port,1024) { } /// <summary> /// 异步Socket TCP服务器 /// </summary> /// <param name="localIPAddress">监听的IP地点</param> /// <param name="listenPort">监听的端口</param> /// <param name="maxClient">最大客户端数量</param> public AsyncSocketTCPServer(IPAddress localIPAddress, int listenPort,int maxClient) { this.Address = localIPAddress; this.Port = listenPort; this.Encoding = Encoding.Default; _maxClient = maxClient; _clients = new List<AsyncSocketState>(); _serverSock = new Socket(localIPAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp); } #endregion #region Method /// <summary> /// 启动服务器 /// </summary> public void Start() { if (!IsRunning) { IsRunning = true; _serverSock.Bind(new IPEndPoint(this.Address, this.Port)); _serverSock.Listen(1024); _serverSock.BeginAccept(new AsyncCallback(HandleAcceptConnected), _serverSock); } } /// <summary> /// 启动服务器 /// </summary> /// <param name="backlog"> /// 服务器所许可的挂起衔接序列的最大长度 /// </param> public void Start(int backlog) { if (!IsRunning) { IsRunning = true; _serverSock.Bind(new IPEndPoint(this.Address, this.Port)); _serverSock.Listen(backlog); _serverSock.BeginAccept(new AsyncCallback(HandleAcceptConnected), _serverSock); } } /// <summary> /// 住手服务器 /// </summary> public void Stop() { if (IsRunning) { IsRunning = false; _serverSock.Close(); //TODO 封闭对一切客户端的衔接 } } /// <summary> /// 处置惩罚客户端衔接 /// </summary> /// <param name="ar"></param> private void HandleAcceptConnected(IAsyncResult ar) { if (IsRunning) { Socket server = (Socket)ar.AsyncState; Socket client = server.EndAccept(ar); //搜检是不是到达最大的许可的客户端数量 if (_clientCount >= _maxClient) { //C-TODO 触发事宜 RaiseOtherException(null); } else { AsyncSocketState state = new AsyncSocketState(client); lock (_clients) { _clients.Add(state); _clientCount++; RaiseClientConnected(state); //触发客户端衔接事宜 } state.RecvDataBuffer = new byte[client.ReceiveBufferSize]; //最先吸收来自该客户端的数据 client.BeginReceive(state.RecvDataBuffer, 0, state.RecvDataBuffer.Length, SocketFlags.None, new AsyncCallback(HandleDataReceived), state); } //吸收下一个要求 server.BeginAccept(new AsyncCallback(HandleAcceptConnected), ar.AsyncState); } } /// <summary> /// 处置惩罚客户端数据 /// </summary> /// <param name="ar"></param> private void HandleDataReceived(IAsyncResult ar) { if (IsRunning) { AsyncSocketState state = (AsyncSocketState)ar.AsyncState; Socket client = state.ClientSocket; try { //假如两次最先了异步的吸收,所以当客户端退出的时刻 //会两次实行EndReceive int recv = client.EndReceive(ar); if (recv == 0) { //C- TODO 触发事宜 (封闭客户端) Close(state); RaiseNetError(state); return; } //TODO 处置惩罚已读取的数据 ps:数据在state的RecvDataBuffer中 //C- TODO 触发数据吸收事宜 RaiseDataReceived(state); } catch (SocketException) { //C- TODO 非常处置惩罚 RaiseNetError(state); } finally { //继承吸收来自来客户端的数据 client.BeginReceive(state.RecvDataBuffer, 0, state.RecvDataBuffer.Length, SocketFlags.None, new AsyncCallback(HandleDataReceived), state); } } } /// <summary> /// 发送数据 /// </summary> /// <param name="state">吸收数据的客户端会话</param> /// <param name="data">数据报文</param> public void Send(AsyncSocketState state, byte[] data) { RaisePrepareSend(state); Send(state.ClientSocket, data); } /// <summary> /// 异步发送数据至指定的客户端 /// </summary> /// <param name="client">客户端</param> /// <param name="data">报文</param> public void Send(Socket client, byte[] data) { if (!IsRunning) throw new InvalidProgramException("This TCP Scoket server has not been started."); if (client == null) throw new ArgumentNullException("client"); if (data == null) throw new ArgumentNullException("data"); client.BeginSend(data, 0, data.Length, SocketFlags.None, new AsyncCallback(SendDataEnd), client); } /// <summary> /// 发送数据完成处置惩罚函数 /// </summary> /// <param name="ar">目的客户端Socket</param> private void SendDataEnd(IAsyncResult ar) { ((Socket)ar.AsyncState).EndSend(ar); RaiseCompletedSend(null); } #endregion #region 事宜 /// <summary> /// 与客户端的衔接已竖立事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> ClientConnected; /// <summary> /// 与客户端的衔接已断开事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> ClientDisconnected; /// <summary> /// 触发客户端衔接事宜 /// </summary> /// <param name="state"></param> private void RaiseClientConnected(AsyncSocketState state) { if (ClientConnected != null) { ClientConnected(this, new AsyncSocketEventArgs(state)); } } /// <summary> /// 触发客户端衔接断开事宜 /// </summary> /// <param name="client"></param> private void RaiseClientDisconnected(Socket client) { if (ClientDisconnected != null) { ClientDisconnected(this, new AsyncSocketEventArgs("衔接断开")); } } /// <summary> /// 吸收到数据事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> DataReceived; private void RaiseDataReceived(AsyncSocketState state) { if (DataReceived != null) { DataReceived(this, new AsyncSocketEventArgs(state)); } } /// <summary> /// 发送数据前的事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> PrepareSend; /// <summary> /// 触发发送数据前的事宜 /// </summary> /// <param name="state"></param> private void RaisePrepareSend(AsyncSocketState state) { if (PrepareSend != null) { PrepareSend(this, new AsyncSocketEventArgs(state)); } } /// <summary> /// 数据发送终了事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> CompletedSend; /// <summary> /// 触发数据发送终了的事宜 /// </summary> /// <param name="state"></param> private void RaiseCompletedSend(AsyncSocketState state) { if (CompletedSend != null) { CompletedSend(this, new AsyncSocketEventArgs(state)); } } /// <summary> /// 收集毛病事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> NetError; /// <summary> /// 触发收集毛病事宜 /// </summary> /// <param name="state"></param> private void RaiseNetError(AsyncSocketState state) { if (NetError != null) { NetError(this, new AsyncSocketEventArgs(state)); } } /// <summary> /// 非常事宜 /// </summary> public event EventHandler<AsyncSocketEventArgs> OtherException; /// <summary> /// 触发非常事宜 /// </summary> /// <param name="state"></param> private void RaiseOtherException(AsyncSocketState state, string descrip) { if (OtherException != null) { OtherException(this, new AsyncSocketEventArgs(descrip, state)); } } private void RaiseOtherException(AsyncSocketState state) { RaiseOtherException(state, ""); } #endregion #region Close /// <summary> /// 封闭一个与客户端之间的会话 /// </summary> /// <param name="state">须要封闭的客户端会话对象</param> public void Close(AsyncSocketState state) { if (state != null) { state.Datagram = null; state.RecvDataBuffer = null; _clients.Remove(state); _clientCount--; //TODO 触发封闭事宜 state.Close(); } } /// <summary> /// 封闭一切的客户端会话,与一切的客户端衔接会断开 /// </summary> public void CloseAllClient() { foreach (AsyncSocketState client in _clients) { Close(client); } _clientCount = 0; _clients.Clear(); } #endregion #region 开释 /// <summary> /// Performs application-defined tasks associated with freeing, /// releasing, or resetting unmanaged resources. /// </summary> public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } /// <summary> /// Releases unmanaged and - optionally - managed resources /// </summary> /// <param name="disposing"><c>true</c> to release /// both managed and unmanaged resources; <c>false</c> /// to release only unmanaged resources.</param> protected virtual void Dispose(bool disposing) { if (!this.disposed) { if (disposing) { try { Stop(); if (_serverSock != null) { _serverSock = null; } } catch (SocketException) { //TODO RaiseOtherException(null); } } disposed = true; } } #endregion } }
事宜参数类
using System; using System.Collections.Generic; using System.Linq; using System.Text; namespace NetFrame.Net.TCP.Sock.Asynchronous { /// <summary> /// 异步Socket TCP事宜参数类 /// </summary> public class AsyncSocketEventArgs:EventArgs { /// <summary> /// 提醒信息 /// </summary> public string _msg; /// <summary> /// 客户端状况封装类 /// </summary> public AsyncSocketState _state; /// <summary> /// 是不是已处置惩罚过了 /// </summary> public bool IsHandled { get; set; } public AsyncSocketEventArgs(string msg) { this._msg = msg; IsHandled = false; } public AsyncSocketEventArgs(AsyncSocketState state) { this._state = state; IsHandled = false; } public AsyncSocketEventArgs(string msg, AsyncSocketState state) { this._msg = msg; this._state = state; IsHandled = false; } } }
用户状况封装
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; namespace NetFrame.Net.TCP.Sock.Asynchronous { /// <summary> /// 异步SOCKET TCP 中用来存储客户端状况信息的类 /// </summary> public class AsyncSocketState { #region 字段 /// <summary> /// 吸收数据缓冲区 /// </summary> private byte[] _recvBuffer; /// <summary> /// 客户端发送到服务器的报文 /// 注重:在有些情况下报文能够只是报文的片段而不完整 /// </summary> private string _datagram; /// <summary> /// 客户端的Socket /// </summary> private Socket _clientSock; #endregion #region 属性 /// <summary> /// 吸收数据缓冲区 /// </summary> public byte[] RecvDataBuffer { get { return _recvBuffer; } set { _recvBuffer = value; } } /// <summary> /// 存取会话的报文 /// </summary> public string Datagram { get { return _datagram; } set { _datagram = value; } } /// <summary> /// 获得与客户端会话关联的Socket对象 /// </summary> public Socket ClientSocket { get { return _clientSock; } } #endregion /// <summary> /// 组织函数 /// </summary> /// <param name="cliSock">会话运用的Socket衔接</param> public AsyncSocketState(Socket cliSock) { _clientSock = cliSock; } /// <summary> /// 初始化数据缓冲区 /// </summary> public void InitBuffer() { if (_recvBuffer == null&&_clientSock!=null) { _recvBuffer=new byte[_clientSock.ReceiveBufferSize]; } } /// <summary> /// 封闭会话 /// </summary> public void Close() { //封闭数据的吸收和发送 _clientSock.Shutdown(SocketShutdown.Both); //清算资本 _clientSock.Close(); } } }
以上就是C#收集编程系列文章(一)之Socket完成异步TCP服务器的内容,更多相关内容请关注ki4网(www.ki4.cn)!