简易聊天室JAVA代码

import java.awt.*;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.awt.event.WindowAdapter;import java.awt.event.WindowEvent;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.net.*;public class ChatClient extends Frame {private boolean connected = false;private DataOutputStream dos = null;private DataInputStream dis = null;private static final long serialVersionUID = 1L;private Socket s = null;private TextField tfWords = null;private TextArea taShow = null;public static void main(String args[]) {ChatClient cc = new ChatClient();cc.launchFrame();cc.Listen();}public void launchFrame() {try {s = new Socket(InetAddress.getByName("localhost"), 8888);connected = true;dos = new DataOutputStream(s.getOutputStream());dis = new DataInputStream(s.getInputStream());} catch (IOException ioe) {System.out.println("服务器连接失败！");ioe.printStackTrace();}this.tfWords = new TextField();this.taShow = new TextArea();this.setTitle("Chatroom Client");this.setLocation(700, 50);this.add(tfWords, BorderLayout.SOUTH);this.add(taShow, BorderLayout.NORTH);this.setSize(200, 250);this.addWindowListener(new WindowAdapter() {public void windowClosing(WindowEvent e) {try {connected = false;dos.writeUTF("###Exit###");dos.flush();close();System.exit(0);} catch (IOException ioe) {System.out.println("消息发送出错！");ioe.printStackTrace();}}});this.setVisible(true);this.tfWords.addActionListener(new TFWordsListener());}public void Listen() {new Thread(new ListenThread()).start();}public void close() {try {if (dos != null)dos.close();if (s != null)s.close();} catch (IOException ioe) {ioe.printStackTrace();System.out.println("客户端断开时出错！");System.exit(-1);}}public class ListenThread implements Runnable{public void run(){while (connected) {try {String back = dis.readUTF(); //堵塞...