Java網(wǎng)絡(luò)編程之UDP網(wǎng)絡(luò)通信詳解

第Java網(wǎng)絡(luò)編程之UDP網(wǎng)絡(luò)通信詳解目錄1.UDP網(wǎng)絡(luò)通信編程原理1.1UDP網(wǎng)絡(luò)通信編程介紹1.2UDP網(wǎng)絡(luò)通信編程的基本流程2.UDP網(wǎng)絡(luò)通信編程案例

1.UDP網(wǎng)絡(luò)通信編程原理

1.1UDP網(wǎng)絡(luò)通信編程介紹

類DatagramSocket何DatagramPacket（數(shù)據(jù)包/數(shù)據(jù)報）實現(xiàn)了基于UDP協(xié)議網(wǎng)絡(luò)程序；

UDP數(shù)據(jù)報通過數(shù)據(jù)報套接字DatagramSocket發(fā)送和接收，系統(tǒng)不保證UDP數(shù)據(jù)報一定能夠安全送達(dá)目的地，也不確定什么時候可以抵達(dá)；

DatagramPacket對象封裝了UDP數(shù)據(jù)報，在數(shù)據(jù)報中包含了發(fā)送端IP地址和端口號，以及接收端的IP地址和端口號；

UDP協(xié)議中每個數(shù)據(jù)報都給出了完整的地址信息，因此無法建立發(fā)送方與接收方的連接。

沒有明確的服務(wù)端和客戶端，演變成數(shù)據(jù)的發(fā)送端和接收端；

接收數(shù)據(jù)和發(fā)送數(shù)據(jù)都是通過DatagramSocket對象完成。

1.2UDP網(wǎng)絡(luò)通信編程的基本流程

核心的兩個類/對象，DatagramSocket與DatagramPacket；

建立發(fā)送端和接收端；

建立數(shù)據(jù)包；

調(diào)用DatagramSocket的發(fā)送和接收方法；

關(guān)閉DatagramSocket。

2.UDP網(wǎng)絡(luò)通信編程案例

1.編寫一個接收端A，一個發(fā)送端B；

2.接收端在9999端口等待接收數(shù)據(jù)(receive);

3.發(fā)送端向接收端發(fā)送數(shù)據(jù)：你好！接收端

4.接收端接收到發(fā)送端的數(shù)據(jù)后，回復(fù)：你好！發(fā)送端，再退出；

5.發(fā)送端接收回復(fù)的數(shù)據(jù)，退出。

UDPReceiverA

importjava.io.IOException;

import.DatagramPacket;

import.DatagramSocket;

import.InetAddress;

*@author興趣使然黃小黃

*@version1.0

*接收端A

publicclassUDPReceiverA{

publicstaticvoidmain(String[]args)throwsIOException{

//1.創(chuàng)建一個DatagramSocket對象，準(zhǔn)備在9999接收數(shù)據(jù)

DatagramSocketsocket=newDatagramSocket(9999);

//2.構(gòu)建一個DatagramPacket對象，準(zhǔn)備接收數(shù)據(jù)

byte[]buf=newbyte[1024];

DatagramPacketpacket=newDatagramPacket(buf,buf.length);

//3.調(diào)用接收方法,將通過網(wǎng)絡(luò)傳輸?shù)腄atagramPacket對象填充到packet對象

System.out.println("接收端A等待接收數(shù)據(jù)...");

socket.receive(packet);

//4.把packet進(jìn)行拆包，取出數(shù)據(jù)

intlength=packet.getLength();//實際數(shù)據(jù)字節(jié)長度

byte[]data=packet.getData();//實際接收的數(shù)據(jù)

Strings=newString(data,0,length);

System.out.println(s);

//回復(fù)信息給B端

data="你好！發(fā)送端".getBytes();

packet=newDatagramPacket(data,0,data.length,

InetAddress.getLocalHost(),9998);

socket.send(packet);

//5.關(guān)閉資源

socket.close();

UDPSenderB

importjava.io.IOException;

import.*;

*@author興趣使然黃小黃

*@version1.0

*發(fā)送端B

publicclassUDPSenderB{

publicstaticvoidmain(String[]args)throwsIOException{

//1.創(chuàng)建DatagramSocket對象，準(zhǔn)備在9998發(fā)送和接收數(shù)據(jù)

DatagramSocketsocket=newDatagramSocket(9998);

//2.將需要發(fā)送的數(shù)據(jù)，封裝到DatagramPacket中

byte[]data="你好！接收端".getBytes();

DatagramPacketdatagramPacket=

newDatagramPacket(data,0,data.length,

InetAddress.getLocalHost(),9999);

socket.send(datagramPacket);

//接收A消息

socket.receive(datagramPacket);

intlength=datagramPacket.getLength();//實際數(shù)據(jù)字節(jié)長度

data=datagramP