JAVA聊天室系统

import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; public class ChatClient extends Frame { Socket s = null; DataOutputStream dos = null; DataInputStream dis = null; private boolean bConnected = false; TextField tf = new TextField(); TextArea ta = new TextArea(); public static void main(String[] args) { new ChatClient().launchFrame(); } public void launchFrame() { setLocation(400, 300); setBackground(Color.MAGENTA); setSize(400, 300); // backGround(Color.blue); tf.setBackground(Color.cyan); ta.setBackground(Color.ORANGE); add(tf, BorderLayout.SOUTH); add(ta, BorderLayout.NORTH); this.addWindowListener(new WindowAdapter(){ public void windowClosing(WindowEvent e) { disconnect(); System.exit(0); }}); tf.addActionListener(new TFListener()); setVisible(true); connect(); new Thread(new Receive()).start(); } public void connect() { try { s = new Socket("127.0.0.1",8888); dos = new DataOutputStream(s.getOutputStream()); dis = new DataInputStream(s.getInputStream()); bConnected = true; } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } public void disconnect() { try { dos.close(); s.close(); } catch (IOException e) { e.printStackTrace(); } } private class TFListener implements ActionListener { public void actionPerformed(ActionEvent e) { String str = tf.getText().trim(); //ta.setText(str); tf.setText(""); try { //每次发送数据都要重新创建一个输出流，太浪费资源，所以在 //类的开头定义一次输出流，每次发数据就不用重新定义 //DataOutputStream dos = new DataOutputStream(s.getOutputStream()); dos.writeUTF(str); dos.flush(); // 不应关闭 //dos.close(); } catch (IOException e1) { e1.printStackTrace(); } } } private class Receive implements Runnable { public void run() { try { while(bConnected) { String str = dis.readUTF(); ta.setText(ta.getText() + str +'\n'); } } catch (SocketException e) { } catch(IOException e) { e.printStackTrace(); } } } }