C#基于Socket套接字的网络通信封装
更新时间：2021年11月25日 15:03:01 作者：uiuan00
这篇文章主要为大家详细介绍了C#基于Socket套接字的网络通信封装本文实例为大家分享了Java实现图片旋转的具体代码，供大家参考，具体内容如下
本文为大家分享了C#基于Socket套接字的网络通信封装代码，供大家参考，具体内容如下
摘要
之所以要进行Socket套接字通信库封装，主要是直接使用套接字进行网络通信编程相对复杂，特别对于初学者而言。实际上微软从.net 2.0开始已经提供了TCP、UDP通信高级封装类如下：
TcpListener
TcpClient
UdpClient
微软从.net 4.0开始提供基于Task任务的异步通信接口。而直接使用socket封装库，很多socket本身的细节没办法自行控制，本文目就是提供一种socket的封装供参考。文中展示部分封装了TCP通信库,UDP封装也可触类旁通：
CusTcpListener
CusTcpClient
TCP服务端
TCP服务端封装了服务端本地绑定、监听、接受客户端连接，并提供了网络数据流的接口。完整代码：
public class CusTcpListener
{
private IPEndPoint mServerSocketEndPoint;
private Socket mServerSocket;
private bool isActive;
public Socket Server
{
get { return this.mServerSocket; }
}
protected bool Active
{
get { return this.isActive; }
}
public EndPoint LocalEndpoint
{
get
{
if (!this.isActive)
{
return this.mServerSocketEndPoint;
}
return this.mServerSocket.LocalEndPoint;
}
}
public NetworkStream DataStream
{
get
{
NetworkStream networkStream = null;
if (this.Server.Connected)
{
networkStream = new NetworkStream(this.Server, true);
}
return networkStream;
}
}
public CusTcpListener(IPEndPoint localEP)
{
this.mServerSocketEndPoint = localEP;
this.mServerSocket = new Socket(this.mServerSocketEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public CusTcpListener(string localaddr, int port)
{
if (localaddr == null)
{
throw new ArgumentNullException("localaddr");
}
this.mServerSocketEndPoint = new IPEndPoint(IPAddress.Parse(localaddr), port);
this.mServerSocket = new Socket(this.mServerSocketEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public CusTcpListener(int port)
{
this.mServerSocketEndPoint = new IPEndPoint(IPAddress.Any, port);
this.mServerSocket = new Socket(this.mServerSocketEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public void Start()
{
this.Start(int.MaxValue);
}
/// <summary>
/// 开始服务器监听
/// </summary>
/// <param name="backlog">同时等待连接的最大个数（半连接队列个数限制）</param>
public void Start(int backlog)
{
if (backlog > int.MaxValue || backlog < 0)
{
throw new ArgumentOutOfRangeException("backlog");
}
if (this.mServerSocket == null)
{
throw new NullReferenceException("套接字为空");
}
this.mServerSocket.Bind(this.mServerSocketEndPoint);
this.mServerSocket.Listen(backlog);
this.isActive = true;
}
public void Stop()
{
if (this.mServerSocket != null)
{
this.mServerSocket.Close();
this.mServerSocket = null;
}
this.isActive = false;
this.mServerSocket = new Socket(this.mServerSocketEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
}
public Socket AcceptSocket()
{
Socket socket = this.mServerSocket.Accept();
return socket;
}
public CusTcpClient AcceptTcpClient()
{
CusTcpClient tcpClient = new CusTcpClient(this.mServerSocket.Accept());
return tcpClient;
}
}
TCP客户端
TCP客户端封装了客户端本地绑定、连接服务器，并提供了网络数据流的接口。完整代码：
public class CusTcpClient : IDisposable
{
public Socket Client { get; set; }
protected bool Active { get; set; }
public IPEndPoint ClientSocketEndPoint { get; set; }
public bool IsConnected { get { return this.Client.Connected; } }
public NetworkStream DataStream
{
get
{
NetworkStream networkStream = null;
if (this.Client.Connected)
{
networkStream = new NetworkStream(this.Client, true);
}
return networkStream;
}
}
public CusTcpClient(IPEndPoint localEP)
{
if (localEP == null)
{
throw new ArgumentNullException("localEP");
}
this.Client = new Socket(localEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
this.Active = false;
this.Client.Bind(localEP);
this.ClientSocketEndPoint = localEP;
}
public CusTcpClient(string localaddr, int port)
{
if (localaddr == null)
{
throw new ArgumentNullException("localaddr");
}
IPEndPoint localEP = new IPEndPoint(IPAddress.Parse(localaddr), port);
this.Client = new Socket(localEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
this.Active = false;
this.Client.Bind(localEP);
this.ClientSocketEndPoint = localEP;
}
internal CusTcpClient(Socket acceptedSocket)
{
this.Client = acceptedSocket;
this.Active = true;
this.ClientSocketEndPoint = (IPEndPoint)this.Client.LocalEndPoint;
}
public void Connect(string address, int port)
{
if (address == null)
{
throw new ArgumentNullException("address");
}
IPEndPoint remoteEP = new IPEndPoint(IPAddress.Parse(address), port);
this.Connect(remoteEP);
}
public void Connect(IPEndPoint remoteEP)
{
if (remoteEP == null)
{
throw new ArgumentNullException("remoteEP");
}
this.Client.Connect(remoteEP);
this.Active = true;
}
public void Close()
{
this.Dispose(true);
}
protected virtual void Dispose(bool disposing)
{
if (disposing)
{
IDisposable dataStream = this.DataStream;
if (dataStream != null)
{
dataStream.Dispose();
}
else
{
Socket client = this.Client;
if (client != null)
{
client.Close();
this.Client = null;
}
}
GC.SuppressFinalize(this);
}
}
public void Dispose()
{
this.Dispose(true);
}
}
通信实验
控制台程序试验，服务端程序：
class Program
{
static void Main(string[] args)
{
Thread listenerThread = new Thread(ListenerClientConnection);
listenerThread.IsBackground = true;
listenerThread.Start();
Console.ReadKey();
}
private static void ListenerClientConnection()
{
CusTcpListener tcpListener = new CusTcpListener("127.0.0.1", 5100);
tcpListener.Start();
Console.WriteLine("等待客户端连接……");
while (true)
{
CusTcpClient tcpClient = tcpListener.AcceptTcpClient();
Console.WriteLine("客户端接入，ip={0} port={1}",
tcpClient.ClientSocketEndPoint.Address, tcpClient.ClientSocketEndPoint.Port);
Thread thread = new Thread(DataHandleProcess);
thread.IsBackground = true;
thread.Start(tcpClient);
}
}
private static void DataHandleProcess(object obj)
{
CusTcpClient tcpClient = (CusTcpClient)obj;
StreamReader streamReader = new StreamReader(tcpClient.DataStream, Encoding.Default);
Console.WriteLine("等待客户端输入：");
while (true)
{
try
{
string receStr = streamReader.ReadLine();
Console.WriteLine(receStr);
}
catch (Exception)
{
Console.WriteLine("断开连接");
break;
}
Thread.Sleep(5);
}
}
}
客户端程序：
class Program
{
static void Main(string[] args)
{
Thread listenerThread = new Thread(UserProcess);
listenerThread.IsBackground = true;
listenerThread.Start();
Console.ReadKey();
}
private static void UserProcess()
{
Console.WriteLine("连接服务器");
CusTcpClient tcpClient = new CusTcpClient("127.0.0.1", 5080);
tcpClient.Connect("127.0.0.1", 5100);
Console.WriteLine("开始和服务器通信");
StreamWriter sw = new StreamWriter(tcpClient.DataStream, Encoding.Default);
sw.AutoFlush = true;
while (true)
{
for (int i = 0; i < 10; i++)
{
string str = string.Format("第{0}次,内容：{1}", i, "测试通信");
Console.WriteLine("发送数据：{0}", str);
sw.WriteLine(str);
}
break;
}
}
}
通信成功：
通过本次封装演示可实现基于Socket的通信库封装，目的就是使用Socket通信库让应用开发人员在进行网络通讯编程时无需关心底层通讯机制，而只关心应用层的开发，让开发变得更简洁。当然UDP封装类似，可自行设计。当然本文只是一种示例，实际使用可使用.net自带封装库或自定义封装。
补充：目前有很多优秀的开源Socket框架，比如SuperSocket、FastSocket等。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
C#实现的最短路径分析，需要的朋友可以参考一下2013-03-03
这篇文章主要介绍了C#中获取各种文件名的实现方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-07-07
C#中的GetField是一个反射方法,用于获取指定类型的字段信息,它可以通过字段名称来获取字段对象,并且可以在运行时动态地访问和操作这些字段,本文给大家介绍了C# GetField方法的应用,需要的朋友可以参考下2024-04-04
为什么 Windbg 附加到 C# 程序后，程序就处于中断状态了？它到底是如何实现的？其实简而言之就是线程的远程注入，这一篇就展开说一下2022-09-09
TortoiseSVN 是 Subversion 版本控制系统的一个免费开源客户端，可以超越时间的管理文件和目录。本文给大家介绍TortoiseSVN使用教程，对tortoisesvn使用相关知识感兴趣的朋友一起学习吧2015-12-12
访问一个类的私有成员不是什么好做法，大家也都知道私有成员在外部是不能被访问的，这篇文章主要给大家介绍了关于C#访问及调用类中私有成员与方法的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考下2018-06-06
这篇文章主要介绍了c#语言程序构建基块，关于c#程序构建基块我们要从成员开始，class 的成员要么是静态成员，要么是实例成员。 静态成员属于类，而实例成员则属于对象，具体内容需要的小伙伴可以参考下面文章的详细内容2021-12-12
这篇文章主要给大家介绍了关于C#中使用闭包与意想不到的坑，文中通过示例代码介绍的非常详细，对大家学习或者使用C#具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2020-06-06
ZXing是一个开源的,支持多种格式的条形码图像处理库，本文主要介绍了C#使用Zxing.dll组件解析二维码的实现，具有一定的参考价值，感兴趣的可以了解一下2023-09-09
在做“亦歌桌面版”的时候，发现当打开歌词状态下，用最小化隐藏窗体到托盘的话（如下code #1），在调出发现歌词缩小了（虽然显现的窗体大小跟刚才一样），从这点看调用该方法其实窗体大小是改变了的（这个过程只是不可视而已）。2009-02-02
最新评论