溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇文章給大家分享的是有關使用UDP連接對象原理，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
由于UDP是無狀態的，在創建 DatagramSocket 對象時只是創建了一個指向網絡的對象，就像你架設一個大喇叭對著某個方向，可是你并不知道這個方向到底有沒有人在聽。
如果，即使你沒有開服務端，創建連接對象并向這個地址放松數據，都是沒有問題。你用喇叭向某個方向喊沒人聽這沒有什么！可是當你需要回應時如果一直沒有接到響應，超時之后就會報錯！
package udp;
import java.net.*;
/**
* @說明 UDP客戶端程序，用于對服務端發送數據，并接收服務端的回應信息
* @author cuisuqiang
* @version 1.0
* @since <a href="mailto:cuisuqiang@163.com" rel="external nofollow" >cuisuqiang@163.com</a>
*/
public class UdpClientSocket {
/**
* 連接對象
*/
private static DatagramSocket ds = null;
/**
* 地址對象
*/
private static SocketAddress address = null;
/**
* 測試客戶端發包和接收回應信息的方法
*/
public static void main(String[] args) throws Exception {
init();
while(true){
UdpClientSocket.send(address,"你好，親愛的!".getBytes());
UdpClientSocket.receive();
try {
Thread.sleep(3 * 1000);
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 對連接和地址初始化
*/
public static void init(){
try {
ds = new DatagramSocket(8899); // 邦定本地端口作為客戶端
ds.setSoTimeout(2 * 1000);
address = new InetSocketAddress("127.0.0.1",3344);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 向指定的服務端發送數據信息
*/
public static void send(SocketAddress address,byte[] bytes){
try {
DatagramPacket dp = new DatagramPacket(bytes, bytes.length, address);
ds.send(dp);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 接收從指定的服務端發回的數據
*/
public static void receive(){
try {
byte[] buffer = new byte[1024];
DatagramPacket dp = new DatagramPacket(buffer, buffer.length);
ds.receive(dp);
byte[] data = new byte[dp.getLength()];
System.arraycopy(dp.getData(), 0, data, 0, dp.getLength());
System.out.println("服務端回應數據：" + new String(data));
} catch (Exception e) {
e.printStackTrace();
}
}
} 執行以代碼運行結果如下：
java.net.SocketTimeoutException: Receive timed out
at java.net.PlainDatagramSocketImpl.receive0(Native Method)
at java.net.PlainDatagramSocketImpl.receive(PlainDatagramSocketImpl.java:136)
at java.net.DatagramSocket.receive(DatagramSocket.java:712)
at udp.UdpClientSocket.receive(UdpClientSocket.java:69)
at udp.UdpClientSocket.main(UdpClientSocket.java:28)
運行超時，但是報錯的地方不是創建對象和發送數據，而是接收數據時超時！
這個程序一直運行，我們來搞一個服務端：
package udp;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
/**
* @說明 UDP服務類
* @author cuisuqiang
* @version 1.0
* @since cuisuqiang@163.com
*/
public class UdpServerSocket {
private static DatagramSocket ds = null;
private static SocketAddress address = null;
/**
* 測試方法
*/
public static void main(String[] args) throws Exception {
init();
System.out.println("---->服務開始監聽！<----");
while (true) {
UdpServerSocket.receive();
UdpServerSocket.response(address,"你好,吃了嗎!");
}
}
public static void init(){
try {
ds = new DatagramSocket(3344);
ds.setSoTimeout(0);
address = new InetSocketAddress("127.0.0.1",8899);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 接收數據包，該方法會造成線程阻塞
*/
public static void receive() {
try {
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
ds.receive(packet);
String info = new String(packet.getData(), 0, packet.getLength());
System.out.println("接收信息：" + info);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 將響應包發送給請求端
*/
public static void response(SocketAddress address,String info){
try {
DatagramPacket dp = new DatagramPacket(info.getBytes(), info.getBytes().length, address);
dp.setData(info.getBytes());
ds.send(dp);
} catch (Exception e) {
e.printStackTrace();
}
}
}運行后客戶端可以正常發送和接收數據！
如果在實際運用中，我是設置一個系統啟動項，來初始化 init 連接對象和地址，具體使用時進行異常捕獲就可以了！
如果你的連接對象每次創建，且使用頻繁，一般幾分鐘系統即可搞掛！
以上就是使用UDP連接對象原理，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
