JAVA聊天室代码

以下是一个简单的Java聊天室项目的代码示例，包括服务器和客户端的实现。

服务器端代码：

import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {
    private ArrayList<PrintWriter> clientOutputStreams;

    public static void main(String[] args) {
        new ChatServer().startServer();
    }

    public void startServer() {
        clientOutputStreams = new ArrayList<PrintWriter>();
        try {
            ServerSocket serverSock = new ServerSocket(5000);

            while (true) {
                Socket clientSocket = serverSock.accept();
                PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
                clientOutputStreams.add(writer);

                Thread t = new Thread(new ClientHandler(clientSocket));
                t.start();
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void broadcast(String message) {
        Iterator<PrintWriter> it = clientOutputStreams.iterator();
        while (it.hasNext()) {
            try {
                PrintWriter writer = it.next();
                writer.println(message);
                writer.flush();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }

    class ClientHandler implements Runnable {
        BufferedReader reader;
        Socket sock;

        public ClientHandler(Socket clientSocket) {
            try {
                sock = clientSocket;
                InputStreamReader isReader = new InputStreamReader(sock.getInputStream());
                reader = new BufferedReader(isReader);
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }

        public void run() {
            String message;
            try {
                while ((message = reader.readLine()) != null) {
                    System.out.println("Received message: " + message);
                    broadcast(message);
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }
}

客户端代码：

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;

public class ChatClient {
    private TextArea incoming;
    private TextField outgoing;
    private BufferedReader reader;
    private PrintWriter writer;
    private Socket sock;

    public static void main(String[] args) {
        new ChatClient().startClient();
    }

    public void startClient() {
        Frame frame = new Frame("Chat Client");
        Panel mainPanel = new Panel(new BorderLayout());
        incoming = new TextArea(15, 50);
        incoming.setEditable(false);
        mainPanel.add(incoming, BorderLayout.CENTER);
        outgoing = new TextField(20);
        mainPanel.add(outgoing, BorderLayout.SOUTH);
        frame.add(mainPanel);
        frame.pack();

        outgoing.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                try {
                    writer.println(outgoing.getText());
                    writer.flush();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
                outgoing.setText("");
                outgoing.requestFocus();
            }
        });

        setupNetworking();

        frame.setVisible(true);
    }

    private void setupNetworking() {
        try {
            sock = new Socket("127.0.0.1", 5000);
            InputStreamReader streamReader = new InputStreamReader(sock.getInputStream());
            reader = new BufferedReader(streamReader);
            writer = new PrintWriter(sock.getOutputStream());
            System.out.println("Networking established");
            Thread t = new Thread(new IncomingReader());
            t.start();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    class IncomingReader implements Runnable {
        public void run() {
            String message;
            try {
                while ((message = reader.readLine()) != null) {
                    System.out.println("Received message: " + message);
                    incoming.append(message + "\n");
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }
}

这是一个简单的Java聊天室项目的代码示例，可以通过运行服务器和多个客户端来进行测试。请注意，这只是一个示例，实际项目可能需要更多的功能和安全性措施。