UDP協議提供的服務不同于TCP協議的端到端服務，它是面向非連接的，屬不可靠協議，UDP套接字在使用前不需要進行連接。實際上，UDP協議實現了兩個功能：

1）在ip協議的基礎上添加了端口；

2）對傳輸過程中可能產生的數據錯誤進行了檢測，并拋棄已經損壞的數據。

Java通過DatagramPacket類和DatagramSocket類來使用UDP套接字，客戶端和服務器端都通過DatagramSocket的send（）方法和receive（）方法來發送和接收數據，用DatagramPacket來包裝需要發送或者接收到的數據。發送信息時，Java創建一個包含待發送信息的DatagramPacket實例，并將其作為參數傳遞給DatagramSocket實例的send（）方法；接收信息時，Java程序首先創建一個DatagramPacket實例，該實例預先分配了一些空間，并將接收到的信息存放在該空間中，然后把該實例作為參數傳遞給DatagramSocket實例的receive（）方法。在創建DatagramPacket實例時，要注意：如果該實例用來包裝待接收的數據，則不指定數據來源的遠程主機和端口，只需指定一個緩存數據的byte數組即可（在調用receive（）方法接收到數據后，源地址和端口等信息會自動包含在DatagramPacket實例中），而如果該實例用來包裝待發送的數據，則要指定要發送到的目的主機和端口。

UDP客戶端首先向被動等待聯系的服務器發送一個數據報文。一個典型的UDP客戶端要經過下面三步操作：

1、創建一個DatagramSocket實例，可以有選擇地對本地地址和端口號進行設置，如果設置了端口號，則客戶端會在該端口號上監聽從服務器端發送來的數據；

2、使用DatagramSocket實例的send（）和receive（）方法來發送和接收DatagramPacket實例，進行通信；

3、通信完成后，調用DatagramSocket實例的close（）方法來關閉該套接字。

由于UDP是無連接的，因此UDP服務端不需要等待客戶端的請求以建立連接。另外，UDP服務器為所有通信使用同一套接字，這點與TCP服務器不同，TCP服務器則為每個成功返回的accept()方法創建一個新的套接字。一個典型的UDP服務端要經過下面三步操作：

1、創建一個DatagramSocket實例，指定本地端口號，并可以有選擇地指定本地地址，此時，服務器已經準備好從任何客戶端接收數據報文；

2、使用DatagramSocket實例的receive（）方法接收一個DatagramPacket實例，當receive（）方法返回時，數據報文就包含了客戶端的地址，這樣就知道了回復信息應該發送到什么地方；

3、使用DatagramSocket實例的send（）方法向服務器端返回DatagramPacket實例。

這里有一點需要注意：

UDP程序在receive()方法處阻塞，直到收到一個數據報文或等待超時。由于UDP協議是不可靠協議，如果沒有收到DatagramPacket，那么程序將會一直阻塞在receive()方法處，這樣客戶端將永遠都接收不到服務器端發送回來的數據，但是又沒有任何提示。為了避免這個問題，我們在客戶端使用DatagramSocket類的setSoTimeout()方法來制定receive()方法的最長阻塞時間，并指定重發數據報的次數，如果每次阻塞都超時，并且重發次數達到了設置的上限，則關閉客戶端。

