溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
java 中模擬UDP傳輸的發送端和接收端實例詳解
一、創建UDP傳輸的發送端
1、建立UDP的Socket服務；
2、將要發送的數據封裝到數據包中；
3、通過UDP的Socket服務將數據包發送出去；
4、關閉Socket服務。
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPSend {
public static void main(String[] args) throws IOException {
System.out.println("發送端啟動......");
// 1、創建UDP的Socket，使用DatagramSocket對象
DatagramSocket ds = new DatagramSocket();
// 2、將要發送的數據封裝到數據包中
String str = "UDP傳輸演示：I'm coming!";
byte[] buf = str.getBytes(); //使用DatagramPacket將數據封裝到該對象的包中
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);
// 3、通過UDP的Socket服務將數據包發送出去，使用send方法
ds.send(dp);
// 4、關閉Socket服務
ds.close();
}
}
二、創建UDP傳輸的接收端
1、建立UDP的Socket服務，因為要接收數據，所以必須明確一個端口號；
2、創建數據包，用于存儲接收到的數據，方便用數據包對象的方法解析這些數據；
3、使用UDP的Socket服務的receive方法接收數據并存儲到數據包中；
4、通過數據包的方法解析這些數據；
5、關閉Socket服務。
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPReceive {
public static void main(String[] args) throws IOException {
System.out.println("接收端啟動......");
// 1、建立UDP的Socket服務
DatagramSocket ds = new DatagramSocket(10000);
// 2、創建數據包
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// 3、使用接收方法將數據存儲到數據包中
ds.receive(dp); // 該方法為阻塞式的方法
// 4、通過數據包對象的方法解析這些數據，例如：地址、端口、數據內容等
String ip = dp.getAddress().getHostAddress();
int port = dp.getPort();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":" + port + ":" + text);
// 5、關閉Socket服務
ds.close();
}
}
三、優化UDP傳輸的發送端和接收端
由于在前兩部分中，我們一次只能發送（或接收）一條消息，然后就關閉服務啦！因此如果我們想要發送多條消息，則需要不斷的在發送端修改發送的內容，并且還需要重新啟動服務器，比較麻煩。為了克服以上的缺點，我們可以對其進行優化，即：
1、在發送端，創建BufferedReader，從鍵盤錄入內容；
2、在接收端，添加while(ture)循環，不斷的循環接收內容。
/**
*優化UDP傳輸的發送端
*/
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPSend {
public static void main(String[] args) throws IOException {
System.out.println("發送端啟動......");
// 創建UDP的Socket，使用DatagramSocket對象
DatagramSocket ds = new DatagramSocket();
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while ((line = bufr.readLine()) != null) {
// 使用DatagramPacket將數據封裝到該對象的包中
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);
// 通過UDP的Socket服務將數據包發送出去，使用send方法
ds.send(dp);
// 如果輸入信息為over，則結束循環
if ("over".equals(line))
break;
}
// 關閉Socket服務
ds.close();
}
}
/**
*優化UDP傳輸的接收端
*/
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPReceive {
public static void main(String[] args) throws IOException {
System.out.println("接收端啟動......");
// 建立UDP的Socket服務
DatagramSocket ds = new DatagramSocket(10000);
while(true) {
// 創建數據包
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// 使用接收方法將數據存儲到數據包中
ds.receive(dp); // 該方法為阻塞式的方法
// 通過數據包對象的方法解析這些數據，例如：地址、端口、數據內容等
String ip = dp.getAddress().getHostAddress();
int port = dp.getPort();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":" + port + ":" + text);
}
}
}
四、創建聊天室
根據UDP（User Datagram Protocol， 用戶數據報協議）的相關性質，我們可以進一步創建一個簡單的基于UDP傳輸協議下的聊天室，實現互動聊天的功能。
/**
*創建UDP傳輸下的聊天室發送端
*/
package chat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Send implements Runnable {
private DatagramSocket ds;
public Send(DatagramSocket ds) {
this.ds = ds;
}
public void run() {
try {
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while ((line = bufr.readLine()) != null) {
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.255"), 10001);
ds.send(dp);
if ("886".equals(line))
break;
}
ds.close();
} catch (Exception e) {
System.out.println("對不起，發生錯誤啦！");
}
}
}
/**
*創建UDP傳輸下的聊天室接收端
*/
package chat;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Rece implements Runnable {
private DatagramSocket ds;
public Rece(DatagramSocket ds) {
this.ds = ds;
}
public void run() {
try {
while (true) {
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":::" + text);
if(text.equals("886")){
System.out.println(ip+"......退出聊天室！");
}
}
} catch (Exception e) {
System.out.println("對不起，發生錯誤啦！");
}
}
}
/**
*創建UDP傳輸下的聊天室
*/
package chat;
import java.io.IOException;
import java.net.DatagramSocket;
public class ChatRoom {
public static void main(String[] args) throws IOException {
DatagramSocket send = new DatagramSocket();
DatagramSocket rece = new DatagramSocket(10001);
new Thread(new Send(send)).start();
new Thread(new Rece(rece)).start();
}
}
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
