Java多客户端聊天.doc

最近回顾Java网络编程写的一个简易聊天demo，支持群聊，UI部分较为简陋，但是功能还是满足的，可以作为Java版的聊天程序基础程序进行二次开发，代码如下：1. Server:package MuliChat;import java.awt.BorderLayout;import java.io.DataInputStream;import java.io.DataOutputStream;import .ServerSocket;import .Socket;import java.util.ArrayList;import java.util.Date;import javax.swing.JFrame;import javax.swing.JScrollPane;import javax.swing.JTextArea;public class Server extends JFrame private JTextArea jTextArea = new JTextArea();public static ArrayList socketList = new ArrayList();/ ArrayList管理socket对象public static void main(String args) / TODO Auto-generated method stubnew Server();public Server() / Server UI部分setLayout(new BorderLayout();add(new JScrollPane(jTextArea), BorderLayout.CENTER);setTitle(server);setSize(500, 300);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setVisible(true);try ServerSocket serverSocket = new ServerSocket(8000);jTextArea.append(Server started at : + new Date() + n);int clientNum = 1;while (true) / 循环监听每一个连接到服务器端的client，并创建线程Socket socket = serverSocket.accept();jTextArea.append(Client + clientNum + connected + n);socketList.add(socket);/ socket监听对象添加进listHandleSession task = new HandleSession(socket, socketList);new Thread(task).start();/ 为每一个client各启动一次线程clientNum+; catch (Exception e) / TODO: handle exception/* * 内部类线程task * * author Alex * */class HandleSession implements Runnable Socket client;ArrayList clients;DataInputStream fromClient;DataOutputStream toClient;/ 构造函数public HandleSession(Socket client, ArrayList clients)throws Exception super();this.client = client;this.clients = clients;fromClient = new DataInputStream(client.getInputStream();public void run() / TODO Auto-generated method stubtry while (true) String content = fromClient.readUTF();/ 获取client的输入值jTextArea.append(content + n);if (content != null) for (Socket socket : clients) / foreach遍历if (client != socket) / 对不是自己本身的Client对象都输出一次值toClient = new DataOutputStream(socket.getOutputStream();toClient.writeUTF(content);/ 传递到Client中 catch (Exception e) / TODO: handle exception2. Client：package MuliChat;import java.awt.BorderLayout;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import .Socket;import javax.swing.JFrame;import javax.swing.JLabel;import javax.swing.JPanel;import javax.swing.JScrollPane;import javax.swing.JTextArea;import javax.swing.JTextField;/* * 使用一个线程实现两个Cilent聊天 * * author Alex * */public class Client extends JFrame private JTextArea jArea = new JTextArea();private JTextField jTextField = new JTextField();private DataInputStream fromServer;private DataOutputStream toServer;public static void main(String args) / TODO Auto-generated method stubnew Client();public Client() / Client UI 部分JPanel panel = new JPanel();panel.setLayout(new BorderLayout();panel.add(new JLabel(Enter), BorderLayout.EAST);panel.add(jTextField, BorderLayout.CENTER);jTextField.setHorizontalAlignment(jTextField.LEFT);setLayout(new BorderLayout();add(panel, BorderLayout.SOUTH);add(new JScrollPane(jArea), BorderLayout.CENTER);setTitle(Client);setSize(400, 400);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setVisible(true);jTextField.addActionListener(new TextFieldListener();try Socket socket = new Socket(localhost, 8000);fromServer = new DataInputStream(socket.getInputStream();toServer = new DataOutputStream(socket.getOutputStream();while (true) String strFromServer = fromServer.readUTF();jArea.append(strFromServer + n); catch (Exception e) / TODO: handle exceptionprivate class TextFieldListener implements ActionListener public void actionPerformed(ActionEvent e) / TODO Auto-generated method stubString stringToServe