讲师中心 微信公众号
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 人工智能 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 人工智能 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机游戏
最近更新
当前位置：首页 > 后端开发 > C#.Net教程 >

正文

0

0

C#网络编程系列文章(三)之TcpListener实现异步TCP服务器

黄舟

黄舟

发布时间：2017-02-27 11:17:59

|

4109人浏览过

|

来源于php中文网

原创

本文介绍

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;
namespace NetFrame.Net.TCP.Listener.Asynchronous
{
    /// 
    /// TcpListener实现异步TCP服务器
    /// 
    public class AsyncTCPServer : IDisposable
    {
        #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 AsyncTCPServer(int listenPort)
            : this(IPAddress.Any, listenPort)
        {
        }

        /// 
        /// 异步TCP服务器
        /// 
        /// 监听的终结点
        public AsyncTCPServer(IPEndPoint localEP)
            : this(localEP.Address, localEP.Port)
        {
        }

        /// 
        /// 异步TCP服务器
        /// 
        /// 监听的IP地址
        /// 监听的端口
        public AsyncTCPServer(IPAddress localIPAddress, int listenPort)
        {
            Address = localIPAddress;
            Port = listenPort;
            this.Encoding = Encoding.Default;

            _clients = new List();

            _listener = new TcpListener(Address, Port);
            _listener.AllowNatTraversal(true);
        }

        #endregion

        #region Method

        /// 
        /// 启动服务器
        /// 
        public void Start()
        {
            if (!IsRunning)
            {
                IsRunning = true;
                _listener.Start();
                _listener.BeginAcceptTcpClient(
                  new AsyncCallback(HandleTcpClientAccepted), _listener);
            }
        }


        /// 
        /// 启动服务器
        /// 
        /// 
        /// 服务器所允许的挂起连接序列的最大长度
        /// 
        public void Start(int backlog)
        {
            if (!IsRunning)
            {
                IsRunning = true;
                _listener.Start(backlog);
                _listener.BeginAcceptTcpClient(
                  new AsyncCallback(HandleTcpClientAccepted), _listener);
            }
        }

        /// 
        /// 停止服务器
        /// 
        public void Stop()
        {
            if (IsRunning)
            {
                IsRunning = false;
                _listener.Stop();
                lock (_clients)
                {
                    //关闭所有客户端连接
                    CloseAllClient();
                }
            }
        }

        /// 
        /// 处理客户端连接的函数
        /// 
        /// 
        private void HandleTcpClientAccepted(IAsyncResult ar)
        {
            if (IsRunning)
            {
                //TcpListener tcpListener = (TcpListener)ar.AsyncState;

                TcpClient client = _listener.EndAcceptTcpClient(ar);
                byte[] buffer = new byte[client.ReceiveBufferSize];

                TCPClientState state
                  = new TCPClientState(client, buffer);
                lock (_clients)
                {
                    _clients.Add(state);
                    RaiseClientConnected(state);
                }

                NetworkStream stream = state.NetworkStream;
                //开始异步读取数据
                stream.BeginRead(state.Buffer, 0, state.Buffer.Length, HandleDataReceived, state);

                _listener.BeginAcceptTcpClient(
                  new AsyncCallback(HandleTcpClientAccepted), ar.AsyncState);
            }
        }
        /// 
        /// 数据接受回调函数
        /// 
        /// 
        private void HandleDataReceived(IAsyncResult ar)
        {
            if (IsRunning)
            {
                TCPClientState state = (TCPClientState)ar.AsyncState;
                NetworkStream stream = state.NetworkStream;

                int recv = 0;
                try
                {
                    recv = stream.EndRead(ar);
                }
                catch
                {
                    recv = 0;
                }

                if (recv == 0)
                {
                    // connection has been closed
                    lock (_clients)
                    {
                        _clients.Remove(state);
                        //触发客户端连接断开事件
                        RaiseClientDisconnected(state);
                        return;
                    }
                }

                // received byte and trigger event notification
                byte[] buff = new byte[recv];
                Buffer.BlockCopy(state.Buffer, 0, buff, 0, recv);
                //触发数据收到事件
                RaiseDataReceived(state);

                // continue listening for tcp datagram packets
                stream.BeginRead(state.Buffer, 0, state.Buffer.Length, HandleDataReceived, state);
            }
        }

