之前寫了一個簡單的UDP服務(wù)端和客戶端示例，用于入門UDP，當(dāng)我實際使用時發(fā)生了一點問題！
上次使用中我也把連接對象 DatagramSocket 寫成了靜態(tài)的，在類的初始化時使用，可是系統(tǒng)中有很多地方使用，難道我要不斷的創(chuàng)建這個類的對象嗎？
可以這么做，當(dāng)時有后果，后果就是內(nèi)存溢出。
UDP是沒有狀態(tài)的，DatagramSocket 創(chuàng)建一次即可，就是開始指向某個地址的端口，而不用每次創(chuàng)建。
由于UDP是無狀態(tài)的，在創(chuàng)建 DatagramSocket 對象時只是創(chuàng)建了一個指向網(wǎng)絡(luò)的對象，就像你架設(shè)一個大喇叭對著某個方向，可是你并不知道這個方向到底有沒有人在聽。
如果，即使你沒有開服務(wù)端，創(chuàng)建連接對象并向這個地址放松數(shù)據(jù)，都是沒有問題。你用喇叭向某個方向喊沒人聽這沒有什么！可是當(dāng)你需要回應(yīng)時如果一直沒有接到響應(yīng)，超時之后就會報錯！
package udp;
import java.net.*;
/**
* @說明 UDP客戶端程序，用于對服務(wù)端發(fā)送數(shù)據(jù)，并接收服務(wù)端的回應(yīng)信息
* @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;
/**
* 測試客戶端發(fā)包和接收回應(yīng)信息的方法
*/
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();
}
}
/**
* 向指定的服務(wù)端發(fā)送數(shù)據(jù)信息
*/
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();
}
}
/**
* 接收從指定的服務(wù)端發(fā)回的數(shù)據(jù)
*/
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("服務(wù)端回應(yīng)數(shù)據(jù)：" + new String(data));
} catch (Exception e) {
e.printStackTrace();
}
}
}
執(zhí)行以代碼運行結(jié)果如下：
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)
運行超時，但是報錯的地方不是創(chuàng)建對象和發(fā)送數(shù)據(jù)，而是接收數(shù)據(jù)時超時！
這個程序一直運行，我們來搞一個服務(wù)端：
package udp;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
/**
* @說明 UDP服務(wù)類
* @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("---->服務(wù)開始監(jiān)聽！<----");
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();
}
}
/**
* 接收數(shù)據(jù)包，該方法會造成線程阻塞
*/
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();
}
}
/**
* 將響應(yīng)包發(fā)送給請求端
*/
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();
}
}
}
運行后客戶端可以正常發(fā)送和接收數(shù)據(jù)！
如果在實際運用中，我是設(shè)置一個系統(tǒng)啟動項，來初始化 init 連接對象和地址，具體使用時進行異常捕獲就可以了！
如果你的連接對象每次創(chuàng)建，且使用頻繁，一般幾分鐘系統(tǒng)即可搞掛！
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
