溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要為大家展示了Java如何模擬UDP通信，內容簡而易懂，希望大家可以學習一下，學習完之后肯定會有收獲的，下面讓小編帶大家一起來看看吧。
Java基礎：模擬UDP通信
// 發送端，不需要連接服務器 public class UdpClientDemo { public static void main(String[] args) throws Exception { // 1. 發送數據包需要一個Socket DatagramSocket 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(); } }
// 接收端，接收端需要保證存在，否則接收不到，所以需要提前開啟
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());
}
}一方多次發送，一方多次接收，加上一個 while(true) {} 死循環，并規定在什么情況下退出即可。
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();
}
}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();
}
}模擬雙方使用UDP通信，需要開啟兩個線程，并對以上代碼進行【共性提取】，進一步進行抽象。
由此，雙方可以通過指定的端口來互相發送消息。
// 開啟多線程需要實現 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();
}
}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();
}
}// 學生端
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();
}
}// 教師端
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();
}
}以上就是關于Java如何模擬UDP通信的內容，如果你們有學習到知識或者技能，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