        /// 
        /// 发送数据
        /// 
        /// 接收数据的客户端会话
        /// 数据报文
        public void Send(TCPClientState state, byte[] data)
        {
            RaisePrepareSend(state);
            Send(state.TcpClient, data);
        }

        /// 
        /// 异步发送数据至指定的客户端
        /// 
        /// 客户端
        /// 报文
        public void Send(TcpClient 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.GetStream().BeginWrite(data, 0, data.Length, SendDataEnd, client);
        }

        /// 
        /// 发送数据完成处理函数
        /// 
        /// 目标客户端Socket
        private void SendDataEnd(IAsyncResult ar)
        {
            ((TcpClient)ar.AsyncState).GetStream().EndWrite(ar);
            RaiseCompletedSend(null);
        }
        #endregion

        #region 事件

        /// 
        /// 与客户端的连接已建立事件
        /// 
        public event EventHandler ClientConnected;
        /// 
        /// 与客户端的连接已断开事件
        /// 
        public event EventHandler ClientDisconnected;


        /// 
        /// 触发客户端连接事件
        /// 
        /// 
        private void RaiseClientConnected(TCPClientState state)
        {
            if (ClientConnected != null)
            {
                ClientConnected(this, new AsyncEventArgs(state));
            }
        }
        /// 
        /// 触发客户端连接断开事件
        /// 
        /// 
        private void RaiseClientDisconnected(TCPClientState state)
        {
            if (ClientDisconnected != null)
            {
                ClientDisconnected(this, new AsyncEventArgs("连接断开"));
            }
        }

        /// 
        /// 接收到数据事件
        /// 
        public event EventHandler DataReceived;

        private void RaiseDataReceived(TCPClientState state)
        {
            if (DataReceived != null)
            {
                DataReceived(this, new AsyncEventArgs(state));
            }
        }

        /// 
        /// 发送数据前的事件
        /// 
        public event EventHandler PrepareSend;

        /// 
        /// 触发发送数据前的事件
        /// 
        /// 
        private void RaisePrepareSend(TCPClientState state)
        {
            if (PrepareSend != null)
            {
                PrepareSend(this, new AsyncEventArgs(state));
            }
        }

        /// 
        /// 数据发送完毕事件
        /// 
        public event EventHandler CompletedSend;

        /// 
        /// 触发数据发送完毕的事件
        /// 
        /// 
        private void RaiseCompletedSend(TCPClientState state)
        {
            if (CompletedSend != null)
            {
                CompletedSend(this, new AsyncEventArgs(state));
            }
        }

        /// 
        /// 网络错误事件
        /// 
        public event EventHandler NetError;
        /// 
        /// 触发网络错误事件
        /// 
        /// 
        private void RaiseNetError(TCPClientState state)
        {
            if (NetError != null)
            {
                NetError(this, new AsyncEventArgs(state));
            }
        }

        /// 
        /// 异常事件
        /// 
        public event EventHandler OtherException;
        /// 
        /// 触发异常事件
        /// 
        /// 
        private void RaiseOtherException(TCPClientState state, string descrip)
        {
            if (OtherException != null)
            {
                OtherException(this, new AsyncEventArgs(descrip, state));
            }
        }
        private void RaiseOtherException(TCPClientState state)
        {
            RaiseOtherException(state, "");
        }

        #endregion

        #region Close
        /// 
        /// 关闭一个与客户端之间的会话
        /// 
        /// 需要关闭的客户端会话对象
        public void Close(TCPClientState state)
        {
            if (state != null)
            {
                state.Close();
                _clients.Remove(state);
                _clientCount--;
                //TODO 触发关闭事件
            }
        }
        /// 
        /// 关闭所有的客户端会话,与所有的客户端连接会断开
        /// 
        public void CloseAllClient()
        {
            foreach (TCPClientState client in _clients)
            {
                Close(client);
            }
            _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
                        RaiseOtherException(null);
                    }
                }
                disposed = true;
            }
        }
        #endregion
    }
}
客户端处理封装类




