本文介绍
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
{
///
/// TcpListener实现同步TCP服务器
///
public class TCPServer
{
#region Fields
///
/// 服务器程序允许的最大客户端连接数
///
private int _maxClient;
///
/// 当前的连接的客户端数
///
private int _clientCount;
///
/// 服务器使用的异步TcpListener
///
private TcpListener _listener;
///
/// 客户端会话列表
///
private List _clients;
private bool disposed = false;
#endregion
#region Properties
///
/// 服务器是否正在运行
///
public bool IsRunning { get; private set; }
///
/// 监听的IP地址
///
public IPAddress Address { get; private set; }
///
/// 监听的端口
///
public int Port { get; private set; }
///
/// 通信使用的编码
///
public Encoding Encoding { get; set; }
#endregion
#region 构造器
///
/// 同步TCP服务器
///
/// 监听的端口
public TCPServer(int listenPort)
: this(IPAddress.Any, listenPort, 1024)
{
}
///
/// 同步TCP服务器
///
/// 监听的终结点
public TCPServer(IPEndPoint localEP)
: this(localEP.Address, localEP.Port, 1024)
{
}
///
/// 同步TCP服务器
///
/// 监听的IP地址
/// 监听的端口
/// 最大客户端数量
public TCPServer(IPAddress localIPAddress, int listenPort, int maxClient)
{
this.Address = localIPAddress;
this.Port = listenPort;
this.Encoding = Encoding.Default;
_maxClient = maxClient;
_clients = new List();
_listener = new TcpListener(new IPEndPoint(this.Address, this.Port));
}
#endregion
#region Method
///
/// 启动服务器
///
public void Start()
{
if (!IsRunning)
{
IsRunning = true;
_listener.Start();
Thread thread = new Thread(Accept);
thread.Start();
}
}
///
/// 开始进行监听
///
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();
}
}
}
///
/// 停止服务器
///
public void Stop()
{
if (IsRunning)
{
IsRunning = false;
_listener.Stop();
//TODO 关闭对所有客户端的连接
}
}
///
/// 发送函数
///
public void Send(string msg, TcpClient client)
{
//TODO
}
#endregion
#region 事件
///
/// 与客户端的连接已建立事件
///
public event EventHandler ClientConnected;
///
/// 与客户端的连接已断开事件
///
public event EventHandler ClientDisconnected;
///
/// 触发客户端连接事件
///
///
private void RaiseClientConnected(TCPClientHandle handle)
{
if (ClientConnected != null)
{
ClientConnected(this, new TCPEventArgs(handle));
}
}
///
/// 触发客户端连接断开事件
///
///
private void RaiseClientDisconnected(Socket client)
{
if (ClientDisconnected != null)
{
ClientDisconnected(this, new TCPEventArgs("连接断开"));
}
}
///
/// 接收到数据事件
///
public event EventHandler DataReceived;
private void RaiseDataReceived(TCPClientHandle handle)
{
if (DataReceived != null)
{
DataReceived(this, new TCPEventArgs(handle));
}
}
///
/// 数据发送事件
///
public event EventHandler CompletedSend;
///
/// 触发数据发送事件
///
///
private void RaiseCompletedSend(TCPClientHandle handle)
{
if (CompletedSend != null)
{
CompletedSend(this, new TCPEventArgs(handle));
}
}
///
/// 网络错误事件
///
public event EventHandler NetError;
///
/// 触发网络错误事件
///
///
private void RaiseNetError(TCPClientHandle handle)
{
if (NetError != null)
{
NetError(this, new TCPEventArgs(handle));
}
}
///
/// 异常事件
///
public event EventHandler OtherException;
///
/// 触发异常事件
///
///
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
///
/// 关闭一个与客户端之间的会话
///
/// 需要关闭的客户端会话对象
public void Close(TCPClientHandle handle)
{
if (handle != null)
{
_clients.Remove(handle);
handle.Dispose();
_clientCount--;
//TODO 触发关闭事件
}
}
///
/// 关闭所有的客户端会话,与所有的客户端连接会断开
///
public void CloseAllClient()
{
foreach (TCPClientHandle handle in _clients)
{
Close(handle);
}
_clientCount = 0;
_clients.Clear();
}
#endregion
#region 释放
///
/// Performs application-defined tasks associated with freeing,
/// releasing, or resetting unmanaged resources.
///
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
///
/// Releases unmanaged and - optionally - managed resources
///
/// true to release
/// both managed and unmanaged resources; false
/// to release only unmanaged resources.
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
{
///
/// TcpListener实现同步TCP服务器 的客户端连接处理类
///
public class TCPClientHandle
{
private TcpClient _tcpclient;
private BinaryReader rs;
private BinaryWriter ws;
///
/// 标识是否与客户端相连接
///
private bool _is_connect;
public bool IsConnect
{
get { return _is_connect; }
set { _is_connect = value; }
}
///
/// 数据接受缓冲区
///
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];
}
///
/// 接受数据
///
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 处理收到的数据
}
}
///
/// 向客户端发送数据
///
///
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 释放
///
/// Performs application-defined tasks associated with freeing,
/// releasing, or resetting unmanaged resources.
///
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
{
///
/// 同步TcpListener TCP服务器事件类
///
public class TCPEventArgs : EventArgs
{
///
/// 提示信息
///
public string _msg;
///
/// 客户端状态封装类
///
public TCPClientHandle _handle;
///
/// 是否已经处理过了
///
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服务器的内容，更多相关内容请关注PHP中文网（www.php.cn）！
