C#-Socket-Thread
Die Originalversion sieht so aus: Klicken Sie hier, um den Link zu öffnen. Aber es wurde nie richtig eingestellt, also habe ich meinen Kollegen Xiang Ge konsultiert und es endlich richtig gemacht!
Client-Code:
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Net.Sockets; using System.Threading; using System.Net; using System.Diagnostics; namespace SocketClient { public partial class Client : Form { Socket vsServerSocket; Thread vsClientThread; string strIP = "127.0.0.1"; public delegate void PassString(string strMsg); int nPort = 9001; public Client() { InitializeComponent(); } public void SetSendData(string strMsg) { if (tBoxClientSend.InvokeRequired == true) { PassString d = new PassString(SetSendData); this.Invoke(d, new object[] { strMsg }); } else { tBoxClientSend.Text = strMsg; } } public void SetRecvData(string strMsg) { if (tBoxClientReceive.InvokeRequired == true) { PassString d = new PassString(SetRecvData); this.Invoke(d, new object[] { strMsg }); } else { tBoxClientReceive.Text = strMsg; } } private void ClientHandle() { string strRecv = string.Empty; //IPEndPoint其实就是一个IP地址和端口的绑定,可以代表一个服务,用来Socket通讯。 //IPAddress类中有一个 Parse()方法,可以把点分的十进制IP表示转化成IPAddress类 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort); //创建套接字实例 //这里创建的时候用ProtocolType.Tcp,表示建立一个面向连接(TCP)的Socket vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try { //将所创建的套接字与IPEndPoint绑定 vsServerSocket.Bind(ipep); } catch (SocketException ex) { MessageBox.Show("Connect Error: " + ex.Message); return; } Byte[] buffer = new Byte[1024]; //设置套接字为收听模式 vsServerSocket.Listen(10); //循环监听 while (true) { //接收服务器信息 int bufLen = 0; try { Socket vsClientSocket = vsServerSocket.Accept(); bufLen=vsClientSocket.Receive(buffer); vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None); } catch (Exception ex) { MessageBox.Show("Receive Error:" + ex.Message); } strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen); SetRecvData(strRecv); //vsClientSocket.Shutdown(SocketShutdown.Both); //vsClientSocket.Close(); } } //发送数据 private void btnSend_Click(object sender, EventArgs e) { byte[] data = new byte[1024]; string ss = tBoxClientSend.Text; Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9002); centerClient.Connect(GsServer); centerClient.Send(Encoding.ASCII.GetBytes(ss)); centerClient.Close(); } private void Client_Load(object sender, EventArgs e) { //连接服务器 //通过ThreadStart委托告诉子线程讲执行什么方法 vsClientThread = new Thread(new ThreadStart(ClientHandle)); vsClientThread.Start(); } //窗体关闭时杀死客户端进程 private void Client_FormClosing(object sender, FormClosingEventArgs e) { KillProcess(); } //杀死客户端进程 private void KillProcess() { Process[] processes = Process.GetProcessesByName("SocketClient"); foreach (Process process in processes) { process.Kill(); break; } } } }
Server-Code:
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Threading; using System.Net.Sockets; using System.Net; using System.Diagnostics; namespace SocketServer { public partial class Server : Form { Thread vsServerThread; Socket vsServerSocket; string strIP = "127.0.0.1"; public delegate void PassString(string strMsg); int nPort = 9002; public Server() { InitializeComponent(); } private void SeverSendData(string strMsg) { //Control.InvokeRequired 属性,命名空间: System.Windows.Forms //获取一个值,该值指示调用方在对控件进行方法调用时是否必须调用 Invoke 方法,因为调用方位于创建控件所在的线程以外的线程中。 if (tBoxServerSend.InvokeRequired == true) { //Control.Invoke 方法 (Delegate) //在拥有此控件的基础窗口句柄的线程上执行指定的委托。 PassString d = new PassString(SeverSendData); this.Invoke(d, new object[] { strMsg }); } else { tBoxServerSend.Text = strMsg; } } private void SeverRecvData(string strMsg) { if (tBoxServerReceive.InvokeRequired == true) { PassString d = new PassString(SeverRecvData); this.Invoke(d, new object[] { strMsg }); } else { tBoxServerReceive.Text = strMsg; } } private void ServerStart() { string strRecv = string.Empty; //创建IPEndPoint实例 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort); //创建一个套接字 vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //将所创建的套接字与IPEndPoint绑定 try { vsServerSocket.Bind(ipep); } catch (Exception ee) { MessageBox.Show(ee.ToString()); return; } //设置套接字为收听模式 vsServerSocket.Listen(10); int bufLen = 0; //循环监听 while (true) { //在套接字上接收接入的连接 Socket vsClientSocket = vsServerSocket.Accept(); try { Byte[] buffer = new Byte[1024]; //在套接字上接收客户端发送的信息 bufLen = vsClientSocket.Receive(buffer); vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None); if (bufLen == 0) continue; //将指定字节数组中的一个字节序列解码为一个字符串。 strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen); SeverRecvData(strRecv.ToString()); } catch (Exception ex) { MessageBox.Show("Listening Error: " + ex.Message); vsClientSocket.Close(); vsServerSocket.Close(); } } } private void btnSend_Click(object sender, EventArgs e) { byte[] data = new byte[1024]; string ss = tBoxServerSend.Text; Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9001); centerClient.Connect(GsServer); centerClient.Send(Encoding.ASCII.GetBytes(ss)); centerClient.Send(Encoding.ASCII.GetBytes(ss)); //Thread.Sleep(100); //centerClient.Close(); } private void Server_Load(object sender, EventArgs e) { vsServerThread = new Thread(new ThreadStart(ServerStart)); vsServerThread.Start(); } //窗体关闭时杀死客户端进程 private void Server_FormClosing(object sender, FormClosingEventArgs e) { KillProcess(); } //杀死客户端进程 private void KillProcess() { Process[] processes = Process.GetProcessesByName("Server"); foreach (Process process in processes) { process.Kill(); break; } } } }
Der Effekt ist wie folgt:
Der Client kann Nachrichten an den Server senden, und der Server kann auch Nachrichten senden auf Kundenseite.
Nachteile:
Jetzt kann der Server nur noch eine Verbindung zu einem Client herstellen
Das Obige ist der Inhalt des C#-Socket-Threads. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website (www.php.cn)!

Heiße KI -Werkzeuge

Undresser.AI Undress
KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover
Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool
Ausziehbilder kostenlos

Clothoff.io
KI-Kleiderentferner

Video Face Swap
Tauschen Sie Gesichter in jedem Video mühelos mit unserem völlig kostenlosen KI-Gesichtstausch-Tool aus!

Heißer Artikel

Heiße Werkzeuge

Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6
Visuelle Webentwicklungstools

SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen



Leitfaden zu Active Directory mit C#. Hier besprechen wir die Einführung und die Funktionsweise von Active Directory in C# sowie die Syntax und das Beispiel.

Leitfaden zur C#-Serialisierung. Hier besprechen wir die Einführung, die Schritte des C#-Serialisierungsobjekts, die Funktionsweise bzw. das Beispiel.

Leitfaden zum Zufallszahlengenerator in C#. Hier besprechen wir die Funktionsweise des Zufallszahlengenerators, das Konzept von Pseudozufallszahlen und sicheren Zahlen.

Leitfaden zur C#-Datenrasteransicht. Hier diskutieren wir die Beispiele, wie eine Datenrasteransicht aus der SQL-Datenbank oder einer Excel-Datei geladen und exportiert werden kann.

Leitfaden zu Mustern in C#. Hier besprechen wir die Einführung und die drei wichtigsten Arten von Mustern in C# zusammen mit ihren Beispielen und der Code-Implementierung.

Leitfaden zu Primzahlen in C#. Hier besprechen wir die Einführung und Beispiele von Primzahlen in C# sowie die Codeimplementierung.

Leitfaden zur Fakultät in C#. Hier diskutieren wir die Einführung in die Fakultät in C# zusammen mit verschiedenen Beispielen und Code-Implementierungen.

Der Unterschied zwischen Multithreading und Asynchron besteht darin, dass Multithreading gleichzeitig mehrere Threads ausführt, während asynchron Operationen ausführt, ohne den aktuellen Thread zu blockieren. Multithreading wird für rechenintensive Aufgaben verwendet, während asynchron für die Benutzerinteraktion verwendet wird. Der Vorteil des Multi-Threading besteht darin, die Rechenleistung zu verbessern, während der Vorteil von Asynchron nicht darin besteht, UI-Threads zu blockieren. Die Auswahl von Multithreading oder Asynchron ist von der Art der Aufgabe abhängt: Berechnungsintensive Aufgaben verwenden Multithreading, Aufgaben, die mit externen Ressourcen interagieren und die UI-Reaktionsfähigkeit asynchron verwenden müssen.
