重庆网站建设圣矢/广告公司网上接单平台

Client端

static void Main(string[] args)
{XSocketService XSocketService = new XSocketService();XSocketService.Init();while (true){Console.Write("请输入消息：");var msg = Console.ReadLine();XSocketService.SendMessageToListener(msg);}//XSocketService.Dispose();
}

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;public class XSocketService : IDisposable
{public static Socket ClientSocket;public void Init(){ConnectToListener();Thread tQureyStatus = new Thread(ReceiveMessageFromListener);tQureyStatus.IsBackground = true;tQureyStatus.Start();}public void Dispose() { ClientSocket.Close(); }public void SendMessageToListener(string message){byte[] buffer = Encoding.UTF8.GetBytes(message);int length = ClientSocket.Send(buffer);Console.WriteLine("SendMessageToListener length: " + length + ", szContent: " + message);}private void ConnectToListener(){ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPEndPoint iPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888);   // 创建IP地址和端口号ClientSocket.Connect(iPEndPoint);  // 绑定IP地址和端口号Console.WriteLine("Connect ToListener Succeed!");}private void ReceiveMessageFromListener(){while (true){int length = ClientSocket.Available;byte[] receiveInfo = new byte[length];length = ClientSocket.Receive(receiveInfo);if (length <= 0){Console.WriteLine("ReceiveMessageFromListener receive info length <= 0,length: " + length);continue;}string message = Encoding.UTF8.GetString(receiveInfo, 0, length);Console.WriteLine("ReceiveMessageFromClient length: " + length + ", message: " + message);}}
}

Listener端

static void Main(string[] args)
{XSocketService XSocketService = new XSocketService();XSocketService.Init();while (true){Console.Write("请输入消息：");var msg = Console.ReadLine();XSocketService.SendMessageToClient(msg);}//XSocketService.Dispose();
}

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;public class XSocketService : IDisposable
{public static Socket ClientSocket;public static Socket ListenerSocket;public void Init(){WaitConnect();Thread tQureyStatus = new Thread(ReceiveMessageFromClient);tQureyStatus.IsBackground = true;tQureyStatus.Start();}public void Dispose() { ClientSocket.Close();ListenerSocket.Close();}public void SendMessageToClient(string message){byte[] buffer = Encoding.UTF8.GetBytes(message);int length = ListenerSocket.Send(buffer);Console.WriteLine("SendMessageToListener length: " + length + ", message: " + message);}private void WaitConnect(){ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  // 创建Socket对象IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888);   // 创建IP地址和端口号ClientSocket.Bind(endPoint);  // 绑定IP地址和端口号ClientSocket.Listen(10);  // 开始监听Console.WriteLine("Listener wait client connect...");ListenerSocket = ClientSocket.Accept();  // 接受客户端连接Console.WriteLine("Listener client connected.");}private void ReceiveMessageFromClient(){while (true){int length = ListenerSocket.Available;byte[] receiveInfo = new byte[length];length = ListenerSocket.Receive(receiveInfo);if (length <= 0){Console.WriteLine("ReceiveMessageFromClient receive info length <= 0,length: " + length);continue;} string message = Encoding.UTF8.GetString(receiveInfo, 0, length);Console.WriteLine("ReceiveMessageFromClient length: " + length + ", message: " + message);}}}

• C#中的Socket类是用于网络编程的重要类之一，其Available属性是指当前Socket缓冲区中可用的字节数。
  该属性可以用于检查接收缓冲区中是否有可用的数据，以便进行相应的处理。

• 当Socket接收到数据时，它会存储在缓冲区中，而Available属性可以让我们知道缓冲区中有多少数据可供读取。
  通过检查Available属性，我们可以确定是否需要读取缓冲区中的数据，以及可以读取多少数据。