C# 使用Socket通信，新建WinForm服务端、客户端程序

一、新建WinForm Socket服务端程序

注：rtbReceviceMsg为RichTextBox控件

服务端程序、界面

在这里插入图片描述

服务端代码

public partial class Form1 : Form
{public Form1(){InitializeComponent();}public virtual void TriggerOnUpdateUI(string message){if (this.InvokeRequired){this.Invoke(new Action<string>(TriggerOnUpdateUI), message);}else{rtbReceviceMsg.Text += message + "\n";}}private void btnStartServer_Click(object sender, EventArgs e){TcpServer.StartListening(9999, this);btnStartServer.Enabled = false;}private void btnStopServer_Click(object sender, EventArgs e){TcpServer.StopListening();btnStartServer.Enabled = true;}
}public class TcpServer{public static Form1 _mainForm;private static TcpListener _listener;private static bool _isRunning;public static void StartListening(int port, Form1 form){_mainForm = form;_listener = new TcpListener(IPAddress.Loopback, port);_listener.Start();_isRunning=true;Console.WriteLine("Server listening on port " + port);Task.Run(() => ListenForClients());}public static void ListenForClients(){while (_isRunning){try{TcpClient client = _listener.AcceptTcpClient();Console.WriteLine("Client connected");HandleClient(client);}catch (SocketException){if (!_isRunning){break;}}}}private static void HandleClient(TcpClient client){NetworkStream stream = client.GetStream();byte[] buffer = new byte[1024];int bytesRead;while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) != 0){string message = Encoding.ASCII.GetString(buffer, 0, bytesRead);Console.WriteLine("received" + message);stream.Write(buffer, 0, bytesRead);_mainForm.BeginInvoke(new Action(() => _mainForm.TriggerOnUpdateUI(message)));}}public static void StopListening(){_isRunning = false;_listener?.Stop();}}

二、新建WinForm Socket客户端程序

客户端程序、界面

在这里插入图片描述

客户端代码

public partial class Form1 : Form
{public Form1(){InitializeComponent();}public static void ConnectToServer(string hostname, int port){try{using (TcpClient tcpClient = new TcpClient(hostname, port)){Console.WriteLine("Connected to server");NetworkStream stream = tcpClient.GetStream();byte[] data = Encoding.ASCII.GetBytes($"Hellow,Server！{DateTime.Now.ToString()}");stream.Write(data, 0, data.Length);Console.WriteLine("Sent：Hellow,Server！");byte[] buffer = new byte[1024];int bytesRead = stream.Read(buffer, 0, buffer.Length);string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);Console.WriteLine($"Response: {response}");}}catch (SocketException ex){MessageBox.Show($"连接异常：{ex.Message}");}}private void btnStartServer_Click(object sender, EventArgs e){ConnectToServer("127.0.0.1", 9999);}
}