客户端
复制代码代码如下:
impor java.io.bufferedReader;
impor java.io.inputStreamReader;
impor java.io.printwriter;
impor java.net.socket;
kelas publik myclient {
public static void main (string [] args) melempar pengecualian {
Soket soket = soket baru ("localhost", 10000);
BufferedReader di = BufferedReader baru (inputStreamReader baru (socket.getInputStream ()));
Printwriter out = printwriter baru (socket.getoutputStream ());
BufferedReader Reader = BufferedReader baru (InputStreamReader baru (System.in));
while (true) {
String msg = reader.readline ();
out.println (msg);
out.flush ();
if (msg.equals ("bye")) {
merusak;
}
System.out.println (in.readline ());
}
socket.close ();
}
}
服务端
复制代码代码如下:
impor java.io.bufferedReader;
impor java.io.ioException;
impor java.io.inputStreamReader;
impor java.io.printwriter;
impor java.net.serversocket;
impor java.net.socket;
kelas publik myserver {
public static void main (string [] args) melempar ioException {
Server server = server baru (10000);
while (true) {
Soket soket = server.accept ();
Invoke (soket);
}
}
Private static void Invoke (klien soket terakhir) melempar ioException {
utas baru (runnable baru () {
public void run () {
BufferedReader di = null;
Printwriter out = null;
mencoba {
di = BufferedReader baru (inputStreamReader baru (client.getInputStream ()));
out = printwriter baru (client.getoutputStream ());
while (true) {
String msg = in.readline ();
System.out.println (msg);
out.println ("server menerima" + msg);
out.flush ();
if (msg.equals ("bye")) {
merusak;
}
}
} catch (ioException ex) {
Ex.PrintStackTrace ();
} Akhirnya {
mencoba {
melampirkan();
} catch (Exception e) {}
mencoba {
out.close ();
} catch (Exception e) {}
mencoba {
client.close ();
} catch (Exception e) {}
}
}
}).awal();
}
}