相關(guān)java類介紹
DatagramSocket
public class DatagramSocket extends Object
此類表示用來發(fā)送和接收數(shù)據(jù)報包的套接字。
數(shù)據(jù)報套接字是包投遞服務(wù)的發(fā)送或接收點。每個在數(shù)據(jù)報套接字上發(fā)送或接收的包都是單獨編址和路由的。從一臺機器發(fā)送到另一臺機器的多個包可能選擇不同的路由，也可能按不同的順序到達。
在DatagramSocket上總是啟用UDP廣播發(fā)送。為了接收廣播包，應(yīng)該將DatagramSocket綁定到通配符地址,在某些實現(xiàn)中，將DatagramSocket綁定到一個更加具體的地址時廣播包也可以被接收.
可以通過DatagramSocket的send和receive來發(fā)送和接收數(shù)據(jù).
public void receive(DatagramPacket p) throws IOException
從此套接字接收數(shù)據(jù)報包。當此方法返回時，DatagramPacket的緩沖區(qū)填充了接收的數(shù)據(jù)。數(shù)據(jù)報包也包含發(fā)送方的IP地址和發(fā)送方機器上的端口號。
此方法在接收到數(shù)據(jù)報前一直阻塞,數(shù)據(jù)報包對象的length字段包含所接收信息的長度。如果信息比包的長度長，該信息將被截短
如果存在安全管理器，而安全管理器的checkAccept方法不允許接收操作，則包不能被接收。
參數(shù)：
p-要放置傳入數(shù)據(jù)的DatagramPacket。
拋出：
IOException-如果發(fā)生I/O錯誤。
SocketTimeoutException-如果先前調(diào)用了setSoTimeout且超時值已過。
PortUnreachableException-套接字連接到當前不可達的目標時可能拋出。注意，不能保證一定拋出該異常。
IllegalBlockingModeException-如果此套接字具有相關(guān)聯(lián)的通道，且通道處于非阻塞模式。
public void send(DatagramPacket p) throws IOException
從此套接字發(fā)送數(shù)據(jù)報包。DatagramPacket包含的信息指示：將要發(fā)送的數(shù)據(jù)、其長度、遠程主機的IP地址和遠程主機的端口號
如果存在安全管理器，且套接字當前沒有連接到遠程地址，則此方法首先執(zhí)行某些安全性檢查。首先，如果p.getAddress().isMulticastAddress()為true，則此方法以p.getAddress()作為參數(shù)調(diào)用安全管理器的checkMulticast方法。如果該表達式的值為false，此方法改為調(diào)用安全管理器的以p.getAddress().getHostAddress()和p.getPort()為參數(shù)的checkConnect方法。如果不允許該操作，則每次調(diào)用安全管理器方法都會導(dǎo)致SecurityException。
參數(shù)：
p-將要發(fā)送的DatagramPacket。
拋出：
IOException-如果發(fā)生I/O錯誤。
SecurityException-如果安全管理器存在并且其checkMulticast或checkConnect方法不允許進行發(fā)送。
PortUnreachableException-套接字連接到當前不可達的目標時可能拋出。注意，不能保證一定拋出該異常。
IllegalBlockingModeException-如果此套接字具有相關(guān)聯(lián)的通道，且通道處于非阻塞模式。
DatagramPacket
public final class DatagramPacket extends Object
此類表示UDP數(shù)據(jù)報包,數(shù)據(jù)報包用來實現(xiàn)無連接包投遞服務(wù)
構(gòu)造方法:
DatagramPacket(byte[]buf,intlength)
構(gòu)造DatagramPacket，用來接收長度為length的數(shù)據(jù)包
DatagramPacket(byte[]buf,intlength,InetAddressaddress,intport)
構(gòu)造數(shù)據(jù)報包，用來將長度為length的包發(fā)送到指定主機上的指定端口號
UDP群聊系統(tǒng)的示例
UDP是面向無連接的,群聊就是向廣播地址(broadcastingaddress)發(fā)送數(shù)據(jù),這樣每個人都會收到消息;采用線程的方式,啟動一個發(fā)送方線程和接收方線程,發(fā)送方讀取鍵盤輸入作為輸出,接收方讀到輸入的信息并顯示
發(fā)送方
UdpSender.java
重慶分公司
重慶分公司
package cn.xidian.socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UdpSender extends Thread{
@Override
public void run() {
try {
//建立UDP的服務(wù)
DatagramSocket socket = new DatagramSocket();
//準備數(shù)據(jù)包發(fā)送
//從系統(tǒng)輸入讀取輸入
BufferedReader in = new BufferedReader(new InputStreamReader(System.in)) ;
String line = null;
while((line = in.readLine()) != null){
//我做測試,寫的是本機地址,群聊需要寫廣播地址,比如:192.168.137.255
DatagramPacket data = new DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName("127.0.0.1"), 9090);
//發(fā)送數(shù)據(jù)
socket.send(data);
}
//關(guān)閉socket
socket.close();
}
catch (IOException e) {
e.printStackTrace();
}
}
} 