using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;

namespace NetFrame.Net.TCP.Listener.Asynchronous
{
    public class TCPClientState
    {
        /// 
        /// 与客户端相关的TcpClient
        /// 
        public TcpClient TcpClient { get; private set; }

        /// 
        /// 获取缓冲区
        /// 
        public byte[] Buffer { get; private set; }

        /// 
        /// 获取网络流
        /// 
        public NetworkStream NetworkStream
        {
            get { return TcpClient.GetStream(); }
        }

        public TCPClientState(TcpClient tcpClient, byte[] buffer)
        {
            if (tcpClient == null)
                throw new ArgumentNullException("tcpClient");
            if (buffer == null)
                throw new ArgumentNullException("buffer");

            this.TcpClient = tcpClient;
            this.Buffer = buffer;
        }
        /// 
        /// 关闭
        /// 
        public void Close()
        {
            //关闭数据的接受和发送
            TcpClient.Close();
            Buffer = null;
        }
    }
}
服务器事件参数类

							

								PpcyAI
								

									PpcyAI
									
泡泡次元AI-游戏美术AI创作平台，低门槛上手，高度可控，让你的创意秒速落地

								

								下载 
							

						




using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace NetFrame.Net.TCP.Listener.Asynchronous
{
    /// 
    /// 异步TcpListener TCP服务器事件参数类 
    /// 
    public class AsyncEventArgs:EventArgs
    {
         /// 
        /// 提示信息
        /// 
        public string _msg;

        /// 
        /// 客户端状态封装类
        /// 
        public TCPClientState _state;

        /// 
        /// 是否已经处理过了
        /// 
        public bool IsHandled { get; set; }

        public AsyncEventArgs(string msg)
        {
            this._msg = msg;
            IsHandled = false;
        }
        public AsyncEventArgs(TCPClientState state)
        {
            this._state = state;
            IsHandled = false;
        }
        public AsyncEventArgs(string msg, TCPClientState state)
        {
            this._msg = msg;
            this._state = state;
            IsHandled = false;
        }
    }
}
 以上就是C#网络编程系列文章(三)之TcpListener实现异步TCP服务器的内容，更多相关内容请关注PHP中文网（www.php.cn）！


					
					

													

								
相关文章

							

							

																	
										
C# Uno Platform入门方法 C#如何使用Uno Platform构建跨所有平台的应用

									
																	
										
C# 链路追踪SkyWalking方法 C#如何集成SkyWalking APM

									
																	
										
C# Humanizer库使用方法 C#如何将日期、数字转换为易读字符串

									
																	
										
c# 在多线程代码中如何正确使用 Random 和 Guid

									
																	
										
C# XML文件解析方法 C#如何使用Linq to XML解析XML

									
															

													

								
相关标签:

								

									c#								

							

						
						
本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

						

													上一篇：C#网络编程系列文章(二)之Socket实现同步TCP服务器
													下一篇：C#网络编程系列文章(四)之TcpListener实现同步TCP服务器
												

					


					

													

								

									
 
										
作者最新文章

									

								

																	

										

											
												
HTML5 Placeholder属性的详情介绍

											
											

												
2018-05-30 09:51

											

										

								

																	

										

											
												
html中关于标签的全部属性的使用总结

											
											

												
2018-05-30 14:32

											

										

								

																	

										

											
												
php如何快速实现数组去重的实例

											
											

												
2018-05-30 15:03

											

										

								

																	

										

											
												
php中关于IMAP如何收取邮件的方法介绍

											
											

												
2018-05-31 09:38

											

										

								

																	

										

											
												
PHPMailer如何利用QQ邮箱完成邮件发送功能的实例分析

											
											

												
2018-05-31 10:28

											

										

								

																	

										

											
												
