Java聊天室之實現(xiàn)一個服務(wù)器與多個客戶端通信
一、題目描述
題目實現(xiàn):一個服務(wù)器與多個客戶端通信。通過一個服務(wù)器與多個客戶端進行通信,運行程序,服務(wù)器啟動后,啟動兩個客戶端程序,然后通過服務(wù)器向客戶端發(fā)送信息,兩個客戶端都會收到服務(wù)器發(fā)送的信息。
二、解題思路
創(chuàng)建一個服務(wù)器類:ServerSocketFrame,繼承JFrame類
寫一個getserver() 方法,實例化Socket對象,啟用9527當(dāng)服務(wù)的端口。
創(chuàng)建輸入流對象,用來接收客戶端信息。
再定義一個getClientInfo()方法,用于接收客戶端發(fā)送的信息。
創(chuàng)建一個客戶端類:ClientSocketFrame,繼承JFrame類。
寫一個connect() 方法,實例化Socket對象,連接本地服務(wù)的9527端口服務(wù)。
再定義一個getClientInfo()方法,用于接收服務(wù)端發(fā)送的信息。
技術(shù)重點:
在服務(wù)器端通過線程來處理不同客戶發(fā)送的信息,所以當(dāng)有多個客戶連接到服務(wù)器時,服務(wù)器會為每個客戶建立一個線程來處理接收到的信息,由于通過線程來處理接收到每個客戶的信息,因此不會產(chǎn)生阻塞,從而實現(xiàn)了一個服務(wù)器與多個客戶端通信,并且在關(guān)閉客戶端窗體時,會向服務(wù)器端發(fā)送退出客戶的索引。
啟動多個客戶端:
1、把項目打成jar包:利用maven 的clean install
會在target目錄下生成jar包
2、進入target目錄,使用java -cp的命令運行指定的類
java -cp 命令中 cp 指的就是classpath。使用該命令可以運行jar中的某個指定的類(要包含全路徑的包名)
進入cmd命令模式
運行服務(wù)端
java -cp basics98-1.0-SNAPSHOT.jar com.xiaoxuzhu.ServerSocketFrame
運行多個客戶端
java -cp basics98-1.0-SNAPSHOT.jar com.xiaoxuzhu.ClientSocketFrame
三、代碼詳解
ServerSocketFrame
package com.xiaoxuzhu; import java.awt.BorderLayout; import java.awt.Color; import java.awt.Dimension; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.*; import java.net.*; 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> * 修改記錄: * 修改后版本 修改人 修改日期 修改內(nèi)容 * 2022/6/5.1 xiaoxuzhu 2022/6/5 Create * </pre> * @date 2022/6/5 */ public class ServerSocketFrame extends JFrame { private JTextField tf_send; private JTextArea ta_info; private PrintWriter writer; // 聲明PrintWriter類對象 private BufferedReader reader; // 聲明BufferedReader對象 private ServerSocket server; // 聲明ServerSocket對象 private Socket socket; // 聲明Socket對象socket public void getServer() { try { server = new ServerSocket(9527); // 實例化Socket對象 ta_info.append("服務(wù)器套接字已經(jīng)創(chuàng)建成功\n"); // 輸出信息 while (true) { // 如果套接字是連接狀態(tài) ta_info.append("等待客戶機的連接......\n"); // 輸出信息 socket = server.accept(); // 實例化Socket對象 reader = new BufferedReader(new InputStreamReader(socket .getInputStream())); // 實例化BufferedReader對象 writer = new PrintWriter(socket.getOutputStream(), true); getClientInfo(); // 調(diào)用getClientInfo()方法 } } catch (Exception e) { e.printStackTrace(); // 輸出異常信息 } } private void getClientInfo() { try { while (true) { String line = reader.readLine();// 讀取客戶端發(fā)送的信息 if (line != null) ta_info.append("接收到客戶機發(fā)送的信息:" + line + "\n"); // 顯示客戶端發(fā)送的信息 } } catch (Exception e) { ta_info.append("客戶端已退出。\n"); // 輸出異常信息 } finally { try { if (reader != null) { reader.close();// 關(guān)閉流 } if (socket != null) { socket.close(); // 關(guān)閉套接字 } } catch (IOException e) { e.printStackTrace(); } } } public static void main(String[] args) { // 主方法 ServerSocketFrame frame = new ServerSocketFrame(); // 創(chuàng)建本類對象 frame.setVisible(true); frame.getServer(); // 調(diào)用方法 } public ServerSocketFrame() { super(); setTitle("服務(wù)器端程序"); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 379, 260); final JScrollPane scrollPane = new JScrollPane(); getContentPane().add(scrollPane, BorderLayout.CENTER); ta_info = new JTextArea(); scrollPane.setViewportView(ta_info); final JPanel panel = new JPanel(); getContentPane().add(panel, BorderLayout.SOUTH); final JLabel label = new JLabel(); label.setText("服務(wù)器發(fā)送的信息:"); panel.add(label); tf_send = new JTextField(); tf_send.setPreferredSize(new Dimension(150, 25)); panel.add(tf_send); final JButton button = new JButton(); button.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { writer.println(tf_send.getText()); // 將文本框中信息寫入流 ta_info.append("服務(wù)器發(fā)送的信息是:" + tf_send.getText() + "\n"); // 將文本框中信息顯示在文本域中 tf_send.setText(""); // 將文本框清空 } }); button.setText("發(fā) 送"); panel.add(button); final JPanel panel_1 = new JPanel(); getContentPane().add(panel_1, BorderLayout.NORTH); final JLabel label_1 = new JLabel(); label_1.setForeground(new Color(0, 0, 255)); label_1.setFont(new Font("", Font.BOLD, 22)); label_1.setText("一對一通信——服務(wù)器端程序"); panel_1.add(label_1); } }
ClientSocketFrame
package com.xiaoxuzhu; import java.awt.BorderLayout; import java.awt.Color; import java.awt.Dimension; import java.awt.Font; 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 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> * 修改記錄: * 修改后版本 修改人 修改日期 修改內(nèi)容 * 2022/6/5.1 xiaoxuzhu 2022/6/5 Create * </pre> * @date 2022/6/5 */ public class ClientSocketFrame extends JFrame { private PrintWriter writer; // 聲明PrintWriter類對象 private BufferedReader reader; // 聲明BufferedReader對象 private Socket socket; // 聲明Socket對象 private JTextArea ta_info; // 創(chuàng)建JtextArea對象 private JTextField tf_send; // 創(chuàng)建JtextField對象 private void connect() { // 連接套接字方法 ta_info.append("嘗試連接......\n"); // 文本域中信息信息 try { // 捕捉異常 socket = new Socket("127.0.0.1", 9527); // 實例化Socket對象 while (true) { writer = new PrintWriter(socket.getOutputStream(), true); reader = new BufferedReader(new InputStreamReader(socket .getInputStream())); // 實例化BufferedReader對象 ta_info.append("完成連接。\n"); // 文本域中提示信息 getServerInfo(); } } catch (Exception e) { e.printStackTrace(); // 輸出異常信息 } } public static void main(String[] args) { // 主方法 ClientSocketFrame clien = new ClientSocketFrame(); // 創(chuàng)建本例對象 clien.setVisible(true); // 將窗體顯示 clien.connect(); // 調(diào)用連接方法 } private void getServerInfo() { try { while (true) { if (reader != null) { String line = reader.readLine();// 讀取服務(wù)器發(fā)送的信息 if (line != null) ta_info.append("接收到服務(wù)器發(fā)送的信息:" + line + "\n"); // 顯示服務(wù)器端發(fā)送的信息 } } } catch (Exception e) { e.printStackTrace(); } finally { try { if (reader != null) { reader.close();// 關(guān)閉流 } if (socket != null) { socket.close(); // 關(guān)閉套接字 } } catch (IOException e) { e.printStackTrace(); } } } /** * Create the frame */ public ClientSocketFrame() { super(); setTitle("客戶端程序"); setBounds(100, 100, 361, 257); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); final JPanel panel = new JPanel(); getContentPane().add(panel, BorderLayout.NORTH); final JLabel label = new JLabel(); label.setForeground(new Color(0, 0, 255)); label.setFont(new Font("", Font.BOLD, 22)); label.setText("一對一通信——客戶端程序"); panel.add(label); final JPanel panel_1 = new JPanel(); getContentPane().add(panel_1, BorderLayout.SOUTH); final JLabel label_1 = new JLabel(); label_1.setText("客戶端發(fā)送的信息:"); panel_1.add(label_1); tf_send = new JTextField(); tf_send.setPreferredSize(new Dimension(140, 25)); panel_1.add(tf_send); final JButton button = new JButton(); button.addActionListener(new ActionListener() { public void actionPerformed(final ActionEvent e) { writer.println(tf_send.getText()); // 將文本框中信息寫入流 ta_info.append("客戶端發(fā)送的信息是:" + tf_send.getText() + "\n"); // 將文本框中信息顯示在文本域中 tf_send.setText(""); // 將文本框清空 } }); button.setText("發(fā) 送"); panel_1.add(button); final JScrollPane scrollPane = new JScrollPane(); getContentPane().add(scrollPane, BorderLayout.CENTER); ta_info = new JTextArea(); scrollPane.setViewportView(ta_info); // } }
服務(wù)器啟動
客戶端1啟動
客戶端2啟動
客戶端1向服務(wù)端發(fā)送信息
服務(wù)端接收到信息
客戶端2向服務(wù)端發(fā)送信息
服務(wù)端接收到信息
服務(wù)端向客戶端發(fā)送信息
以上就是Java聊天室之實現(xiàn)一個服務(wù)器與多個客戶端通信的詳細內(nèi)容,更多關(guān)于Java聊天室的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Java課設(shè)案例之百行代碼實現(xiàn)簡易計算器
下面這篇文章主要給大家介紹了關(guān)于Java課設(shè)案例之百行代碼實現(xiàn)簡易計算器的相關(guān)資料,這是一個關(guān)于java簡單計算器的完整課程設(shè)計以及源碼,需要的朋友可以參考下2023-06-06劍指Offer之Java算法習(xí)題精講數(shù)組與二叉樹
跟著思路走,之后從簡單題入手,反復(fù)去看,做過之后可能會忘記,之后再做一次,記不住就反復(fù)做,反復(fù)尋求思路和規(guī)律,慢慢積累就會發(fā)現(xiàn)質(zhì)的變化2022-03-03線程池之newFixedThreadPool定長線程池的實例
這篇文章主要介紹了線程池之newFixedThreadPool定長線程池的實例,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-06-06