多人聊天包

由于要先創建服務面板，接收客戶端連接的信息，此代碼使用順序為先啟動服務端，在啟動客戶端，服務端不用關，不然會報錯。多運行幾次客戶端，實現單人聊天

創建服務面板

package yiduiduo;import java.awt.BorderLayout;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Set;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;public class Ltmb extends JFrame {private JTextArea ta_info;private ServerSocket server; // 聲明ServerSocket對象private Socket socket; // 聲明Socket對象socketprivate Hashtable<String, Socket> map = new Hashtable<String, Socket>();// 用于存儲連接到服務器的用戶和客戶端套接字對象public void createSocket() {try {server = new ServerSocket(1978);while (true) {ta_info.append("等待新客戶連接......\n");socket = server.accept();// 創建套接字對象ta_info.append("客戶端連接成功。" + socket + "\n");new ServerThread(socket).start();// 創建并啟動線程對象}} catch (IOException e) {e.printStackTrace();}}class ServerThread extends Thread {Socket socket;public ServerThread(Socket socket) {this.socket = socket;}public void run() {try {BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 創建輸入流對象while (true) {String info = in.readLine();// 讀取信息String key = "";if (info.startsWith("用戶：")) {// 添加登錄用戶到客戶端列表key = info.substring(3, info.length());// 獲得用戶名并作為鍵使用map.put(key, socket);// 添加鍵值對Set<String> set = map.keySet();// 獲得集合中所有鍵的Set視圖Iterator<String> keyIt = set.iterator();// 獲得所有鍵的迭代器while (keyIt.hasNext()) {String receiveKey = keyIt.next();// 獲得表示接收信息的鍵Socket s = map.get(receiveKey);// 獲得與該鍵對應的套接字對象PrintWriter out = new PrintWriter(s.getOutputStream(), true);// 創建輸出流對象Iterator<String> keyIt1 = set.iterator();// 獲得所有鍵的迭代器while (keyIt1.hasNext()) {String receiveKey1 = keyIt1.next();// 獲得鍵，用于向客戶端添加用戶列表out.println(receiveKey1);// 發送信息out.flush();// 刷新輸出緩沖區}}} else {// 轉發接收的消息key = info.substring(info.indexOf("：發送給：") + 5, info.indexOf("：的信息是："));// 獲得接收方的key值,即接收方的用戶名String sendUser = info.substring(0, info.indexOf("：發送給："));// 獲得發送方的key值,即發送方的用戶名Set<String> set = map.keySet();// 獲得集合中所有鍵的Set視圖Iterator<String> keyIt = set.iterator();// 獲得所有鍵的迭代器while (keyIt.hasNext()) {String receiveKey = keyIt.next();// 獲得表示接收信息的鍵if (key.equals(receiveKey)&& !sendUser.equals(receiveKey)) {// 如果是發送方，但不是用戶本身Socket s = map.get(receiveKey);// 獲得與該鍵對應的套接字對象PrintWriter out = new PrintWriter(s.getOutputStream(), true);// 創建輸出流對象out.println("MSG:"+info);// 發送信息out.flush();// 刷新輸出緩沖區}}}}} catch (IOException e) {ta_info.append(socket + "已經退出。\n");}}}public static void main(String args[]) {Ltmb frame = new Ltmb();frame.setVisible(true);frame.createSocket();}public Ltmb() {super();setTitle("多個用戶聊天");setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);}
}

創建客戶面板

package yiduiduo;import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;public class Kehuduan extends JFrame {private JTextArea ta_info;private JTextField tf_send;PrintWriter out;// 聲明輸出流對象/*** Launch the application* * @param args*/public static void main(String args[]) {EventQueue.invokeLater(new Runnable() {public void run() {try {Kehuduan frame = new Kehuduan();frame.setVisible(true);frame.createClientSocket();} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try {Socket socket = new Socket("127.0.0.1", 1978);// 連接本地1978端口out = new PrintWriter(socket.getOutputStream(), true);// 創建輸出流對象new ClientThread(socket).start();// 創建并啟動線程對象} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}class ClientThread extends Thread {Socket socket;public ClientThread(Socket socket) {this.socket = socket;}public void run() {try {BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 創建輸入流對象while (true) {String info = in.readLine();// 讀取信息ta_info.append(info + "\n");// 在文本域中顯示信息if (info.equals("88")) {break;// 結束線程}}} catch (IOException e) {e.printStackTrace();}}}private void send() {String info = tf_send.getText();// 獲得輸入的信息if (info.equals("")) {return;// 如果沒輸入信息則返回，即不發送}if (info.equals("88")) {System.exit(0);// 如果沒輸入信息是88，則退出}out.println(info);// 發送信息out.flush();// 刷新輸出緩沖區tf_send.setText(null);// 清空文本框}public Kehuduan() {  //創建面板super();setTitle("客戶互相聊天");setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JPanel panel = new JPanel();getContentPane().add(panel, BorderLayout.SOUTH);final JLabel label = new JLabel();label.setText("輸入聊天內容：");panel.add(label);tf_send = new JTextField();tf_send.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});tf_send.setPreferredSize(new Dimension(180, 25));panel.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});button.setText("發  送");panel.add(button);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);}}

結果如下