一. 服务端代码 :
Java.net importieren.*; // für Socket, ServerSocket und Inetaddress import Java.io.*; // für IOException und Input/OutputStream Public Class TCpechoServer {private statische endgültige int bufsize = 32; // Größe des Empfangs Buffer Public static void main (String [] args) löst ioException {int Servport = 5500 aus; // Erstellen Sie einen Server -Socket, um Client -Verbindungsanforderungen ServerSocket Servsock = New ServerSocket (Servport) zu akzeptieren. int recvmsgSize; // Größe des empfangenen Nachrichten Byte [] recemeBuf = new Byte [bufsize]; // Puffer empfangen, während (true) {// für immer rennen, Annahme und Wartung von Verbindungen Socket clntsock = servsock.accept (); // client Connection SocketAddress ClientAddress = clntsock.getRemotesocketAddress (); System.out.println ("Client bei" + clientAddress); InputStream in = clntsock.getInputStream (); OutputStream out = clntsock.getOutputStream (); // Empfangen Sie, bis der Client die Verbindung schließt, angegeben durch -1 return while ((recvmsgSize = in.read (recemeBuf))! } clntsock.close (); // die Steckdose schließen. Wir sind mit diesem Kunden fertig! } / * Nicht erreicht * /}}二. 客户端代码 :
Java.net importieren.*; import Java.io.*; public class tcpechoclient {public static void main (String [] args) löscht ioException {String Server = "127.0.0.1"; // Servername oder IP -Adresse int Servport = 5500; //// Server -Port -Byte [] data = "Hi, World" .GetByTes (); // Socket erstellen, der mit dem angegebenen Port Socket Socket = New Socket (Server, Servport) an den Server verbunden ist; System.out.println ("mit dem Server verbunden ... Echo -String senden"); InputStream in = socket.getInputStream (); OutputStream out = socket.getOutputStream (); out.write (Daten); // Senden Sie die codierte Zeichenfolge an den Server // Empfangen Sie die gleiche Zeichenfolge zurück vom Server int TotalByTesrcvd = 0; // Gesamt Bytes, die bisher int Bytesrcvd erhalten wurden; // Bytes, die in der letzten LEAD empfangen werden (TotalByTesrcvd <data.length) {if ((byteSrcvd = in.read (Daten, TotalByTesrcvd), Data.Length - TotalByTesrcvd)) == -1) Wirf eine neue SocketException ("Verbindung vorzeitig geschlossen geschlossen"); TotalByTesrcvd += bytesrcvd; } // Datenarray ist volles System.out.println ("Empfangen:" + neue String (Daten)); socket.close (); // Schließen Sie den Socket und seine Streams}}}上述代码的 TCP 服务端是单线程 , 一次只能服务一个客户端。 一次只能服务一个客户端。
查看更多 Java 的语法 , : : 《《Denken in Java 中文手册》、《 Jdk 1.7 参考手册官方英文版》、《 Jdk 1.6 API Java 中文参考手册》、《 Jdk 1.5 API Java 中文参考手册》 , 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。 也希望大家多多支持武林网。