从零开始打造自己的PHP框架的视频资料

											
											

												
2018-05-31 10:45

											

										

								

																	

										

											
												
php基础知识总结（新手入门必备）

											
											

												
2018-05-30 14:26

											

										

								

																	

										

											
												
ReactJS中表单的单选多选与反选的实现方法

											
											

												
2018-05-30 09:45

											

										

								

																	

										

											
												
JavaScript中typeof的使用方法介绍

											
											

												
2018-05-30 11:42

											

										

								

																	

										

											
												
JavaScript中confirm()方法的使用介绍

											
											

												
2018-05-30 10:29

											

										

								

															

						
						

							

								
 
									
热门AI工具

								

								更多
							


							

																	

										

											
												DeepSeek
											
											

												DeepSeek
												
幻方量化公司旗下的开源大模型平台

																									

														AI 编程开发AI 聊天问答													

																							

										

									

																	

										

											
												豆包大模型
											
											

												豆包大模型
												
字节跳动自主研发的一系列大型语言模型

																									

														AI 编程开发AI大模型													

																							

										

									

																	

										

											
												通义千问
											
											

												通义千问
												
阿里巴巴推出的全能AI助手

																									

														AI 编程开发Agent智能体													

																							

										

									

																	

										

											
												腾讯元宝
											
											

												腾讯元宝
												
腾讯混元平台推出的AI助手

																									

														文档处理AI 聊天问答													

																							

										

									

																	

										

											
												文心一言
											
											

												文心一言
												
文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

																									

														AI 编程开发AI 文本写作													

																							

										

									

																	

										

											
												讯飞写作
											
											

												讯飞写作
												
基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

																									

														AI 文本写作中文写作													

																							

										

									

																	

										

											
												即梦AI
											
											

												即梦AI
												
一站式AI创作平台，免费AI图片和视频生成。

																									

														图片拼接													

																							

										

									

																	

										

											
												ChatGPT
											
											

												ChatGPT
												
最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

																									

														AI 编程开发AI 文本写作													

																							

										

									

																	

										

											
												智谱清言 - 免费全能的AI助手
											
											

												智谱清言 - 免费全能的AI助手
												
智谱清言 - 免费全能的AI助手

																									

														AI 编程开发Agent智能体													

																							

										

									

															

						


					



				


			
			

				

                    
                

				

					

						
 
							
相关专题

						

						更多
					

					

													

								C++ 设计模式与软件架构
								

									C++ 设计模式与软件架构
									
本专题深入讲解 C++ 中的常见设计模式与架构优化，包括单例模式、工厂模式、观察者模式、策略模式、命令模式等，结合实际案例展示如何在 C++ 项目中应用这些模式提升代码可维护性与扩展性。通过案例分析，帮助开发者掌握 如何运用设计模式构建高质量的软件架构，提升系统的灵活性与可扩展性。

									

										
 
											
8

										

										
 
											
2026.01.30

										

									

								

							

													

								c++ 字符串格式化
								

									c++ 字符串格式化
									
本专题整合了c++字符串格式化用法、输出技巧、实践等等内容，阅读专题下面的文章了解更多详细内容。

									

										
 
											
8

										

										
 
											
2026.01.30

										

									

								

							

													

								java 字符串格式化
								

									java 字符串格式化
									
本专题整合了java如何进行字符串格式化相关教程、使用解析、方法详解等等内容。阅读专题下面的文章了解更多详细教程。

									

										
 
											
6

										

										
 
											
2026.01.30

										

									

								

							

													

								python 字符串格式化
								

									python 字符串格式化
									
本专题整合了python字符串格式化教程、实践、方法、进阶等等相关内容，阅读专题下面的文章了解更多详细操作。

									

										
 
											
1

										

										
 
											
2026.01.30

										

									

								

							

													

								java入门学习合集
								

									java入门学习合集
									
