import java.net.*;
import java.io.*;public class TalkServer { public static void main(String[] args) {
ServerSocket ss = null;
Socket sk = null;
BufferedReader cRead = null;
BufferedReader sRead = null;
String message = null;
PrintWriter pw = null; try {
ss = new ServerSocket(6666); sk = ss.accept(); cRead = new BufferedReader(new InputStreamReader(sk.getInputStream())); pw = new PrintWriter(sk.getOutputStream()); sRead = new BufferedReader(new InputStreamReader(System.in)); System.out.println("客户端说:" + cRead.readLine()); message = sRead.readLine();
while (!message.equals("bye")) {
pw.print(message);
pw.flush(); System.out.println("客户端说" + cRead.readLine());
message = sRead.readLine();
}
} catch (IOException e) {
e.printStackTrace();
} try {
cRead.close();
sRead.close();
pw.close();
sk.close();
ss.close();
} catch (IOException e) { e.printStackTrace();
} }
}


import java.net.*;
import java.io.*;public class TalkClient { public static void main(String[] args) { try {
String message = null;
Socket sk = new Socket("127.0.0.1", 6666);
BufferedReader sRead = new BufferedReader(new InputStreamReader(sk.getInputStream()));
PrintWriter pw = new PrintWriter(sk.getOutputStream());
BufferedReader cRead = new BufferedReader(new InputStreamReader(System.in));
message = cRead.readLine();
while (!message.equals("bye")) {
pw.print(message);
pw.flush();
System.out.println("服务器端说:" + sRead.readLine()); message = cRead.readLine(); }
cRead.close();
sRead.close();
pw.close();
sk.close();
} catch (UnknownHostException e) { e.printStackTrace();
} catch (IOException e) { e.printStackTrace();
} }
}