Shulou(Shulou.com)06/02 Report--

Editor to share with you how C# to achieve Socket socket-based network communication encapsulation, I believe that most people do not know much about it, so share this article for your reference, I hope you can learn a lot after reading this article, let's learn about it!

Abstract

The reason for the encapsulation of Socket socket communication library is that it is relatively complex to use sockets directly for network communication programming, especially for beginners. In fact, Microsoft has provided advanced wrapper classes for TCP and UDP communications since .net 2.0 as follows:

TcpListener

TcpClient

UdpClient

Microsoft has been providing asynchronous communication interfaces based on Task tasks since. Net 4.0. The direct use of socket packaging library, many of the details of socket itself can not be controlled by themselves, this article is to provide a socket encapsulation for reference. The TCP communication library is partially encapsulated in this article, and UDP encapsulation can also be used by analogy:

CusTcpListener

CusTcpClient

TCP server

The TCP server encapsulates the local binding of the server, listens, accepts client connections, and provides an interface for network data flow. Complete code:

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) } / start server listening / the maximum number of connections waiting at the same time (semi-connected queue limit) public void Start (int backlog) {if (backlog > int.MaxValue | | backlog < 0) {throw new ArgumentOutOfRangeException ("backlog") } if (this.mServerSocket = = null) {throw new NullReferenceException ("socket is empty");} 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 client

The TCP client encapsulates the client's local binding, connects to the server, and provides an interface for network data flow. Complete code:

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);}} Communication experiment

Console program test, server program:

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 ("waiting for client connection...") ; while (true) {CusTcpClient tcpClient = tcpListener.AcceptTcpClient (); Console.WriteLine ("client access, 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 ("waiting for client input:") While (true) {try {string receStr = streamReader.ReadLine (); Console.WriteLine (receStr);} catch (Exception) {Console.WriteLine ("disconnect") Break;} Thread.Sleep (5);}

Client program:

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 ("connect to server") CusTcpClient tcpClient = new CusTcpClient ("127.0.0.1", 5080); tcpClient.Connect ("127.0.0.1", 5100); Console.WriteLine ("start communicating with the server"); StreamWriter sw = new StreamWriter (tcpClient.DataStream, Encoding.Default); sw.AutoFlush = true While (true) {for (int I = 0; I < 10; iTunes +) {string str = string.Format ("{0} th, content: {1}", I, "test communication"); Console.WriteLine ("send data: {0}", str) Sw.WriteLine (str);} break;}

Communication success:

Through this encapsulation demonstration, the encapsulation of communication library based on Socket can be realized. The purpose is to use Socket communication library so that application developers do not need to care about the underlying communication mechanism when programming network communication, but only care about the development of the application layer, which makes the development more concise. Of course, the UDP package is similar and can be designed by yourself. Of course, this article is just an example, and you can actually use. Net built-in wrapper libraries or custom wrappers.

These are all the contents of the article "how to implement network communication encapsulation based on Socket sockets in C #". Thank you for reading! I believe we all have a certain understanding, hope to share the content to help you, if you want to learn more knowledge, welcome to follow the industry information channel!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.