多用户在线聊天客户端

[java]代码库

import javax.swing.*;
import java.awt.*;
import java.net.*;
import java.awt.*;
import javax.swing.*;
import java.io.*;
import java.awt.event.*;
 
public class ChatClient{
    private String name;
    private Socket s;
    private DataInputStream dis;
    private DataOutputStream dos;
    private JFrame jf;
    private JTextArea jta;
    private JTextField jtf;
    private boolean runnable = true;
     
    public static void main(String args[]){
        ChatClient cc = new ChatClient();
        cc.createUI();
        cc.inputName();
        cc.connect();
        cc.createThread();
         
    }
    public void createUI(){
        jf = new JFrame("客户端");
        jta = new JTextArea();
        jta.setEditable(false);
        jtf = new JTextField();
        Button send = new Button("发送");
        Panel p = new Panel();
        p.setLayout(new BorderLayout());
        p.add(jtf,"Center");
        p.add(send,"East");
        jf.add(jta,"Center");
        jf.add(p,"South");
         
        MyClientListener listener = new MyClientListener(this);
        send.addActionListener(listener);
        jtf.addActionListener(listener);
        jf.addWindowListener(new WindowAdapter(){
            public void windowClosing(WindowEvent e){
                ChatClient.this.shutDown();
            }
            });
        jf.setSize(400,400);
        jf.setLocation(600,0);
        jf.setVisible(true);
        jtf.requestFocus();
    }
    public void inputName(){
        String name = JOptionPane.showInputDialog("Input Your name:");
        this.setName(name);
        jf.setTitle(name);
    }
    public void connect(){
        try{
            s = new Socket("127.0.0.1",9999);
            dos = new DataOutputStream(s.getOutputStream());
            dis = new DataInputStream(s.getInputStream());
            dos.writeUTF(name);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    public void createThread(){
        MyClientReader reader = new MyClientReader(this);
        reader.start();
    }
    public void stop(){
        runnable = false;
    }
    public void shutDown(){
        try{
            dos.writeUTF("Bye");
            jta.append("Exit in 5 seconds");
            this.stop();
            Thread.sleep(5000);
            dis.close();
            dos.close();
            s.close();
        }catch(Exception e){
            e.printStackTrace();
        }
        System.exit(0);
    }
     
    public boolean getRunnable(){
        return runnable;
    }
    public void setName(String name){
        this.name = name;
    }
    public DataInputStream getDataInputStream(){
        return dis;
    }
    public DataOutputStream getDataOutputStream(){
        return dos;
    }
    public JTextArea getTextArea(){
        return jta;
    }
    public JTextField getTextField(){
        return jtf;
    }
     
}
 
class MyClientListener implements ActionListener{
    private ChatClient client;
    public MyClientListener(ChatClient client){
        this.client = client;
    }
    public void actionPerformed(ActionEvent e){
        JTextField jtf = client.getTextField();
        String info = jtf.getText();
        try{
            client.getDataOutputStream().writeUTF(info);
        }catch(Exception e1){
            e1.printStackTrace();
        }
        if(info.equals("bye")){
            client.shutDown();
        }
        jtf.setText("");
        jtf.requestFocus();
    }
}
 
class MyClientReader extends Thread{
    private ChatClient client;
    public MyClientReader(ChatClient client){
        this.client = client;
    }
     
    public void run(){
        String info;
        DataInputStream dis = client.getDataInputStream();
        JTextArea jta = client.getTextArea();
        try{
            while(client.getRunnable()){
                info = dis.readUTF();
                jta.append(info+"\n");
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}