UDP的理論不再多說，我這里直接給出一個關于UDP的HelloWorld程序，代碼明了，希望對剛入門的學生有所幫助！
當然，實際上，在這塊我也剛入門！
首先寫服務端代碼，服務端邦定本地的IP和端口來監(jiān)聽訪問：
package udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
/**
* UDP服務類
*/
public class UdpServerSocket {
private byte[] buffer = new byte[1024];
private static DatagramSocket ds = null;
private DatagramPacket packet = null;
private InetSocketAddress socketAddress = null;
/**
* 測試方法
*/
public static void main(String[] args) throws Exception {
String serverHost = "127.0.0.1";
int serverPort = 3344;
UdpServerSocket udpServerSocket = new UdpServerSocket(serverHost,
serverPort);
while (true) {
udpServerSocket.receive();
udpServerSocket.response("你好,吃了嗎!");
}
}
/**
* 構造函數(shù)，綁定主機和端口
*/
public UdpServerSocket(String host, int port) throws Exception {
socketAddress = new InetSocketAddress(host, port);
ds = new DatagramSocket(socketAddress);
System.out.println("服務端啟動!");
}
/**
* 接收數(shù)據(jù)包，該方法會造成線程阻塞
*/
public final String receive() throws IOException {
packet = new DatagramPacket(buffer, buffer.length);
ds.receive(packet);
String info = new String(packet.getData(), 0, packet.getLength());
System.out.println("接收信息：" + info);
return info;
}
/**
* 將響應包發(fā)送給請求端
*/
public final void response(String info) throws IOException {
System.out.println("客戶端地址 : " + packet.getAddress().getHostAddress()
+ ",端口：" + packet.getPort());
DatagramPacket dp = new DatagramPacket(buffer, buffer.length, packet
.getAddress(), packet.getPort());
dp.setData(info.getBytes());
ds.send(dp);
}
}
運行后提示服務端運行成功，程序開始監(jiān)聽端口，接收方法堵塞，當有訪問時才會向下進行！
我們寫客戶端進行訪問，看到網(wǎng)上的例子都是直接創(chuàng)建了 DatagramSocket 對象，而其實自己都不知道自己使用的端口是那個，這里我創(chuàng)建時會指定自己邦定的端口，其實很簡單，就是初始化該對象時傳遞一個端口參數(shù)。
這里你訪問客戶端時客戶端會打印你的IP和端口！
看一看客戶端代碼：
package udp;
import java.io.*;
import java.net.*;
/**
* UDP客戶端程序，用于對服務端發(fā)送數(shù)據(jù)，并接收服務端的回應信息
*/
public class UdpClientSocket {
private byte[] buffer = new byte[1024];
private static DatagramSocket ds = null;
/**
* 測試客戶端發(fā)包和接收回應信息的方法
*/
public static void main(String[] args) throws Exception {
UdpClientSocket client = new UdpClientSocket();
String serverHost = "127.0.0.1";
int serverPort = 3344;
client.send(serverHost, serverPort, ("你好，親愛的!").getBytes());
byte[] bt = client.receive();
System.out.println("服務端回應數(shù)據(jù)：" + new String(bt));
// 關閉連接
try {
ds.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
/**
* 構造函數(shù)，創(chuàng)建UDP客戶端
*/
public UdpClientSocket() throws Exception {
ds = new DatagramSocket(8899); // 邦定本地端口作為客戶端
}
/**
* 向指定的服務端發(fā)送數(shù)據(jù)信息
*/
public final void send(final String host, final int port,
final byte[] bytes) throws IOException {
DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName(host), port);
ds.send(dp);
}
/**
* 接收從指定的服務端發(fā)回的數(shù)據(jù)
*/
public final byte[] receive()
throws Exception {
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());
return data;
}
}
直接運行程序看效果！
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