下面給出一個客戶端服務端UDP通信的Demo（沒有用多線程），該客戶端在本地2222端口監聽接收到的數據，并將字符串"Hello UDPserver"發送到本地服務器的3222端口，服務端在本地3222端口監聽接收到的數據，如果接收到數據，則返回字符串"Hello UDPclient"到該客戶端的2222端口。在客戶端，由于程序可能會一直阻塞在receive（）方法處，因此這里我們在客戶端用DatagramSocket實例的setSoTimeout（）方法來指定receive（）的最長阻塞時間TIMEOUT，并設置重發數據的次數MAXNUM，如果最終依然沒有接收到從服務端發送回來的數據，我們就關閉客戶端。

 1 import java.io.IOException; 2 import java.io.InterruptedIOException; 3 import java.net.DatagramPacket; 4 import java.net.DatagramSocket; 5 import java.net.InetAddress; 6  7 public class UdpClient { 8     PRivate static final int MAXNUM = 5; // 設置重發數據的最多次數 9     private static final int TIMEOUT = 5000;  //設置接收數據的超時時間10     private static final int CLIENT_PORT = 2222;11     private static final int SERVER_PORT = 3222;12     private static final int REV_SIZE = 1024; //接收數據的存儲空間大小13     14     public static void main(String[] args) throws IOException {15         String str_send = "Hello UDPserver"; //要發送的字串16         byte[] buf_rev = new byte[REV_SIZE];     //要接收的存儲空間17         18         /*第一步 實例化DatagramSocket*/19         DatagramSocket mSoc = new DatagramSocket(CLIENT_PORT);20         mSoc.setSoTimeout(TIMEOUT);              //設置接收數據時阻塞的最長時間  21         22         /*第二步 實例化用于發送的DatagramPacket和用于接收的DatagramPacket*/23         InetAddress inetAddress = InetAddress.getLocalHost();24         DatagramPacket data_send = new DatagramPacket(str_send.getBytes(),25                 str_send.length(), inetAddress, SERVER_PORT);26         27         DatagramPacket data_rev = new DatagramPacket(buf_rev, REV_SIZE);28 29         30         /*第三步 DatagramPacket send發送數據，receive接收數據*/31         int send_count = 0; // 重發數據的次數32         boolean revResponse = false; // 是否接收到數據的標志位33         while (!revResponse && send_count < MAXNUM) {34             try {35                 mSoc.send(data_send); //發送數據36                 mSoc.receive(data_rev);//接收數據37                 if (!data_rev.getAddress().getHostAddress()38                         .equals(InetAddress.getLocalHost().getHostAddress())) {39                     throw new IOException(40                             "Received packet from an umknown source");41                 }42                 revResponse = true;43             } catch (InterruptedIOException e) {44                 // 如果接收數據時阻塞超時，重發并減少一次重發的次數45                 send_count += 1;46                 System.out.println("Time out," + (MAXNUM - send_count)47                         + " more tries...");48             }49         }50         if (revResponse) {51             // 如果收到數據，則打印出來52             System.out.println("client received data from server：");53             String str_receive = new String(data_rev.getData(), 0,54                     data_rev.getLength())55                     + " from "56                     + data_rev.getAddress().getHostAddress()57                     + ":"58                     + data_rev.getPort();59             System.out.println(str_receive);60             // 由于dp_receive在接收了數據之后，其內部消息長度值會變為實際接收的消息的字節數，61             // 所以這里要將dp_receive的內部消息長度重新置為102462             data_rev.setLength(REV_SIZE);63         } else {64             // 如果重發MAXNUM次數據后，仍未獲得服務器發送回來的數據，則打印如下信息65             System.out.println("No response -- give up.");66         }67         68         /*第四步 關閉DatagramPacket*/69         mSoc.close();70     }71 72 }

 1 import java.io.IOException; 2 import java.net.DatagramPacket; 3 import java.net.DatagramSocket; 4 import java.net.InetAddress; 5  6 public class UdpServer { 7  8     private static final int SERVER_PORT = 3222; 9     private static final int REV_SIZE = 1024; // 接收數據的存儲空間大小10 11     public static void main(String[] args) throws IOException {12         byte[] buf_rev = new byte[REV_SIZE];13         String str_send = "Hello UDPclient";14         /* 第一步 實例化DatagramSocket */15         DatagramSocket mSoc = new DatagramSocket(SERVER_PORT);16 17         /* 第二步 實例化用于接收的DatagramPacket 并從DatagramSocket接收數據 */18         DatagramPacket data_rev = new DatagramPacket(buf_rev, REV_SIZE);19         boolean f = true;20         while (f) {21             mSoc.receive(data_rev);22             InetAddress inetAddress = data_rev.getAddress();23             int port = data_rev.getPort();24             System.out.println("server received data from client：");25             String str_rev = new String(data_rev.getData(), 0,26                     data_rev.getLength())27                     + " from " + inetAddress.getHostAddress() + ":" + port;28             System.out.println(str_rev);29 30             /* 第三步 實例化用于發送的DatagramPacket，并從DatagramSocket中發送出去 */31             DatagramPacket data_send = new DatagramPacket(str_send.getBytes(),32                     str_send.length(), inetAddress, port);33             mSoc.send(data_send);34 35             /*36              * 由于dp_receive在接收了數據之后，其內部消息長度值會變為實際接收的消息的字節數，37              * 所以這里要將dp_receive的內部消息長度重新置為102438              */39             data_rev.setLength(REV_SIZE);40         }41         mSoc.close();42 43     }44 }

如果服務器端沒有運行，則receive（）會失敗，此時運行結果如下圖所示：

如果服務端先運行，客戶端后運行，客戶端將向服務端發送數據，并接受從服務端發送回來的數據，此時運行結果如下圖所示：

1、UDP套接字和TCP套接字的一個微小但重要的差別：UDP協議保留了消息的邊界信息。

DatagramSocket的每一次receive()調用最多只能接收調用一次send()方法所發送的數據，而且，不同的receive()方法調用絕對不會返回同一個send()方法所發送的額數據。

當在TCP套接字的輸出流上調用write（）方法返回后，所有調用者都知道數據已經被復制到一個傳輸緩存區中，實際上此時數據可能已經被發送，也有可能還沒有被傳送，而UDP協議沒有提供從網絡錯誤中恢復的機制，因此，并不對可能需要重傳的數據進行緩存。這就意味著，當send（）方法調用返回時，消息已經被發送到了底層的傳輸信道中。

2、UDP數據報文所能負載的最多數據，亦及一次傳送的最大數據為65507個字節

當消息從網絡中到達后，其所包含的數據被TCP的read（）方法或UDP的receive（）方法返回前，數據存儲在一個先進先出的接收數據隊列中。對于已經建立連接的TCP套接字來說，所有已接受但還未傳送的字節都看作是一個連續的字節序列。然而，對于UDP套接字來說，接收到的數據可能來自不同的發送者，一個UDP套接字所接受的數據存放在一個消息隊列中，每個消息都關聯了其源地址信息，每次receive（）調用只返回一條消息。如果receive（）方法在一個緩存區大小為n的DatagramPacket實例中調用，而接受隊里中的第一條消息的長度大于n，則receive（）方法只返回這條消息的前n個字節，超出部分會被自動放棄，而且對接收程序沒有任何消息丟失的提示！

出于這個原因，接受者應該提供一個有足夠大的緩存空間的DatagramPacket實例，以完整地存放調用receive（）方法時應用程序協議所允許的最大長度的消息。一個DatagramPacket實例中所允許傳輸的最大數據量為65507個字節，也即是UDP數據報文所能負載的最多數據。因此，可以用一個65600字節左右的緩存數組來接受數據。

3、DatagramPacket的內部消息長度值在接收數據后會發生改變，變為實際接收到的數據的長度值。

每一個DatagramPacket實例都包含一個內部消息長度值，其初始值為byte緩存數組的長度值，而該實例一旦接受到消息，這個長度值便會變為接收到的消息的實際長度值，這一點可以用DatagramPacket類的getLength（）方法來測試。如果一個應用程序使用同一個DatagramPacket實例多次調用receive（）方法，每次調用前就必須顯式地將其內部消息長度重置為緩存區的實際長度，以免接受的數據發生丟失。

4、DatagramPacket的getData（）方法總是返回緩沖區的原始大小，忽略了實際數據的內部偏移量和長度信息。

由于DatagramPacket的getData（）方法總是返回緩沖數組的原始大小，即剛開始創建緩沖數組時指定的大小，在上面程序中，該長度為1024，因此如果我們要獲取接收到的數據，就必須截取getData（）方法返回的數組中只含接收到的數據的那一部分。

我們可以使用Arrays.copyOfRange（）方法來實現，只需一步便可實現以上功能：

byte[] destbuf = Arrays.copyOfRange(data_rev.getData(),data_rev.getOffset(),

data_rev.getOffset() + data_rev.getLength());

當然，如果要將接收到的字節數組轉換為字符串的話，也可以采用本程序中直接new一個String對象的方法：

new String(data_rev.getData(),data_rev.getOffset(),

data_rev.getOffset() + data_rev.getLength());

參考文章：

【Java TCP/IP Socket】UDP Socket（含代碼） http://blog.csdn.net/ns_code/article/details/14128987

《Java TCP/IP Socket 編程》