本文引见
TcpListener 类供应一些简朴要领,用于在阻挠同步形式下侦听和接收传入衔接要求。 可运用 TcpClient 或 Socket 来衔接 TcpListener。 可运用 IPEndPoint、当地 IP 地点及端口号或许仅运用端口号,来竖立 TcpListener。 能够将当地 IP 地点指定为 Any,将当地端口号指定为 0(假如愿望基本效劳供应顺序为您分派这些值)。 假如您挑选如许做,可在衔接套接字后运用 LocalEndpoint 属性来标识已指定的信息。运用 Start 要领,可最先侦听传入的衔接要求。 Start 将对传入衔接举行列队,直至您挪用 Stop 要领或它已完成 MaxConnections 列队为止。 可运用 AcceptSocket 或 AcceptTcpClient 从传入衔接要求行列提取衔接。 这两种要领将阻挠。 假如要防止阻挠,可起首运用 Pending 要领来肯定行列中是不是有可用的衔接要求。
虽然TcpListener已封装的比较不错了,我们于是就运用它在组织一个比较不错的同步TCP效劳器,这里依旧和前两章一样,给出效劳器中的代码,代码中解释很细致,我也会给出相干的封装类。
TcpListener同步TCP效劳器
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; using System.Net; using System.Threading; namespace NetFrame.Net.TCP.Listener.Synchronous { /// <summary> /// TcpListener完成同步TCP效劳器 /// </summary> public class TCPServer { #region Fields /// <summary> /// 效劳器顺序许可的最大客户端衔接数 /// </summary> private int _maxClient; /// <summary> /// 当前的衔接的客户端数 /// </summary> private int _clientCount; /// <summary> /// 效劳器运用的异步TcpListener /// </summary> private TcpListener _listener; /// <summary> /// 客户端会话列表 /// </summary> private List<TCPClientHandle> _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> /// 同步TCP效劳器 /// </summary> /// <param name="listenPort">监听的端口</param> public TCPServer(int listenPort) : this(IPAddress.Any, listenPort, 1024) { } /// <summary> /// 同步TCP效劳器 /// </summary> /// <param name="localEP">监听的终结点</param> public TCPServer(IPEndPoint localEP) : this(localEP.Address, localEP.Port, 1024) { } /// <summary> /// 同步TCP效劳器 /// </summary> /// <param name="localIPAddress">监听的IP地点</param> /// <param name="listenPort">监听的端口</param> /// <param name="maxClient">最大客户端数目</param> public TCPServer(IPAddress localIPAddress, int listenPort, int maxClient) { this.Address = localIPAddress; this.Port = listenPort; this.Encoding = Encoding.Default; _maxClient = maxClient; _clients = new List<TCPClientHandle>(); _listener = new TcpListener(new IPEndPoint(this.Address, this.Port)); } #endregion #region Method /// <summary> /// 启动效劳器 /// </summary> public void Start() { if (!IsRunning) { IsRunning = true; _listener.Start(); Thread thread = new Thread(Accept); thread.Start(); } } /// <summary> /// 最先举行监听 /// </summary> private void Accept() { TCPClientHandle handle; while (IsRunning) { TcpClient client = _listener.AcceptTcpClient(); if (_clientCount >= _maxClient) { //TODO 触发事宜 } else { handle = new TCPClientHandle(client); _clientCount++; _clients.Add(handle); //TODO 竖立一个处置惩罚客户端的线程并启动 //运用线程池来操纵 new Thread(new ThreadStart(handle.RecevieData)).Start(); } } } /// <summary> /// 住手效劳器 /// </summary> public void Stop() { if (IsRunning) { IsRunning = false; _listener.Stop(); //TODO 封闭对一切客户端的衔接 } } /// <summary> /// 发送函数 /// </summary> public void Send(string msg, TcpClient client) { //TODO } #endregion #region 事宜 /// <summary> /// 与客户端的衔接已竖立事宜 /// </summary> public event EventHandler<TCPEventArgs> ClientConnected; /// <summary> /// 与客户端的衔接已断开事宜 /// </summary> public event EventHandler<TCPEventArgs> ClientDisconnected; /// <summary> /// 触发客户端衔接事宜 /// </summary> /// <param name="state"></param> private void RaiseClientConnected(TCPClientHandle handle) { if (ClientConnected != null) { ClientConnected(this, new TCPEventArgs(handle)); } } /// <summary> /// 触发客户端衔接断开事宜 /// </summary> /// <param name="client"></param> private void RaiseClientDisconnected(Socket client) { if (ClientDisconnected != null) { ClientDisconnected(this, new TCPEventArgs("衔接断开")); } } /// <summary> /// 接收到数据事宜 /// </summary> public event EventHandler<TCPEventArgs> DataReceived; private void RaiseDataReceived(TCPClientHandle handle) { if (DataReceived != null) { DataReceived(this, new TCPEventArgs(handle)); } } /// <summary> /// 数据发送事宜 /// </summary> public event EventHandler<TCPEventArgs> CompletedSend; /// <summary> /// 触发数据发送事宜 /// </summary> /// <param name="state"></param> private void RaiseCompletedSend(TCPClientHandle handle) { if (CompletedSend != null) { CompletedSend(this, new TCPEventArgs(handle)); } } /// <summary> /// 收集毛病事宜 /// </summary> public event EventHandler<TCPEventArgs> NetError; /// <summary> /// 触发收集毛病事宜 /// </summary> /// <param name="state"></param> private void RaiseNetError(TCPClientHandle handle) { if (NetError != null) { NetError(this, new TCPEventArgs(handle)); } } /// <summary> /// 非常事宜 /// </summary> public event EventHandler<TCPEventArgs> OtherException; /// <summary> /// 触发非常事宜 /// </summary> /// <param name="state"></param> private void RaiseOtherException(TCPClientHandle handle, string descrip) { if (OtherException != null) { OtherException(this, new TCPEventArgs(descrip, handle)); } } private void RaiseOtherException(TCPClientHandle handle) { RaiseOtherException(handle, ""); } #endregion #region Close /// <summary> /// 封闭一个与客户端之间的会话 /// </summary> /// <param name="handle">须要封闭的客户端会话对象</param> public void Close(TCPClientHandle handle) { if (handle != null) { _clients.Remove(handle); handle.Dispose(); _clientCount--; //TODO 触发封闭事宜 } } /// <summary> /// 封闭一切的客户端会话,与一切的客户端衔接会断开 /// </summary> public void CloseAllClient() { foreach (TCPClientHandle handle in _clients) { Close(handle); } _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 (_listener != null) { _listener = null; } } catch (SocketException) { //TODO 非常 } } disposed = true; } } #endregion } }
客户端处置惩罚封装类
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; using System.IO; namespace NetFrame.Net.TCP.Listener.Synchronous { /// <summary> /// TcpListener完成同步TCP效劳器 的客户端衔接处置惩罚类 /// </summary> public class TCPClientHandle { private TcpClient _tcpclient; private BinaryReader rs; private BinaryWriter ws; /// <summary> /// 标识是不是与客户端相衔接 /// </summary> private bool _is_connect; public bool IsConnect { get { return _is_connect; } set { _is_connect = value; } } /// <summary> /// 数据接收缓冲区 /// </summary> private byte[] _recvBuffer; public TCPClientHandle(TcpClient client) { _tcpclient = client; rs = new BinaryReader(client.GetStream()); ws = new BinaryWriter(client.GetStream()); // NetworkStream ns = tmpTcpClient.GetStream(); // if(ns.CanRead&&ns.CanWrite) _recvBuffer=new byte[client.ReceiveBufferSize]; } /// <summary> /// 接收数据 /// </summary> public void RecevieData() { int len = 0; while (_is_connect) { try { len = rs.Read(_recvBuffer, 0, _recvBuffer.Length); } catch (Exception) { break; } if (len == 0) { //the client has disconnected from server break; } //TODO 处置惩罚收到的数据 } } /// <summary> /// 向客户端发送数据 /// </summary> /// <param name="msg"></param> public void SendData(string msg) { byte[] data = Encoding.Default.GetBytes(msg); try { ws.Write(data, 0, data.Length); ws.Flush(); } catch (Exception) { //TODO 处置惩罚非常 } } #region 事宜 //TODO 音讯发送事宜 //TODO 数据收到事宜 //TODO 非常处置惩罚事宜 #endregion #region 开释 /// <summary> /// Performs application-defined tasks associated with freeing, /// releasing, or resetting unmanaged resources. /// </summary> public void Dispose() { _is_connect = false; if (_tcpclient != null) { _tcpclient.Close(); _tcpclient = null; } GC.SuppressFinalize(this); } #endregion } }
Tcp效劳器事宜参数类
using System; using System.Collections.Generic; using System.Linq; using System.Text; namespace NetFrame.Net.TCP.Listener.Synchronous { /// <summary> /// 同步TcpListener TCP效劳器事宜类 /// </summary> public class TCPEventArgs : EventArgs { /// <summary> /// 提醒信息 /// </summary> public string _msg; /// <summary> /// 客户端状况封装类 /// </summary> public TCPClientHandle _handle; /// <summary> /// 是不是已处置惩罚过了 /// </summary> public bool IsHandled { get; set; } public TCPEventArgs(string msg) { this._msg = msg; IsHandled = false; } public TCPEventArgs(TCPClientHandle handle) { this._handle = handle; IsHandled = false; } public TCPEventArgs(string msg, TCPClientHandle handle) { this._msg = msg; this._handle = handle; IsHandled = false; } } }
以上就是C#收集编程系列文章(四)之TcpListener完成同步TCP效劳器的内容,更多相干内容请关注ki4网(www.ki4.cn)!