客户端
复制代码代码如下::
Import Java.io.BufferedReader;
importieren java.io.inputStreamReader;
Import Java.io.printwriter;
importieren java.net.socket;
öffentliche Klasse Myclient {
public static void main (String [] args) löst Ausnahme {aus {
Socket Socket = New Socket ("Localhost", 10000);
BufferedReader in = neuer BufferedReader (neuer InputStreamReader (Socket.GetInputStream ()));
Printwriter out = neuer printwriter (socket.getOutputStream ());
BufferedReader reader = neuer bufferedReader (neuer InputStreamReader (System.in));
while (wahr) {
String msg = reader.readline ();
out.println (msg);
out.flush ();
if (msg.equals ("bye")) {
brechen;
}
System.out.println (in.readline ());
}
socket.close ();
}
}
服务端
复制代码代码如下::
Import Java.io.BufferedReader;
importieren java.io.ioException;
importieren java.io.inputStreamReader;
Import Java.io.printwriter;
importieren java.net.serversocket;
importieren java.net.socket;
öffentliche Klasse MyServer {
public static void main (String [] args) löst ioException {aus
ServerSocket Server = New ServerSocket (10000);
while (wahr) {
Socket Socket = server.accept ();
aufrufen (Socket);
}
}
private static void incoke (endgültiger Socket Client) löst IoException {aus
neuer Thread (neuer Runnable () {
public void run () {
BufferedReader in = null;
Printwriter out = null;
versuchen {
in = neuer BufferedReader (neuer InputStreamReader (client.getInputStream ()));
out = new printwriter (client.getOutputStream ());
while (wahr) {
String msg = in.readline ();
System.out.println (MSG);
out.println ("Server empfangen" + msg);
out.flush ();
if (msg.equals ("bye")) {
brechen;
}
}
} catch (ioException ex) {
ex.printstacktrace ();
} Endlich {
versuchen {
in.close ();
} catch (Ausnahme e) {}
versuchen {
out.close ();
} catch (Ausnahme e) {}
versuchen {
client.close ();
} catch (Ausnahme e) {}
}
}
}).Start();
}
}