UDP群聊

客戶端


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 ClientOneToMany_ClientFrame 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 {ClientOneToMany_ClientFrame frame = new ClientOneToMany_ClientFrame();frame.setVisible(true);frame.createClientSocket();} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try {Socket socket = new Socket("127.0.0.1", 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);// 清空文本框}/*** Create the frame*/public ClientOneToMany_ClientFrame() {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);//}}

?服務端


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;public class ClientOneToMany_ServerFrame extends JFrame {private JTextArea ta_info;private ServerSocket server; // 聲明ServerSocket對象private Socket socket; // 聲明Socket對象socketprivate Vector<Socket> vector = new Vector<Socket>();// 用于存儲連接到服務器的客戶端套接字對象public void createSocket() {try {server = new ServerSocket(1978);while (true) {ta_info.append("等待新客戶連接......\n");socket = server.accept();// 創建套接字對象vector.add(socket);// 將套接字對象添加到向量對象中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();// 讀取信息for (Socket s : vector) {// 遍歷所有客戶端套接字對象if (s != socket) {// 如果不是發送信息的套接字對象PrintWriter out = new PrintWriter(s.getOutputStream(), true);// 創建輸出流對象out.println(info);// 發送信息out.flush();// 刷新輸出緩沖區}}}} catch (IOException e) {ta_info.append(socket + "已經退出。\n");vector.remove(socket);// 移除退出的客戶端套接字}}}/*** Launch the application* * @param args*/public static void main(String args[]) {ClientOneToMany_ServerFrame frame = new ClientOneToMany_ServerFrame();frame.setVisible(true);frame.createSocket();}/*** Create the frame*/public ClientOneToMany_ServerFrame() {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);}}

結果?

第二類

服務端

 import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class Server{public static ServerSocket server_socket;public static ArrayList<Socket> socketList=new ArrayList<Socket>();  public static void main(String []args){try{server_socket = new ServerSocket(5000);while(true){Socket socket = server_socket.accept();socketList.add(socket); //把sock對象加入sock集合ServerBO_Thread st=new ServerBO_Thread(socket,socketList); //初始化多線程st.start();//啟動多線程}}catch(Exception ex){ex.printStackTrace();}finally{try{if(server_socket!=null){server_socket.close();}}catch(Exception ex){ex.printStackTrace();}}}public void encryptWrite(String src,DataOutputStream output)throws IOException{//將一個字符串轉化為字符數組//System.out.println(src);char[] char_arr = src.toCharArray();//加密操作for(int i = 0;i<char_arr.length;i++){output.writeChar(char_arr[i]+13);}//用作結束標志符output.writeChar(2333);output.flush();}//讀取并解密public String readDecrypt(DataInputStream input)throws IOException{String rtn="";while(true){int char_src =input.readChar();if(char_src!=2333){rtn=rtn+(char)(char_src-13);}else{break;}}return rtn;}
}
class ServerBO_Thread extends Thread{Socket client = null;ArrayList<Socket> clients;ServerBO_Thread(Socket s,ArrayList<Socket> ss){//初始化client=s;clients=ss; }public void run(){DataInputStream input = null;DataOutputStream output =null;try{input = new DataInputStream(client.getInputStream());Server bo = new Server();String receive=null;String send=null;while(true){//監視當前客戶端有沒有發來消息if(!client.isClosed()){receive=bo.readDecrypt(input);clients.trimToSize();String[] param = receive.split("&");if(")start".equals(param[1])){    //分析客戶端發來的內容send = param[0]+"進入聊天室";}else{send = param[0]+"說:    "+param[1];}if(!("3333".equals(param[1]))){//3333為退出聊天室信號for(Socket socket:clients){ //遍歷socke集合 //把讀取到的消息發送給各個客戶端  if(!socket.isClosed()){output = new DataOutputStream(socket.getOutputStream());bo.encryptWrite(send,output);}}  }else{//如果有客戶端退出for(Socket socket:clients){ //遍歷socke集合 if(socket!=client){//告訴其他人此人退出聊天室if(!(socket.isClosed())){output = new DataOutputStream(socket.getOutputStream());bo.encryptWrite(param[0]+"已退出聊天室",output);}}}output = new DataOutputStream(client.getOutputStream());bo.encryptWrite("3333",output);//返回信號給要退出的客戶端，然后關閉線程client.close();input.close();output.close();}}else{break;}}}catch(Exception ex){ex.printStackTrace();}}
}

客戶端

 
import java.io.IOException;
import java.util.Scanner;
import java.net.*;
import java.io.*;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import java.io.DataOutputStream;
public class People{
//服務端ippublic  String ip = "127.0.0.1";//服務端端口public  int port = 5000;public  DataOutputStream output = null;public  Socket socket = null;public  DataInputStream input = null;public  Scanner sc =new Scanner (System.in);public  String send ;public  String receive;public  String name;public String sd = null;public static void main(String[]aa){People po = new People();po.start();}public void start(){try{System.out.println("*******歡迎使用匿名聊天室！**********");System.out.println("請輸入你將要使用的昵稱：");name=sc.nextLine();//獲取昵稱socket = new Socket(ip,port);output=new DataOutputStream(socket.getOutputStream());input = new DataInputStream(socket.getInputStream());send = name+"&)start";//把昵稱發送到server 告訴所有人有新成員加入聊天室System.out.println("(如果要退出聊天室請輸入“3333”！)");System.out.println("*******成功進入匿名聊天室！**********");System.out.println("");encryptWrite(send,output);Out out=new Out(output,name,input,socket);out.start();//啟動發送聊天內容的多線程while(true){    String receive = readDecrypt(input);if("3333".equals(receive)){//如果收到“3333”則退出聊天室System.out.println("*******成功退出匿名聊天室！**********");input.close();output.close();socket.close();System.exit(0);}System.out.println(receive);}}catch(Exception ex){ex.printStackTrace();}finally{try{if(socket!=null) socket.close();input.close();output.close();}catch(Exception ex){ex.printStackTrace();}}    }public void encryptWrite(String src,DataOutputStream output)throws IOException{//將一個字符串轉化為字符數組char[] char_arr = src.toCharArray();//加密操作for(int i = 0;i<char_arr.length;i++){output.writeChar(char_arr[i]+13);}//用作結束標志符output.writeChar(2333);output.flush();}//讀取并解密public String readDecrypt(DataInputStream input)throws IOException{String rtn="";while(true){int char_src =input.readChar();if(char_src!=2333){rtn=rtn+(char)(char_src-13);}else{break;}}return rtn;}
}
class Out extends Thread {public DataOutputStream output;public DataInputStream input;public static String name;public Socket socket;public  Scanner sc =new Scanner (System.in);Out(DataOutputStream ot,String n,DataInputStream it,Socket socket){output=ot;input=it;name=n;}public void run(){People po = new People();try{while(true){String send=sc.nextLine();//獲取用戶輸入String send2=name+"&"+send;//把聊天內容打包成約定形式po.encryptWrite(send2,output);}}catch(Exception ex){ex.printStackTrace();}finally{System.out.println("sfef");}}
}

結果

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/206809.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/206809.shtml
英文地址，請注明出處：http://en.pswp.cn/news/206809.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

LeetCode738. Monotone Increasing Digits

LeetCode738. Monotone Increasing Digits

文章目錄 一、題目二、題解 一、題目 An integer has monotone increasing digits if and only if each pair of adjacent digits x and y satisfy x < y. Given an integer n, return the largest number that is less than or equal to n with monotone increasing digi…
閱讀更多...
使用VBA快速統計詞組（單詞組合）詞頻

使用VBA快速統計詞組（單詞組合）詞頻

實例需求&#xff1a;產品清單如A列所示&#xff0c;現在如下統計詞組詞頻。想必各位小伙伴都指定如何使用字典對象實現去重&#xff0c;進而實現單個單詞的詞頻統計。 但是統計詞組詞頻就沒有那么簡單了&#xff0c;為了便于演示&#xff0c;此處的詞組只限于兩個單詞的組合。…
閱讀更多...
自動駕駛右向輔助功能規范

自動駕駛右向輔助功能規范

目 錄 Contents 目錄 1. 介紹 Introduction. 8 1.1 此文檔的范圍和目的 Scope and Purpose of This Document 8 1.2 參考文檔References. 9 1.3 文檔的維護 Maintenance of the Document 10 1.4 縮略詞Abbreviations. 10 1.5 文檔概述Document Overview.. 11 1.6 功能…
閱讀更多...
GoLong的學習之路，進階，Viper（yaml等配置文件的管理）

GoLong的學習之路，進階，Viper（yaml等配置文件的管理）

本來有今天是繼續接著上一章寫微服務的。但是這幾天有朋友說&#xff0c;再寫Web框架的時候&#xff0c;遇到一個問題&#xff0c;就是很多的中間件&#xff08;redis&#xff0c;微信&#xff0c;mysql&#xff0c;mq&#xff09;的配置信息寫的太雜了&#xff0c;很不好管理。…
閱讀更多...
【解決辦法】Pycharm中新添加或者導入項目文件名紅色！

【解決辦法】Pycharm中新添加或者導入項目文件名紅色！

提示&#xff1a;文章寫完后&#xff0c;目錄可以自動生成&#xff0c;如何生成可參考右邊的幫助文檔 文章目錄 一、問題描述二、問題原因三、解決辦法 一、問題描述 Pycharm的代碼中添加新的文件夾&#xff0c;發現文件夾下的文件名是紅色的&#xff0c;如下圖&#xff1a; …
閱讀更多...
jvm-sandbox-repeater 精簡版部署之standalone模式

jvm-sandbox-repeater 精簡版部署之standalone模式

jvm-sandbox-repeater 僅僅提供了錄制回放的能力&#xff0c;如果需要完成業務回歸、實時監控、壓測等平臺&#xff0c;后面須要有一個數據中心負責采集數據的加工、存儲、搜索&#xff0c;repeater-console提供了簡單的demo示例&#xff1b;一個模塊管理平臺負責管理JVM-Sandb…
閱讀更多...
設計模式——單例模式（Singleton Pattern）

設計模式——單例模式（Singleton Pattern）

概述 單例模式確保一個類只有一個實例&#xff0c;而且自行實例化并向整個系統提供整個實例&#xff0c;這個類稱為單例類&#xff0c;它提供全局訪問的方法。單例模式是一種對象創建型模式。單例模式有三個要點&#xff1a;一是某個類只能有一個實例&#xff1b;二是它必須自行…
閱讀更多...
矩陣基本操作算法

矩陣基本操作算法

題目描述&#xff1a; 題目描述 根據主函數和頭文件提示&#xff0c;編寫子函數void matrixInput(int (*mat)[COL]); void matrixPrint(int *mat[ROW]); void matrixAddT(int *mat); ? 分別實現矩陣的輸入&#xff0c;輸出&#xff0c;與自身的轉置相加&#xff1a;void matr…
閱讀更多...
微信小程序開發中的圖片缺少后自動居中問題的解決，自動居中樣式，自適應圖片多少的寫法

微信小程序開發中的圖片缺少后自動居中問題的解決，自動居中樣式，自適應圖片多少的寫法

下面是寫的wxml的view樣式類似于web開發中的HTML文件 home-grid是我創建的一個父樣式&#xff0c;采用子絕父相的定位方式 我在home-grid的父view&#xff08;類似于web中div&#xff09;中包含了三個小的子樣式分別是下述代碼中的class“yellowstar”&#xff0c;class“maint…
閱讀更多...
Java---線程講解（二）

Java---線程講解（二）

文章目錄 1. Runnable接口2. 賣票案例3. 同步代碼塊解決數據安全問題4. 同步方法解決數據安全問題5. 線程安全的類6. Lock鎖 1. Runnable接口 1. 創建線程的另一種方法是聲明一個實現Runnable接口的類&#xff0c;之后重寫run()方法&#xff0c;然后可以分配類的實例&#xff0…
閱讀更多...
基于remix+metamask+ganache的智能合約部署調用

基于remix+metamask+ganache的智能合約部署調用

在我們部署合約時為了讓它更接近真實區塊鏈去中心化體驗&#xff0c;我們需要調用小狐貍&#xff08;Metamask&#xff09;來進行真實交易&#xff0c;而metamask里沒有內置虛擬測試幣&#xff0c;我們需要進行調用Ganache來添加帶有虛擬測試幣的賬號。以上就是三者的關系&…
閱讀更多...
從 MLOps 到 LMOps 的關鍵技術嬗變

從 MLOps 到 LMOps 的關鍵技術嬗變

本文整理自 2023 年 9 月 3 日 QCon 全球軟件開發大會 2023 北京站 —— 從 MLOps 到 LMOps 分論壇的同名主題演講。 本次分享的內容結構如下&#xff1a; 從 MLOps 到 LMOps&#xff1b; MLOps 概述、挑戰與解決方案&#xff1b; LMOps 實施挑戰與關鍵技術&#xff08;大模…
閱讀更多...
[FPGA 學習記錄] 快速開發的法寶——IP核

[FPGA 學習記錄] 快速開發的法寶——IP核

快速開發的法寶——IP核 文章目錄 1 IP 核是什么2 為什么要使用 IP 核3 IP 核的存在形式4 IP 核的缺點5 Quartus II 軟件下 IP 核的調用6 Altera IP 核的分類 在本小節當中&#xff0c;我們來學習一下 IP 核的相關知識。 IP 核在 FPGA 開發當中應用十分廣泛&#xff0c;它被稱為…
閱讀更多...
Java最全面試題專題---1、Java基礎知識（2）

Java最全面試題專題---1、Java基礎知識（2）

筆者有七八年的面試者經驗&#xff0c;負責公司技術同學的社招和校招&#xff0c;近些年面試過三四百個技術同學&#xff0c;考慮接近年底這個時段&#xff0c;整理并更新一些以往的面試經驗&#xff0c;希望同學們跳槽能有個更好的工作&#xff0c;如有需要的同學可以關注下筆…
閱讀更多...
Jenkins安裝

Jenkins安裝

環境 Ubuntu&#xff0c; 其他平臺查看官方文檔 步驟 安裝jdk sudo apt-get install openjdk-8-jdk 安裝Jenkins first add the key to your system wget -q -O - https://pkg.jenkins.io/debian/jenkins.io.key | sudo apt-key add -Then add a Jenkins apt repository …
閱讀更多...
使用Golang構建高性能網絡爬蟲

使用Golang構建高性能網絡爬蟲

目錄 一、Golang的特點 二、構建網絡爬蟲的步驟 三、關鍵技術和注意事項 使用協程進行并發處理 使用通道進行協程間的通信 合理控制并發數和處理速度 遵守網站使用協議和法律法規 防止被網站封禁或限制訪問 優化網頁解析和數據處理 異常處理和錯誤處理 日志記錄和監控…
閱讀更多...
Flink入門之部署（二）

Flink入門之部署（二）

三種部署模式 standalone集群&#xff0c;會話模式部署&#xff1a;先啟動flink集群 web UI提交shell命令提交&#xff1a;bin/flink run -d -m hadoop102:8081 -c com.atguigu.flink.deployment.Flinke1_NordCount./Flink-1.0-SNAPSHOT.jar --hostname hadoop102 --port 8888 …
閱讀更多...
vmware虛擬機17 安裝macos14過程及問題處理親測

vmware虛擬機17 安裝macos14過程及問題處理親測

前期準備 1、可引導可虛擬機安裝的macOS Sonoma 14 ISO鏡像安裝文件 我找到得地址&#xff0c;下載自行解決啦 2、VMware虛擬機應用軟件 官網下載就好&#xff0c;搜個碼搞定 3、解鎖工具macOS Unlocker 開始安裝&#xff1a; 1、打開VMware軟件&#xff0c;新建一個系統…
閱讀更多...
API集錦：免費好用的API接口

API集錦：免費好用的API接口

通用文字識別OCR&#xff1a;多場景、多語種、高精度的整圖文字檢測和識別服務&#xff0c;多項指標行業領先&#xff0c;可識別中、英、日、韓、法、德多種語言。 二維碼識別OCR&#xff1a;對圖片中的二維碼、條形碼進行檢測和識別&#xff0c;返回存儲的文字內容。 手機號…
閱讀更多...
Bert-vits2新版本V2.1英文模型本地訓練以及中英文混合推理(mix)

Bert-vits2新版本V2.1英文模型本地訓練以及中英文混合推理(mix)

中英文混合輸出是文本轉語音(TTS)項目中很常見的需求場景&#xff0c;尤其在技術文章或者技術視頻領域里&#xff0c;其中文文本中一定會夾雜著海量的英文單詞&#xff0c;我們當然不希望AI口播只會念中文&#xff0c;Bert-vits2老版本(2.0以下版本)并不支持英文訓練和推理&…
閱讀更多...
最新文章

Copyright @ 2022~2023