国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

java 多線程實現在線咨詢(udp)

瀏覽:2日期:2022-08-20 17:58:51

在線咨詢:兩個人都可以是發送方,也可以是接收方,實現網上在線咨詢正常通信。

聊天發送線程

package chat;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetSocketAddress;import java.net.SocketException;/** * 聊天發送線程: * 重寫 run 方法通過 implements 關鍵字實現 Runnable 接口 * 重寫方法快捷鍵:Ctrl + O */public class TalkSend implements Runnable { DatagramSocket socket = null; BufferedReader reader = null; private int fromPort; //從哪個端口 private String toIP; //到哪個地址 private int toPort; //到哪個端口 //構造:Alt + Insert public TalkSend(int fromPort, String toIP, int toPort) { this.fromPort = fromPort; this.toIP = toIP; this.toPort = toPort; //快捷鍵:Ctrl + Alt + T try { //構造一個數據報套接字并將其綁定到本地主機上的指定端口 socket = new DatagramSocket(fromPort); //準備數據:控制臺讀取:System.in reader = new BufferedReader(new InputStreamReader(System.in)); } catch (SocketException e) { e.printStackTrace(); } } @Override public void run() { while (true){ try { String data = reader.readLine(); byte[] dataBytes = data.getBytes(); DatagramPacket packet = new DatagramPacket(dataBytes, 0 , dataBytes.length, new InetSocketAddress(this.toIP, this.toPort)); //發送數據包 socket.send(packet); //當發送一句 bye 的時候表示結束發送 if (data.equals('bye')){ break; } } catch (IOException e) { e.printStackTrace(); } } //關閉 socket.close(); }}

聊天接收線程

package chat;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.SocketException;/** * 聊天接收線程: * 重寫 run 方法通過 implements 關鍵字實現 Runnable 接口 * 重寫方法快捷鍵:Ctrl + O */public class TalkReceive implements Runnable { DatagramSocket socket = null; private int port; private String msgFrom; //構造 public TalkReceive(int port, String msgFrom) { this.port = port; this.msgFrom = msgFrom; try { socket = new DatagramSocket(port); } catch (SocketException e) { e.printStackTrace(); } } @Override public void run() { while (true){ try { //準備接收數據包 byte[] container = new byte[1024]; DatagramPacket packet = new DatagramPacket(container, 0, container.length); //接收數據包 socket.receive(packet); //阻塞式接收包裹 //讀取數據 byte[] data = packet.getData(); String receiveData = new String(data, 0, data.length); //接收到的數據 System.out.println(msgFrom + ':' + receiveData); //當我們說一聲 bye 的時候就表示斷開連接 if (receiveData.equals('bye')){ break; } } catch (IOException e) { e.printStackTrace(); } } //關閉 socket.close(); }}

學生端

package chat;/** * 學生端 */public class TalkStudent { public static void main(String[] args) { /** * 學生端 * 從 7777 端口發送消息 * 發送消息到 9999 端口 * 從 8888 端口接收消息 * * 開啟兩個線程: * new TalkSend:從 77777 端口發送,發送到 localhost,發送給 9999 端口 * @param fromPort * @param toIP * @param toPort * * new TalkReceive:從 8888 端口接收,接收來自 “老師” 的消息 * @param port * @param msgFrom * * 使用了一種模式:靜態代理模式 */ new Thread(new TalkSend(7777, 'localhost', 9999)).start(); new Thread(new TalkReceive(8888, '老師')).start(); }}

老師端

package chat;/** * 老師端 */public class TalkTeacher { public static void main(String[] args) { /** * 老師端 * 從 5555 端口發送消息 * 發送消息到 8888 端口 * 從 9999 端口接收消息 * * 開啟兩個線程: * new TalkSend:從 5555 端口發送,發送到 localhost,發送給 8888 端口 * @param fromPort * @param toIP * @param toPort * * new TalkReceive:從 9999 端口接收,接收來自 “學生” 的消息 * @param port * @param msgFrom * * 使用了一種模式:靜態代理模式 */ new Thread(new TalkSend(5555, 'localhost', 8888)).start(); new Thread(new TalkReceive(9999, '學生')).start(); }}

效果一覽

java 多線程實現在線咨詢(udp)

java 多線程實現在線咨詢(udp)

以上就是java實現的多線程實現在線咨詢(udp)的詳細內容,更多關于java 在線咨詢的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 波多野结衣在线观看高清免费资源 | 久久韩国| 草草影院永久在线观看 | 久久久久久久久久久观看 | 久久久久香蕉视频 | 亚洲精品98久久久久久中文字幕 | 国产精品成人自拍 | 久久久久久久久毛片精品 | 亚洲精品一区二区三区在线看 | fc2在线播放 | 欧美日韩精品一区二区三区视频 | 国产成人免费视频 | 国产精品黄网站 | 全黄性高视频 | 国产91九色刺激露脸对白 | 手机看片高清国产日韩片 | 成人午夜视频在线观 | 男同黄网站 | 亚洲rct中文字幕在线 | 国产一级一片免费播放视频 | 亚洲免费视频网 | 人与拘一级a毛片 | 日韩在线成人 | 99免费精品视频 | 免费永久在线观看黄网 | 久久免视频 | 九九精品视频在线 | 孕妇交 | 日韩亚洲欧美一区二区三区 | 久久黄色免费网站 | 国产成人精品永久免费视频 | 国产成人黄色 | 欧美俄罗斯一级毛片 | 日本理论片免费高清影视在线观看 | 国产在线观看一区精品 | 国产精品久久久久网站 | 草草伊人| 三级成人网 | 国产午夜人做人视频羞羞 | 九九视频精品全部免费播放 | 新版天堂资源中文在线 |