av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

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

Java模擬UDP通信示例代碼

瀏覽:6日期:2022-08-31 13:27:40

Java基礎:模擬UDP通信

1、一次發送,一次接收1.1、發送方

// 發送端,不需要連接服務器public class UdpClientDemo { public static void main(String[] args) throws Exception {// 1. 發送數據包需要一個SocketDatagramSocket socket = new DatagramSocket();// 1.2 建立一個包String msg = '你好';InetAddress localhost = InetAddress.getByName('localhost');System.out.println(localhost);int port = 8080;/*通過UDP發送消息,需要通過 包 來發送,--> DatagramPacket(),該方法有多種重載形式,以下使用參數列表最多的那個參數:- 要發送的 消息 的字節數組 - 從字節數組的哪個位置開始發送- 發送的長度- 對方的 IP地址- 對方的端口號 */DatagramPacket packet = new DatagramPacket(msg.getBytes(), 0, msg.getBytes().length, localhost, port);// 2. 發送數據包socket.send(packet);socket.close(); }}1.2、接收方

// 接收端,接收端需要保證存在,否則接收不到,所以需要提前開啟public class UdpServerDemo { public static void main(String[] args) throws Exception {// 1. 接收也需要一個Socket,并且要開啟接收的端口DatagramSocket socket = new DatagramSocket(8080);// 需要一個字節數組來接收數據byte[] buffer = new byte[1024];// 1.2 封裝數據包DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);// 2. 接收數據,阻塞式接收:一直處于監聽狀態socket.receive(packet);// 關閉套接字socket.close();// 輸出一下System.out.println(packet.getAddress().getHostAddress());// trim():為了去除多余的空格System.out.println(new String(packet.getData()).trim()); }}2、多次發送,多次接收

一方多次發送,一方多次接收,加上一個 while(true) {} 死循環,并規定在什么情況下退出即可。

2.1、發送方

public class ChatSenderDemo { public static void main(String[] args) throws Exception {// 使用Socket來接收DatagramSocket socket = new DatagramSocket();while (true) { // 準備發送包裹,從鍵盤接收數據 BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); // 讀取一行 String data = reader.readLine(); byte[] dataBytes = data.getBytes(); DatagramPacket packet = new DatagramPacket(dataBytes, dataBytes.length, new InetSocketAddress('127.0.0.1', 6666)); // 發送 socket.send(packet); // 什么時候退出 if ('bye'.equals(data)) {break; }}// 關閉socket.close(); }}2.2、接收方

public class ChatReceiveDemo { public static void main(String[] args) throws Exception {DatagramSocket socket = new DatagramSocket(6666);while (true) { // 準備接收數據包裹 byte[] buffer = new byte[1024]; // 用來接收數據 DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length); // 接收包裹,阻塞時接收 socket.receive(packet); // 接收到的數據 String receiveData = new String(packet.getData()).trim(); // 打印到控制臺 System.out.println(receiveData); // 什么時候退出 if ('bye'.equals(receiveData)) {break; }}// 關閉socket.close(); }}3、模擬雙方通信

模擬雙方使用UDP通信,需要開啟兩個線程,并對以上代碼進行【共性提取】,進一步進行抽象。

由此,雙方可以通過指定的端口來互相發送消息。

3.1、發送方的線程

// 開啟多線程需要實現 Runnable 接口,實現 run()方法public class TalkSender implements Runnable { // 網絡套接字,發送需要 DatagramSocket socket = null; // 緩沖讀取流 BufferedReader reader = null; // 開啟哪個端口接收 private int fromPort; // 對方的 IP private String toIP; // 對方的端口 private int toPort; // 通過構造方法進行初始化 public TalkSender(int fromPort, String toIP, int toPort) {this.fromPort = fromPort;this.toIP = toIP;this.toPort = toPort;try { socket = new DatagramSocket(fromPort);} catch (SocketException e) { e.printStackTrace();} } // 重寫 run()方法,設置線程任務 @Override public void run() {while (true) { String data = null; try {// 準備發送包裹,從鍵盤接收數據reader = new BufferedReader(new InputStreamReader(System.in));// 讀取一行data = reader.readLine();byte[] dataBytes = data.getBytes();DatagramPacket packet = new DatagramPacket(dataBytes, dataBytes.length, new InetSocketAddress(toIP, toPort));socket.send(packet); } catch (IOException e) {e.printStackTrace(); } // 什么時候退出 if ('bye'.equals(data)) {break; }}// 關閉socket.close(); }}3.2、接收方的線程

public class TalkReveicer implements Runnable { DatagramSocket socket = null; // 從哪個端口接收 private int formPort; // 發送方是誰 private String who; public TalkReveicer(int formPort, String who) {this.formPort = formPort;this.who = who;try { socket = new DatagramSocket(formPort);} catch (SocketException e) { e.printStackTrace();} } @Override public void run() {while (true) { String receiveData = null; try {// 準備接收數據包裹byte[] buffer = new byte[1024];// 接收數據DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);// 接收數據,阻塞式socket.receive(packet);// 接收到的數據receiveData = new String(packet.getData());System.out.println(who + ':' + receiveData.trim()); } catch (IOException e) {e.printStackTrace(); } // 什么時候退出 if ('bye'.equals(receiveData)) {break; }}// 關閉socket.close(); }}3.3、模擬學生

// 學生端public class TalkStudent { public static void main(String[] args) {// 開啟 5555端口,發送到本機的 6666端口new Thread(new TalkSender(5555, 'localhost', 6666)).start();// 規定使用 7777 端口接收老師發送的消息new Thread(new TalkReveicer(7777, '老師')).start(); }}3.4、模擬老師

// 教師端public class TalkTeacher { public static void main(String[] args) {// 開啟 8888端口,發送到本機的 7777端口new Thread(new TalkSender(8888, 'localhost', 7777)).start();// 規定使用 6666 端口接收學生發送的消息new Thread(new TalkReveicer(6666, '學生')).start(); }}

總結:

使用UDP通信,其實主要的步驟分為三步:

1 用 DatagramSocket() 來開啟端口,通過開啟端口聊天。2 用DatagramPacket() 來發送或者接收數據。3 關閉 DatagramSocket,釋放資源。

以上就是Java模擬UDP通信示例代碼的詳細內容,更多關于Java模擬UDP通信的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 亚洲 欧美 日韩 在线 | 欧美精品久久久久 | 精品av | 国产精品爱久久久久久久 | 国色天香成人网 | 亚洲女人天堂成人av在线 | 日本精品一区二区在线观看 | 国内精品久久久久久久影视简单 | 免费网站国产 | 中文字幕一区二区三区精彩视频 | 九九热精品在线 | 婷婷久久一区 | 亚洲午夜精品久久久久久app | 久久精品欧美一区二区三区不卡 | 在线观看h视频 | 亚洲欧美中文日韩在线v日本 | 国产精品久久久久久婷婷天堂 | 亚洲精品久久久久久久久久久 | 国产大片一区 | 91玖玖| 欧美 日韩精品 | 天天插天天狠天天透 | 天堂一区| 精品一区二区电影 | 亚洲自拍一区在线观看 | 91精品国产91久久久久久吃药 | 国产91久久久久久久免费 | 精品国产伦一区二区三区观看说明 | 久久一二 | 国产二区三区 | 求毛片 | 国产91丝袜在线播放 | 91在线精品一区二区 | 91精品国产麻豆 | 日韩字幕一区 | 在线视频一区二区 | 免费超碰| 91欧美精品成人综合在线观看 | 日韩在线欧美 | 精品日本久久久久久久久久 | 在线亚洲欧美 |