本专题整合了java入门学习指南、初学者项目实战、入门到精通等等内容，阅读专题下面的文章了解更多详细学习方法。

									

										
 
											
20

										

										
 
											
2026.01.29

										

									

								

							

													

								java配置环境变量教程合集
								

									java配置环境变量教程合集
									
本专题整合了java配置环境变量设置、步骤、安装jdk、避免冲突等等相关内容，阅读专题下面的文章了解更多详细操作。

									

										
 
											
17

										

										
 
											
2026.01.29

										

									

								

							

													

								java成品学习网站推荐大全
								

									java成品学习网站推荐大全
									
本专题整合了java成品网站、在线成品网站源码、源码入口等等相关内容，阅读专题下面的文章了解更多详细推荐内容。

									

										
 
											
18

										

										
 
											
2026.01.29

										

									

								

							

													

								Java字符串处理使用教程合集
								

									Java字符串处理使用教程合集
									
本专题整合了Java字符串截取、处理、使用、实战等等教程内容，阅读专题下面的文章了解详细操作教程。

									

										
 
											
3

										

										
 
											
2026.01.29

										

									

								

							

													

								Java空对象相关教程合集
								

									Java空对象相关教程合集
									
本专题整合了Java空对象相关教程，阅读专题下面的文章了解更多详细内容。

									

										
 
											
6

										

										
 
											
2026.01.29

										

									

								

							

											

				


				

					

						
 
							
热门下载

						

						更多
					

					

						

							
网站特效  
 /
							
网站源码 
 /
							
网站素材 
 /
							
前端模板 

						

						
						
						
						
					

					

				


				

					
                




				

					

						
 
							
相关下载

						

						更多
					

					

											
php商城系统

											
淘源码商城PHP淘宝查信誉

											
PHP房产程序[BBWPS]

											
PHP简约自动发卡平台个人版

											
ERMEB域名PHP离线网络授权系统

											
Difeye-敏捷的轻量级PHP框架

											
大泉州汽车网PHP整站程序

										


				


				

					

						
 
							
精品课程

						

						更多
					

					

						

							
相关推荐  
 /
							
热门推荐 
 /
							
最新课程 

						

						

													

								
									C# 教程
								
								

									C# 教程

									

										
共94课时 | 8万人学习

									

								

							

													

								
									C 教程
								
								

									C 教程

									

										
共75课时 | 4.3万人学习

									

								

							

													

								
									C++教程
								
								

									C++教程

									

										
共115课时 | 14.8万人学习

									

								

							

												


						

						
						

					

				


				

					

						
 
							
最新文章

						

						更多
					

					

													
c# await foreach 是什么

													
C# 动态PGO优化方法 C# Dynamic PGO如何提升应用性能

													
C# WPF Community Toolkit使用方法 C# MVVM Toolkit如何简化MVVM开发

													
C# ML.NET入门方法 C#如何进行机器学习情感分析

													
C# 类型转换方法 C#如何进行显式和隐式转换

													
C# Uno Platform入门方法 C#如何使用Uno Platform构建跨所有平台的应用

													
C# 链路追踪SkyWalking方法 C#如何集成SkyWalking APM

													
C# Humanizer库使用方法 C#如何将日期、数字转换为易读字符串

													
c# 在多线程代码中如何正确使用 Random 和 Guid

													
C# XML文件解析方法 C#如何使用Linq to XML解析XML

											


				







			




		

	
	
	

    

        

            

                

                    

                        关于我们
                        免责申明
                        举报中心
                        意见反馈
                        讲师合作
                        广告合作
                        最新更新
                                                

                    

                    
php中文网：公益在线php培训，帮助PHP学习者快速成长！

                    

                      
                        关注服务号
                        
                      
                        
                        技术交流群
                        
                      
                        

                    

                

                
            

            

                

                    
                    

                        
PHP中文网订阅号

                        
每天精选资源文章推送

                    

                

            

        

    

    

        
Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

    













	
	
		
	
	


    
  • 
        
    
            
    
                
                    
                    
    PHP学习
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    技术支持
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    返回顶部
    
                    
            
    
        
    
    
    •