客户端
复制代码代码如下:
Importer java.io.bufferedReader;
Importer java.io.inputStreamReader;
import java.io.printwriter;
import java.net.socket;
classe publique myClient {
public static void main (String [] args) lève une exception {
Socket socket = new socket ("localhost", 10000);
BufferedReader dans = new BufferedReader (new InputStreamReader (socket.getInputStream ()));
Printwriter out = new printwriter (socket.getOutputStream ());
BufferedReader Reader = new BufferedReader (new InputStreamReader (System.in));
while (true) {
String msg = reader.readline ();
out.println (msg);
out.flush ();
if (msg.equals ("bye")) {
casser;
}
System.out.println (in.readline ());
}
socket.close ();
}
}
服务端
复制代码代码如下:
Importer java.io.bufferedReader;
Importer java.io.ioException;
Importer java.io.inputStreamReader;
import java.io.printwriter;
import java.net.serversocket;
import java.net.socket;
classe publique MyServer {
public static void main (String [] args) lance ioException {
SERVERSOCKET Server = new SERVERSocket (10000);
while (true) {
Socket socket = server.accept ();
invoquer (douille);
}
}
Invoque de vide statique privé (client de socket final) lève IOException {
nouveau thread (new Runnable () {
public void run () {
BufferedReader dans = null;
Printwriter out = null;
essayer {
dans = new BufferedReader (new inputStreamReader (client.getInputStream ()));
out = new printwriter (client.getOutputStream ());
while (true) {
String msg = in.readline ();
System.out.println (msg);
out.println ("serveur reçu" + msg);
out.flush ();
if (msg.equals ("bye")) {
casser;
}
}
} catch (ioException ex) {
ex.printStackTrace ();
} enfin {
essayer {
joindre();
} catch (exception e) {}
essayer {
out.close ();
} catch (exception e) {}
essayer {
client.close ();
} catch (exception e) {}
}
}
}).commencer();
}
}