Java版多人聊天室

server.java

import java.io.*;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.*;
import java.awt.*;
import javax.swing.*;

@SuppressWarnings("serial")
public class Server extends JFrame {
    // Text area for displaying data
    private JTextArea jta = new JTextArea();
    ArrayList<Client> clients = new ArrayList<Client>();
    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    Date d = new Date();
    String time = format.format(d);
    // Statistics the number of clients
    int clientNo = 0;

    public static void main(String[] args) {
        new Server();
    }

    public Server() {
        // Place text area on the frame
        setLayout(new BorderLayout());
        add(new JScrollPane(jta), BorderLayout.CENTER);

        setTitle("Server");
        setSize(500, 300);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setVisible(true); // It is necessary to show the frame here!

        ServerSocket serverSocket = null;
        try {
            // Create a server socket
            serverSocket = new ServerSocket(2014);
        } catch (IOException ex) {
            jta.append(" ***端口已被占用!*** " + '
');
        }
        jta.append(" ***服务器启动时间： " + time + "***" + '
');

        while (true) {
            Socket socket = null;
            try {
                // Listen for a connection request
                socket = serverSocket.accept();
            } catch (IOException e) {
                e.printStackTrace();
            }
            // To display client inetAddress
            InetAddress inetAddress = socket.getInetAddress();
            clientNo++;
            jta.append(" Client " + clientNo + '
');
            jta.append(" Host name is " + inetAddress.getHostName() + '
');
            jta.append(" IP Address is " + inetAddress.getHostAddress() + '
');

            // Create a new Thread for client
            Client task = new Client(socket);
            clients.add(task);
            new Thread(task).start();
        }
    }

    class Client implements Runnable {
        Socket socket;
        // Create data input and output streams
        DataInputStream inputFromClient = null;
        DataOutputStream outputToClient = null;
        Client c = null;

        public Client(Socket socket) {
            this.socket = socket;
            try {
                inputFromClient = new DataInputStream(socket.getInputStream());
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                outputToClient = new DataOutputStream(socket.getOutputStream());
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        public void sentAll(String str) {
            try {
                // Receive message from the client
                outputToClient.writeUTF(str);
            } catch (SocketException e) {
                if (c != null)
                    clients.remove(c);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        public void run() {
            try {
                while (true) {
                    // Receive sentence from the client
                    String sentence = inputFromClient.readUTF();
                    // Send sentence back to the client
                    for (int i = 0; i < clients.size(); i++) {
                        c = clients.get(i);
                        c.sentAll(sentence);
                    }

                    // Display to the text area
                    jta.append(" " + time + "
");
                    jta.append(" " + sentence + '
');
                }
            } catch (IOException e) {
                // e.printStackTrace();
                clientNo--;
                if (clientNo == 0) {
                    jta.append(" ***无客户端连接!***" + "
");
                    clients.remove(c); // 防止新用户使用
                } else {
                    jta.append(" ***退出一用户! 剩余用户: " + clientNo + "***" + "
");
                }
            }
        }
    }
}

client.java

import java.io.*;
import java.net.*;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;

@SuppressWarnings("serial")
public class Client extends JFrame {
    // Text field for receiving data
    private JTextField jtfName = new JTextField(); // Enter Name
    private JTextField jtfMessage = new JTextField(); // Enter Message

    // Text Area to display data
    private JTextArea jta = new JTextArea();

    // Button for send massage
    private JButton jbSend = new JButton("Send");

    // IO streams
    private DataOutputStream toServer;
    private DataInputStream fromServer;

    public static void main(String[] args) {
        new Client();
    }

    public Client() {
        // Panel p to hold the label and text field
        JPanel p = new JPanel();
        p.setLayout(new GridLayout(2, 2));
        p.add(new JLabel(" Enter Name: "));
        p.add(jtfName);
        p.add(new JLabel(" Enter Message: "));
        p.add(jtfMessage);
        jtfName.setHorizontalAlignment(JTextField.LEFT);
        jtfMessage.setHorizontalAlignment(JTextField.LEFT);

        setLayout(new BorderLayout());
        add(p, BorderLayout.NORTH);
        add(new JScrollPane(jta), BorderLayout.CENTER);
        add(jbSend, BorderLayout.SOUTH);

        // Register listener for jbSend button
        jbSend.addActionListener(new ButtonListener());

        // Register listener for jtfName JTextField
        jtfName.addActionListener(new ButtonListener());

        // Register listener for jtfMessage JTextField
        jtfMessage.addActionListener(new ButtonListener());

        setTitle("Client");
        setSize(500, 300);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setVisible(true); // It is necessary to show the frame here!

        try {
            // Create a socket to connect to the server
            Socket socket = new Socket("localhost", 2014);

            // Create an input stream to receive data from the server
            fromServer = new DataInputStream(socket.getInputStream());

            // Create an output stream to send data to the server
            toServer = new DataOutputStream(socket.getOutputStream());

            // Receive data from the server all the time
            while (true) {
                // read data from client
                String sentence = fromServer.readUTF();
                SimpleDateFormat format = new SimpleDateFormat(
                        "yyyy-MM-dd HH:mm:ss");
                Date d = new Date();
                String time = format.format(d);

                // Display to the text area
                jta.append(" " + time + "
");
                jta.append(" " + sentence + "
");
            }
        } catch (IOException ex) {
            jta.append(" ***服务器连接失败!***" + '
');
        }
    }

    private class ButtonListener implements ActionListener {
        public void actionPerformed(ActionEvent e) {
            try {
                // Get the Name and Message from the text field
                String Name = jtfName.getText().trim();
                String Message = jtfMessage.getText().trim();
                // Prevent send a blank message
                if (Name != null && Name.length() != 0 && Message != null
                        && Message.length() != 0) {
                    String data = Name + "： " + Message;

                    // Send the data to the server
                    toServer.writeUTF(data);
                    toServer.flush();
                } else
                    jta.append(" ***警告：名称和内容均不能为空!*** " + "
");

            } catch (IOException ex) {
                System.err.println(ex);
            }
        }
    }
}

下载链接: http://pan.baidu.com/s/1i3oQlyl 密码: jk6q