當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

创建专属聊天室练习（客户端与服务端通信|客户端界面交互）

發布時間：2023/12/20 编程问答 33 豆豆

生活随笔收集整理的這篇文章主要介紹了创建专属聊天室练习（客户端与服务端通信|客户端界面交互）小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

一、知識回顧與補充

二、客戶端與服務器通信

package client;import java.io.*; import java.net.Socket; import java.util.Scanner;public class TestClient {public static void main(String[] args) {try {System.out.println("我是客戶端");//1.主動訪問服務端，訪問成功后，即連接成功，獲取一個socket對象Socket socket=new Socket("127.0.0.1",9999);//服務器地址（IP）服務器開放的端口號（port）System.out.println("我成功連接到服務器啦？");//======================================Scanner input=new Scanner(System.in);//2.讀取服務器發送過來的消息讀消息/輸入流對象//不能自己創建，需要通過socket對象來回去InputStream is = socket.getInputStream();//is其實可以拿去讀取消息，is是一個字節型輸入流//為了讀取字符更加方便，做一個包裝InputStreamReader isr=new InputStreamReader(is);//字節--->字符轉換流--->最終是個字符//isr其實可以讀取中文啦，但是由于對面發送過來的是一行為單位的，isr無法讀取一行數據//為了讀取一行比較方便，再做一個包裝BufferedReader reader = new BufferedReader(isr);//包裝本身體現出來一種設計模式——————裝飾者模式 23//3.客戶端回寫點什么寫消息/輸出流對象OutputStream os = socket.getOutputStream();PrintWriter writer=new PrintWriter(os);while (true){String value = reader.readLine();System.out.println("消息"+value);System.out.println("回寫點什么吧：");String mess=input.nextLine();writer.println(mess);writer.flush();}} catch (IOException e) {e.printStackTrace();}} } package server;import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.Scanner;public class TestServer {public static void main(String[] args) {try {System.out.println("===Server start===");//1.開啟一個服務//調用構造方法，缺少參數//沒法構造對象，接口/抽象類//類中構造方法雖然有，但是都是private（私有化），提供的都是類似工廠一樣的方法//構建對象的時候，出現了編譯時異常// ArrayIndexOutofBoundsException// NullPointerException// InputMisMatchException// NumberFormatException// ArithmeticException// ClassCastException// StringIndexOutOfBoundsExceptionServerSocket server=new ServerSocket(9999);//0——65535//服務器開發的端口號，為了讓客戶的數據從這個端口進入到服務器來的//2.開啟服務之后，等待某一個客戶端過來訪問我，需要服務器統一/接收Socket socket = server.accept();System.out.println("有一個客戶端跟我連接成功啦");//================================================================Scanner input=new Scanner(System.in);//3.先讓服務器跟客戶端說一句話————寫消息/輸出流//不是自己隨意創建的輸出流，得通過socket來獲取OutputStream os = socket.getOutputStream(); //流(讀 I/寫O）字節/字符（Reader、Writer）//上述os對象可以寫消息了，但是os是一個字節流，發送中文的時候不方便//字節流進行一個包裝---->字符流PrintWriter writer=new PrintWriter(os);//4.服務器讀取回寫的消息讀信息/輸入流對象InputStream is = socket.getInputStream();InputStreamReader isr=new InputStreamReader(is);BufferedReader reader=new BufferedReader(isr);while(true){//4.可以發送數據啦System.out.println("說點什么吧：");String mess = input.nextLine();writer.println(mess);writer.flush();//刷新清空流管道String value = reader.readLine();System.out.println("消息："+value);}} catch (IOException e) {e.printStackTrace();}} }

三、客戶端發起聊天

四、完成客戶端界面交互

優化代碼

package frame;import javax.swing.*;//只是發現以后所有的框都是按照剛才那套流程畫出來的 //只不過具體的組件，位置，布局都不一樣，但是需要做的事情抽象來看都是一樣的 //設計一個抽象的規則//模板方法模式 23個設計模式當中的一個//還有一種是：缺省適配器模式 MyFrame（接口 10個） baseFrame（挑一些不重要的實現掉{} 子類去實現一些必要的方法） public abstract class BaseFrame extends JFrame {public BaseFrame(String title){super(title);}protected abstract void setOther();protected abstract void addElements();protected abstract void addListener();protected abstract void setSelf(); } package frame;import javax.swing.*; import java.awt.*; import java.io.*; import java.net.Socket; import java.text.DateFormat; import java.text.FieldPosition; import java.text.ParsePosition; import java.text.SimpleDateFormat; import java.util.Date;//簡單梳理一下關于Swing的技術 //GUI 圖形用戶接口（規則） Client/Server //GUI下面有兩個接口：AWT Swing。可以做但很少用來基于Browser/Server HTML <html></html> //想要利用Swing技術來實現一個窗口的繪制 //里面有JFrame窗體可看成類似于<body> //還有JPanel面板可看成類似于<div><span> 無色透明的容器做布局管理 //各種組件按鈕文本框文本域理解為HTMl中那些<input type="button"> //JButton按鈕 JTextField //最終肯定是需要有功能事件-方法 HTML（布局）+CSS（樣式）+JS（事件） Tomcat //事件背后才是我們真正需要實現的強大邏輯/功能//============================================================ //需要自己描述一個類 //可能需要描述屬性，方法 //類與類的關系 //繼承泛化（實現） A is a B // 聚合組合 A has-a B // 包含依賴 A use-a B public class QQFrame extends BaseFrame{//是一個窗口類和類之間的關系 A is-a B 繼承//構造方法里面可以放這三個方法，或者這三個方法可以放在代碼塊，讓它在構造方法之前加載public QQFrame(String uid){super(uid);this.uid=uid;//1.真的跟服務器產生一個連接this.start();//2.調用里面的方法this.setOther();this.addElements();this.addListener();this.setSelf();}//1.需要一個窗體/窗口private JFrame frame=new JFrame("聊天框");//GC 邊界管理//2.需要一個無色透明的容器--面板private JPanel panel=new JPanel();// 流式管理可以有多個//3.需要一些聊天窗口的組件//這是兩個帶滾動條的文本域private JTextArea messArea=new JTextArea();private JScrollPane messPane=new JScrollPane(messArea);//滾動條范圍大，里面是包著文本域的private JTextArea sendArea=new JTextArea();private JScrollPane sendPand=new JScrollPane(sendArea);//兩個按鈕private JButton sendButton=new JButton("發送");private JButton cancelButton=new JButton("取消");//設計一個方法做一些設置布局字體。。@Overrideprotected void setOther(){//4.為了讓布局更好的好看一點，我們采用一個自動布局的方式// 自定義布局需要將原有的布局清空panel.setLayout(null);//所有的組件按照自己的設計位置放置messPane.setBounds(10, 10, 320, 220);sendPand.setBounds(10, 240, 320, 140);sendButton.setBounds(180, 390, 60, 30);cancelButton.setBounds(260, 390, 60, 30);//設置上面接收框的信息不能更改messArea.setEnabled(false);//設置文本域中字體的效果messArea.setFont(new Font("黑體", Font.BOLD,18));sendArea.setFont(new Font("黑體", Font.BOLD,18));}//設計一個方法做一些組件之間的相互添加@Overrideprotected void addElements(){//5.將這些組件放在panel里，panel放在frame里panel.add(messPane);panel.add(sendPand);panel.add(sendButton);panel.add(cancelButton);this.add(panel);}//設計一個方法給窗口中的某些組件添加事件@Overrideprotected void addListener(){//給取消按鈕綁定一個事件---對象（幫你去做）觀察者模式Observer 按鈕-目標做事-觀察者對象cancelButton.addActionListener(e->{sendArea.setText("");});//給發送按鈕綁定一個事件---sendButton.addActionListener(e -> {try {PrintWriter writer=new PrintWriter(socket.getOutputStream());String message = sendArea.getText();//獲取一個系統當前時間Date date=new Date();DateFormat df=new SimpleDateFormat("yyyy-MM-dd kk:mm:ss");String time = df.format(date);writer.println(time+"##@##"+uid+":"+message);//客戶端真正發送的消息writer.flush();//發送框文字清空sendArea.setText("");} catch (IOException e1) {e1.printStackTrace();}});}//設計一個方法用來做窗體自己的一些設置初始位置不可拖拽@Overrideprotected void setSelf(){//需要在創建出來的同時，設置一下窗口的展示this.setBounds(500, 200, 350, 480);//可以設置窗口不可以拖拽改變大小this.setResizable(false);//設置點擊右上角關閉按鈕的同時，讓程序結束this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// private static final int xxx=3;//其實窗口已經創建出來了，默認效果是隱藏的//需要設置那個窗口的狀態隱藏--->顯示//面向對象窗口的狀態-----對象的屬性// 設置狀態----事情----方法 setXXXXthis.setVisible(true);}//=============================================================================//因為當前的QQFrame就是那個客戶端，// 所以客戶端需要有一個uidprivate String uid;//所以客戶端需要一個socketprivate Socket socket;//====================================================public void start(){try {//1.主動訪問服務端socket=new Socket("127.0.0.1",9999);//2.客戶端將自己的uid寫給服務器PrintWriter writer=new PrintWriter(socket.getOutputStream());writer.println(uid);writer.flush();//3.將socket分別交給兩個小弟，讀/寫ClientReader cr=new ClientReader();cr.start();} catch (IOException e) {e.printStackTrace();}}//====================================================//客戶端讀線程（剩下的那個小弟）---只管客戶端自己用//1.不想讓別人看見我客戶端自己不干活，還有一個小弟幫我//2.節省一個類文件//3.客戶端讀線程，讀取的數據不是在控制臺展示的，是需要展示在客戶端的文本域中// 最主要才是這個問題，內部類中直接使用外部類成員private class ClientReader extends Thread{//頻繁的追加新的字符串，不能讓聊天框中的文字清空StringBuilder result=new StringBuilder();@Overridepublic void run(){//讀取try {InputStream is=socket.getInputStream();InputStreamReader isr=new InputStreamReader(is);BufferedReader reader=new BufferedReader(isr);//可以讀取一行while (true){String value=reader.readLine();//time##@##uid:messagevalue.replace("##@##", "\r\n");result.append(value);result.append("\n");//找到那個文本域，value放里即可messArea.setText(result.toString());}} catch (IOException e) {//e.printStackTrace();System.out.println("服務器宕機啦");}}}} package frame;import frame.QQFrame;public class TestClient {public static void main(String[] args) {//1.創建客戶端new QQFrame("zzt");new QQFrame("dmc");new QQFrame("Ella");} // public static void main(String[] args) { // try { // System.out.println("我是客戶端"); // //1.主動訪問服務端，訪問成功后，即連接成功，獲取一個socket對象 // Socket socket=new Socket("127.0.0.1",9999);//服務器地址（IP）服務器開放的端口號（port） // System.out.println("我成功連接到服務器啦？"); // //====================================== // Scanner input=new Scanner(System.in); // // //2.讀取服務器發送過來的消息讀消息/輸入流對象 // //不能自己創建，需要通過socket對象來回去 // InputStream is = socket.getInputStream(); // //is其實可以拿去讀取消息，is是一個字節型輸入流 // //為了讀取字符更加方便，做一個包裝 // InputStreamReader isr=new InputStreamReader(is);//字節--->字符轉換流--->最終是個字符 // //isr其實可以讀取中文啦，但是由于對面發送過來的是一行為單位的，isr無法讀取一行數據 // //為了讀取一行比較方便，再做一個包裝 // BufferedReader reader = new BufferedReader(isr);//包裝本身體現出來一種設計模式——————裝飾者模式 23 // //3.客戶端回寫點什么寫消息/輸出流對象 // OutputStream os = socket.getOutputStream(); // PrintWriter writer=new PrintWriter(os); // // while (true){ // String value = reader.readLine(); // System.out.println("消息"+value); // // System.out.println("回寫點什么吧："); // String mess=input.nextLine(); // writer.println(mess); // writer.flush(); // } // } catch (IOException e) { // e.printStackTrace(); // } // // } } package server;import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import java.util.HashMap;//服務器類 public class Server {//屬性集合----Map<String,User>static HashMap<String,User> userBox=new HashMap();public void start(int port){try {System.out.println("====server start===");ServerSocket server=new ServerSocket(port);while (true){//服務器開啟，一直等待客戶端Socket socket = server.accept();//將socket對象存入map集合//讀取客戶端發來的Uid 服務端可以獲取socket，但是沒有Uid（客戶端發送過來）//<Uid,User(Uid,Socket)>InputStream is = socket.getInputStream();InputStreamReader isr=new InputStreamReader(is);BufferedReader reader=new BufferedReader(isr);String uid = reader.readLine();//構建一個User對象User user=new User(uid, socket);userBox.put(uid, user);System.out.println(uid+"成功連接到服務器啦");//將這個socker交給一個小弟來負責處理ServerThread st=new ServerThread(user);st.start();}} catch (IOException e) {e.printStackTrace();}} } package server;import java.io.*; import java.util.Iterator; import java.util.Map; import java.util.Set;//服務端線程 public class ServerThread extends Thread{private User user;public ServerThread(User user){this.user=user;}@Overridepublic void run(){try {//1.讀取剛才那個socket客戶端發送過來的數據InputStream is = user.getSocket().getInputStream();InputStreamReader isr=new InputStreamReader(is);BufferedReader reader=new BufferedReader(isr);while (true){//服務器從客戶端那里讀取過來的真實數據/消息String message =reader.readLine();System.out.println("接收到"+user.getUid()+"xxx發送過來的"+message);//2.將數據轉發給其他socket對應的客戶端------群聊 map遍歷 User(socket)//想要轉發出去，需要找到那個mapMap<String,User> map=Server.userBox;//<uid,user>//將map集合遍歷，獲取里面全部的user，拿到每一個user里面的socket--->Set keySet = map.keySet();Iterator it = keySet.iterator();while (it.hasNext()){String uid= (String)it.next();User user=map.get(uid);PrintWriter pw=new PrintWriter(user.getSocket().getOutputStream());pw.println(message);pw.flush();}}} catch (IOException e) {//e.printStackTrace();System.out.println(user.getUid()+"下線啦");}} } package server;public class TestServer {public static void main(String[] args) {//1.啟動一個服務Server server=new Server();//2.啟動即可server.start(9999);} // public static void main(String[] args) { // try { // System.out.println("===Server start==="); // //1.開啟一個服務 // //調用構造方法，缺少參數 // //沒法構造對象，接口/抽象類 // //類中構造方法雖然有，但是都是private（私有化），提供的都是類似工廠一樣的方法 // //構建對象的時候，出現了編譯時異常 // // ArrayIndexOutofBoundsException // // NullPointerException // // InputMisMatchException // // NumberFormatException // // ArithmeticException // // ClassCastException // // StringIndexOutOfBoundsException // ServerSocket server=new ServerSocket(9999);//0——65535//服務器開發的端口號，為了讓客戶的數據從這個端口進入到服務器來的 // //2.開啟服務之后，等待某一個客戶端過來訪問我，需要服務器統一/接收 // Socket socket = server.accept(); // System.out.println("有一個客戶端跟我連接成功啦"); // //================================================================ // // Scanner input=new Scanner(System.in); // // //3.先讓服務器跟客戶端說一句話————寫消息/輸出流 // //不是自己隨意創建的輸出流，得通過socket來獲取 // OutputStream os = socket.getOutputStream(); //流(讀 I/寫O）字節/字符（Reader、Writer） // //上述os對象可以寫消息了，但是os是一個字節流，發送中文的時候不方便 // //字節流進行一個包裝---->字符流 // PrintWriter writer=new PrintWriter(os); // // // //4.服務器讀取回寫的消息讀信息/輸入流對象 // InputStream is = socket.getInputStream(); // InputStreamReader isr=new InputStreamReader(is); // BufferedReader reader=new BufferedReader(isr); // // while(true){ // //4.可以發送數據啦 // System.out.println("說點什么吧："); // String mess = input.nextLine(); // writer.println(mess); // writer.flush();//刷新清空流管道 // // String value = reader.readLine(); // System.out.println("消息："+value); // } // } catch (IOException e) { // e.printStackTrace(); // } // // // // } } package server;import java.net.Socket;//服務器端自己創建的一個類型 //目的：為了將一個用戶名和這個用戶對應的socket對象包括包裝在一起 //每一個User對象，其實就是一個存儲數據的容器 public class User {private String uid;private Socket socket;public User(String uid, Socket socket) {this.uid = uid;this.socket = socket;}public String getUid() {return uid;}public Socket getSocket() {return socket;} }

總結

以上是生活随笔為你收集整理的创建专属聊天室练习（客户端与服务端通信|客户端界面交互）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： tableau 倒序都倒了_Tablea
下一篇： html表单作业练习