一、题目描述
题目实现：不同的客户端之间需要进行通信，一个客户端与其他的多个客户端进行通信，实现群聊功能。
实现一个客户端与其他多个客户端进行通信，运行程序，服务器启动后，启动3个客户端程序，然后通过第一个客户端向另外两个客户端发送信息，则另外的两个客户端都会收到服务器发送的信息。
二、解题思路
创建一个服务类：ClientOneToManyServerFrame，继承JFrame类
定义一个createSocket()方法，用于创建服务Socket和监听客户端程序。以及创建并启动线程对象并将接收到的客户端发送的信息转发给其他客户端。
创建一个客户端类：ClientOneToManyClientFrame，继承JFrame类
定义一个createClientSocket()方法，用于创建与服务器连接的Socket对象，输出流对象，以及启动线程对象接收服务器端转发的信息。
技术重点：
在服务器端通过线程对客户端发送的信息进行监听，当有客户端发送信息时，就会将该信息发送给其他已经登录到服务器的客户端，但是不会向发送方发送该信息，在客户端也通过线程来监听服务器转发的信息。 (1)在服务器端创建线程类ServerThread，用于接收客户端发送的信息，并转发给其他已经连接到服务器的客户端。
(2)在客户端创建线程类ClientThread，用于接收服务器端转发的客户端信息，并在客户端的文本域中显示接收到的信息。
启动多个客户端：
1、把项目打成jar包：利用maven 的clean install
会在target目录下生成jar包
2、进入target目录，使用java -cp的命令运行指定的类
java -cp 命令中 cp 指的就是classpath。使用该命令可以运行jar中的某个指定的类(要包含全路径的包名)
进入cmd命令模式
运行服务端
java -cp basics98-1.0-SNAPSHOT.jar com.xiaoxuzhu.ClientOneToManyServerFrame
运行多个客户端
java -cp basics98-1.0-SNAPSHOT.jar com.xiaoxuzhu.ClientOneToManyClientFrame
三、代码详解
ClientOneToManyServerFrame
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 | package com.xiaoxuzhu;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.Vector;import javax.swing.JFrame;import javax.swing.JScrollPane;import javax.swing.JTextArea;/** * Description: * * @author xiaoxuzhu * @version 1.0 * * <pre> * 修改记录: * 修改后版本 修改人 修改日期 修改内容 * 2022/6/5.1 xiaoxuzhu 2022/6/5 Create * </pre><p> * @date 2022/6/5<br> */<br>public class ClientOneToManyServerFrame extends JFrame {<br> private JTextArea ta_info;<br> private ServerSocket server; // 声明ServerSocket对象<br> private Socket socket; // 声明Socket对象socket<br> private Vector vector = new Vector();// 用于存储连接到服务器的客户端套接字对象</p><p> public void createSocket() {<br> try {<br> server = new ServerSocket(9527);<br> while (true) {<br> ta_info.append("等待新客户连接......n");<br> socket = server.accept();// 创建套接字对象<br> vector.add(socket);// 将套接字对象添加到向量对象中<br> ta_info.append("客户端连接成功。" + socket + "n");<br> new ServerThread(socket).start();// 创建并启动线程对象<br> }<br> } catch (IOException e) {<br> e.printStackTrace();<br> }<br> }</p><p> class ServerThread extends Thread {<br> Socket socket;<br> public ServerThread(Socket socket) {<br> this.socket = socket;<br> }<br> public void run() {<br> try {<br> BufferedReader in = new BufferedReader(new InputStreamReader(<br> socket.getInputStream()));// 创建输入流对象<br> while (true) {<br> String info = in.readLine();// 读取信息<br> for (Socket s : vector) {// 遍历所有客户端套接字对象<br> if (s != socket) {// 如果不是发送信息的套接字对象<br> PrintWriter out = new PrintWriter(s<br> .getOutputStream(), true);// 创建输出流对象<br> out.println(info);// 发送信息<br> out.flush();// 刷新输出缓冲区<br> }<br> }<br> }<br> } catch (IOException e) {<br> ta_info.append(socket + "已经退出。n");<br> vector.remove(socket);// 移除退出的客户端套接字<br> }<br> }<br> }</p><p> /**<br> * Launch the application<br> *<br> * @param args<br> */<br> public static void main(String args[]) {<br> ClientOneToManyServerFrame frame = new ClientOneToManyServerFrame();<br> frame.setVisible(true);<br> frame.createSocket();<br> }</p><p> /**<br> * Create the frame<br> */<br> public ClientOneToManyServerFrame() {<br> super();<br> setTitle("客户端一对多通信——服务器端程序");<br> setBounds(100, 100, 385, 266);<br> setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);</p><p> final JScrollPane scrollPane = new JScrollPane();<br> getContentPane().add(scrollPane, BorderLayout.CENTER);</p><p> ta_info = new JTextArea();<br> scrollPane.setViewportView(ta_info);<br> }<br>}</p> |
ClientOneToManyClientFrame
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 | package com.xiaoxuzhu;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;/** * Description: * * @author xiaoxuzhu * @version 1.0 * * <pre> * 修改记录: * 修改后版本 修改人 修改日期 修改内容 * 2022/6/5.1 xiaoxuzhu 2022/6/5 Create * </pre><p> * @date 2022/6/5<br> */<br>public class ClientOneToManyClientFrame extends JFrame{<br> private JTextArea ta_info;<br> private JTextField tf_send;<br> PrintWriter out;// 声明输出流对象</p><p> /**<br> * Launch the application<br> *<br> * @param args<br> */<br> public static void main(String args[]) {<br> EventQueue.invokeLater(new Runnable() {<br> public void run() {<br> try {<br> ClientOneToManyClientFrame frame = new ClientOneToManyClientFrame();<br> frame.setVisible(true);<br> frame.createClientSocket();<br> } catch (Exception e) {<br> e.printStackTrace();<br> }<br> }<br> });<br> }</p><p> public void createClientSocket() {<br> try {<br> Socket socket = new Socket("127.0.0.1", 9527);// 创建套接字对象<br> out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象<br> new ClientThread(socket).start();// 创建并启动线程对象<br> } catch (UnknownHostException e) {<br> e.printStackTrace();<br> } catch (IOException e) {<br> e.printStackTrace();<br> }<br> }</p><p> class ClientThread extends Thread {<br> Socket socket;</p><p> public ClientThread(Socket socket) {<br> this.socket = socket;<br> }</p><p> public void run() {<br> try {<br> BufferedReader in = new BufferedReader(new InputStreamReader(<br> socket.getInputStream()));// 创建输入流对象<br> while (true) {<br> String info = in.readLine();// 读取信息<br> ta_info.append(info + "n");// 在文本域中显示信息<br> if (info.equals("88")) {<br> break;// 结束线程<br> }<br> }<br> } catch (IOException e) {<br> e.printStackTrace();<br> }<br> }<br> }<br> private void send() {<br> String info = tf_send.getText();// 获得输入的信息<br> if (info.equals("")) {<br> return;// 如果没输入信息则返回，即不发送<br> }<br> if (info.equals("88")) {<br> System.exit(0);// 如果没输入信息是88，则退出<br> }<br> out.println(info);// 发送信息<br> out.flush();// 刷新输出缓冲区<br> tf_send.setText(null);// 清空文本框<br> }<br> /**<br> * Create the frame<br> */<br> public ClientOneToManyClientFrame() {<br> super();<br> setTitle("客户端一对多通信——客户端程序");<br> setBounds(100, 100, 385, 266);<br> setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);</p><p> final JPanel panel = new JPanel();<br> getContentPane().add(panel, BorderLayout.SOUTH);</p><p> final JLabel label = new JLabel();<br> label.setText("输入聊天内容：");<br> panel.add(label);</p><p> tf_send = new JTextField();<br> tf_send.addActionListener(new ActionListener() {<br> public void actionPerformed(final ActionEvent e) {<br> send();// 调用方法发送信息<br> }<br> });<br> tf_send.setPreferredSize(new Dimension(180, 25));<br> panel.add(tf_send);</p><p> final JButton button = new JButton();<br> button.addActionListener(new ActionListener() {<br> public void actionPerformed(final ActionEvent e) {<br> send();// 调用方法发送信息<br> }<br> });<br> button.setText("发 送");<br> panel.add(button);</p><p> final JScrollPane scrollPane = new JScrollPane();<br> getContentPane().add(scrollPane, BorderLayout.CENTER);</p><p> ta_info = new JTextArea();<br> scrollPane.setViewportView(ta_info);<br> //<br> }<br>}</p> |
服务器启动
客户端1向其他客户端群发信息
客户端2接收到的信息
客户端3接收到的信息
以上就是Java聊天室之实现客户端群聊功能的详细内容，更多关于Java聊天室的资料请关注IT俱乐部其它相关文章！
