客户端
复制代码代码如下:
import java.io.bufferedReader;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.socket;
clase pública myclient {
public static void main (string [] args) lanza la excepción {
Socket Socket = nuevo socket ("localhost", 10000);
BufferedReader in = new BufferedReader (new InputStreamReader (Socket.getInputStream ()));
PrintWriter out = new PrintWriter (Socket.getOutputStream ());
BufferedReader lector = new BufferedReader (new InputStreamReader (System.in));
while (verdadero) {
Cadena msg = lector.readline ();
out.println (msg);
out.flush ();
if (msg.equals ("adiós")) {
romper;
}
System.out.println (in.readline ());
}
socket.close ();
}
}
服务端
复制代码代码如下:
import java.io.bufferedReader;
import java.io.ioException;
import java.io.inputstreamreader;
import java.io.printwriter;
import java.net.serversocket;
import java.net.socket;
clase pública myServer {
public static void main (string [] args) lanza ioexception {
Serversocket Server = nuevo Serversocket (10000);
while (verdadero) {
Socket socket = server.accept ();
invocar (enchufe);
}
}
Invoca void estática privada (cliente final de socket) lanza IoException {
nuevo hilo (nuevo runnable () {
public void run () {
BufferedReader en = NULL;
PrintWriter out = null;
intentar {
in = new BufferedReader (new InputStreamReader (Client.getInputStream ()));
out = new PrintWriter (Client.getOutputStream ());
while (verdadero) {
Cadena msg = in.readline ();
System.out.println (MSG);
out.println ("servidor recibido" + msg);
out.flush ();
if (msg.equals ("adiós")) {
romper;
}
}
} catch (ioException ex) {
Ex.PrintStackTrace ();
} finalmente {
intentar {
cercar();
} capt (excepción e) {}
intentar {
out.close ();
} capt (excepción e) {}
intentar {
client.close ();
} capt (excepción e) {}
}
}
}).comenzar();
}
}