java编写的聊天器.doc

Java代码编写的聊天器。属于自己的聊天器。（模拟QQ） 运行的时候先运行ChatServer.java 在运行ChatClient.java可多次运行，群聊) 客户端代码： ChatClient.java import java.awt.*; import java.awt.event.*; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.EOFException; import java.io.IOException; import java.net.Socket; import java.net.SocketException; import java.net.UnknownHostException; public class ChatClient extends Frame { Socket s= null; DataOutputStream dos = null; DataInputStream dis = null; private boolean bconnected = false; TextField tfTxt = new TextField(); TextArea taContent = new TextArea(); public void lanuchClient() { setLocation(400, 300); setSize(400, 400); add(tfTxt, BorderLayout.SOUTH); add(taContent, BorderLayout.NORTH); pack(); connect(); new Thread(new RecvThread()).start(); tfTxt.addActionListener(new TFListener() ); this.addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent e) { disconnect(); System.exit(0); } }); setVisible(true); } public class TFListener implements ActionListener{ public void actionPerformed(ActionEvent e) { String str = tfTxt.getText().trim(); // taContent.setText(str); tfTxt.setText(); try { dos.writeUTF(str); dos.flush(); //dos.close(); } catch (IOException e1) { e1.printStackTrace(); } } } public void connect(){ try { s = new Socket(127.0.0.1,88); dos = new DataOutputStream(s.getOutputStream()); dis = new DataInputStream(s.getInputStream()); System.out.println(-----connect!); 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 RecvThread implements Runnable{ public void run() { //单独的线程来接受服务器的发来的消息 try{ wh