相關java類介紹
DatagramSocket
public class DatagramSocket extends Object
此類表示用來發送和接收數據報包的套接字。
數據報套接字是包投遞服務的發送或接收點。每個在數據報套接字上發送或接收的包都是單獨編址和路由的。從一台機器發送到另一台機器的多個包可能選擇不同的路由，也可能按不同的順序到達。
在DatagramSocket上總是啟用UDP廣播發送。為了接收廣播包，應該將DatagramSocket綁定到通配符地址,在某些實現中，將DatagramSocket綁定到一個更加具體的地址時廣播包也可以被接收.
可以通過DatagramSocket的send和receive來發送和接收數據.
public void receive(DatagramPacket p) throws IOException
從此套接字接收數據報包。當此方法返回時，DatagramPacket的緩衝區填充了接收的數據。數據報包也包含發送方的IP地址和發送方機器上的端口號。
此方法在接收到數據報前一直阻塞,數據報包對象的length字段包含所接收信息的長度。如果信息比包的長度長，該信息將被截短
如果存在安全管理器，而安全管理器的checkAccept方法不允許接收操作，則包不能被接收。
參數：
p-要放置傳入數據的DatagramPacket。
拋出：
IOException-如果發生I/O錯誤。
SocketTimeoutException-如果先前調用了setSoTimeout且超時值已過。
PortUnreachableException-套接字連接到當前不可達的目標時可能拋出。注意，不能保證一定拋出該異常。
IllegalBlockingModeException-如果此套接字具有相關聯的通道，且通道處於非阻塞模式。
public void send(DatagramPacket p) throws IOException
從此套接字發送數據報包。 DatagramPacket包含的信息指示：將要發送的數據、其長度、遠程主機的IP地址和遠程主機的端口號
如果存在安全管理器，且套接字當前沒有連接到遠程地址，則此方法首先執行某些安全性檢查。首先，如果p.getAddress().isMulticastAddress()為true，則此方法以p.getAddress()作為參數調用安全管理器的checkMulticast方法。如果該表達式的值為false，此方法改為調用安全管理器的以p.getAddress().getHostAddress()和p.getPort()為參數的checkConnect方法。如果不允許該操作，則每次調用安全管理器方法都會導致SecurityException。
參數：
p-將要發送的DatagramPacket。
拋出：
IOException-如果發生I/O錯誤。
SecurityException-如果安全管理器存在並且其checkMulticast或checkConnect方法不允許進行發送。
PortUnreachableException-套接字連接到當前不可達的目標時可能拋出。注意，不能保證一定拋出該異常。
IllegalBlockingModeException-如果此套接字具有相關聯的通道，且通道處於非阻塞模式。
DatagramPacket
public final class DatagramPacket extends Object
此類表示UDP數據報包,數據報包用來實現無連接包投遞服務
構造方法:
DatagramPacket(byte[]buf,intlength)
構造DatagramPacket，用來接收長度為length的數據包
DatagramPacket(byte[]buf,intlength,InetAddressaddress,intport)
構造數據報包，用來將長度為length的包發送到指定主機上的指定端口號
UDP群聊系統的示例
UDP是面向無連接的,群聊就是向廣播地址(broadcastingaddress)發送數據,這樣每個人都會收到消息;採用線程的方式,啟動一個發送方線程和接收方線程,發送方讀取鍵盤輸入作為輸出,接收方讀到輸入的信息並顯示
發送方
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的服務DatagramSocket socket = new DatagramSocket();//準備數據包發送//從系統輸入讀取輸入BufferedReader in = new BufferedReader(new InputStreamReader(System.in)) ;String line = null;while((line = in.readLine()) != null){//我做測試,寫的是本機地址,群聊需要寫廣播地址,比如:192.168.137.255DatagramPacket data = new DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName("127.0.0.1"), 9090);//發送數據socket.send(data);}//關閉socketsocket.close();}catch (IOException e) {e.printStackTrace();}}}接收方
UdpReceiver.java
package cn.xidian.socket;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;public class UdpReceiver extends Thread {@Override public void run() {try {//建立UDP的服務,監聽端口DatagramSocket socket = new DatagramSocket(9090);//接受數據包byte[] temp = new byte[1024];DatagramPacket data = new DatagramPacket(temp, temp.length);Boolean flag = true;while(flag){socket.receive(data);//輸出發送方的相關信息String senderAddress = data.getAddress().getHostAddress();String senderHostName = data.getAddress().getHostName();System.out.println(senderHostName+"("+senderAddress+")"+" say: " + new String(temp, 0,data.getLength()));}//關閉資源socket.close();}catch (IOException e) {e.printStackTrace();}}}Main方法
UdpMain.java
package cn.xidian.socket;public class UdpMain {public static void main(String[] args) {//啟動UdpReceiver線程UdpReceiver receiver = new UdpReceiver();receiver.start();//啟動UdpSender線程UdpSender sender = new UdpSender();sender.start();}}測試結果
輸入方讀取鍵盤輸入作為輸出,接收方接收消息並顯示發送方的ip和主機名
總結
以上就是本文關於Java編程使用UDP建立群聊系統代碼實例的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！