相關(guān)java類介紹

DatagramSocket

public class DatagramSocket extends Object

此類表示用來發(fā)送和接收數(shù)據(jù)報(bào)包的套接字。

數(shù)據(jù)報(bào)套接字是包投遞服務(wù)的發(fā)送或接收點(diǎn)。每個(gè)在數(shù)據(jù)報(bào)套接字上發(fā)送或接收的包都是單獨(dú)編址和路由的。從一臺(tái)機(jī)器發(fā)送到另一臺(tái)機(jī)器的多個(gè)包可能選擇不同的路由，也可能按不同的順序到達(dá)。

在DatagramSocket上總是啟用UDP廣播發(fā)送。為了接收廣播包，應(yīng)該將DatagramSocket綁定到通配符地址,在某些實(shí)現(xiàn)中，將DatagramSocket綁定到一個(gè)更加具體的地址時(shí)廣播包也可以被接收.

可以通過DatagramSocket的send和receive來發(fā)送和接收數(shù)據(jù).

public void receive(DatagramPacket p) throws IOException

從此套接字接收數(shù)據(jù)報(bào)包。當(dāng)此方法返回時(shí)，DatagramPacket的緩沖區(qū)填充了接收的數(shù)據(jù)。數(shù)據(jù)報(bào)包也包含發(fā)送方的IP地址和發(fā)送方機(jī)器上的端口號(hào)。

此方法在接收到數(shù)據(jù)報(bào)前一直阻塞,數(shù)據(jù)報(bào)包對(duì)象的length字段包含所接收信息的長(zhǎng)度。如果信息比包的長(zhǎng)度長(zhǎng)，該信息將被截短

如果存在安全管理器，而安全管理器的checkAccept方法不允許接收操作，則包不能被接收。

參數(shù)：

p-要放置傳入數(shù)據(jù)的DatagramPacket。

拋出：

IOException-如果發(fā)生I/O錯(cuò)誤。

SocketTimeoutException-如果先前調(diào)用了setSoTimeout且超時(shí)值已過。

PortUnreachableException-套接字連接到當(dāng)前不可達(dá)的目標(biāo)時(shí)可能拋出。注意，不能保證一定拋出該異常。

IllegalBlockingModeException-如果此套接字具有相關(guān)聯(lián)的通道，且通道處于非阻塞模式。

public void send(DatagramPacket p) throws IOException

從此套接字發(fā)送數(shù)據(jù)報(bào)包。DatagramPacket包含的信息指示：將要發(fā)送的數(shù)據(jù)、其長(zhǎng)度、遠(yuǎn)程主機(jī)的IP地址和遠(yuǎn)程主機(jī)的端口號(hào)

如果存在安全管理器，且套接字當(dāng)前沒有連接到遠(yuǎn)程地址，則此方法首先執(zhí)行某些安全性檢查。首先，如果p.getAddress().isMulticastAddress()為true，則此方法以p.getAddress()作為參數(shù)調(diào)用安全管理器的checkMulticast方法。如果該表達(dá)式的值為false，此方法改為調(diào)用安全管理器的以p.getAddress().getHostAddress()和p.getPort()為參數(shù)的checkConnect方法。如果不允許該操作，則每次調(diào)用安全管理器方法都會(huì)導(dǎo)致SecurityException。

參數(shù)：

p-將要發(fā)送的DatagramPacket。

拋出：

IOException-如果發(fā)生I/O錯(cuò)誤。

SecurityException-如果安全管理器存在并且其checkMulticast或checkConnect方法不允許進(jìn)行發(fā)送。

PortUnreachableException-套接字連接到當(dāng)前不可達(dá)的目標(biāo)時(shí)可能拋出。注意，不能保證一定拋出該異常。

IllegalBlockingModeException-如果此套接字具有相關(guān)聯(lián)的通道，且通道處于非阻塞模式。

DatagramPacket

public final class DatagramPacket extends Object

此類表示UDP數(shù)據(jù)報(bào)包,數(shù)據(jù)報(bào)包用來實(shí)現(xiàn)無連接包投遞服務(wù)

構(gòu)造方法:

DatagramPacket(byte[]buf,intlength)

構(gòu)造DatagramPacket，用來接收長(zhǎng)度為length的數(shù)據(jù)包

DatagramPacket(byte[]buf,intlength,InetAddressaddress,intport)

構(gòu)造數(shù)據(jù)報(bào)包，用來將長(zhǎng)度為length的包發(fā)送到指定主機(jī)上的指定端口號(hào)

UDP群聊系統(tǒng)的示例

UDP是面向無連接的,群聊就是向廣播地址(broadcastingaddress)發(fā)送數(shù)據(jù),這樣每個(gè)人都會(huì)收到消息;采用線程的方式,啟動(dòng)一個(gè)發(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();
			//準(zhǔn)備數(shù)據(jù)包發(fā)送
			//從系統(tǒng)輸入讀取輸入
			BufferedReader in = new BufferedReader(new InputStreamReader(System.in)) ;
			String line = null;
			while((line = in.readLine()) != null){
				//我做測(cè)試,寫的是本機(jī)地址,群聊需要寫廣播地址,比如: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();
		}
	}
}

接收方

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的服務(wù),監(jiān)聽端口
			DatagramSocket socket = new DatagramSocket(9090);
			//接受數(shù)據(jù)包
			byte[] temp = new byte[1024];
			DatagramPacket data = new DatagramPacket(temp, temp.length);
			Boolean flag = true;
			while(flag){
				socket.receive(data);
				//輸出發(fā)送方的相關(guān)信息
				String senderAddress = data.getAddress().getHostAddress();
				String senderHostName = data.getAddress().getHostName();
				System.out.println(senderHostName+"("+senderAddress+")"+" say: " + new String(temp, 0,data.getLength()));
			}
			//關(guān)閉資源
			socket.close();
		}
		catch (IOException e) {
			e.printStackTrace();
		}
	}
}

Main方法

UdpMain.java

package cn.xidian.socket;
public class UdpMain {
	public static void main(String[] args) {
		//啟動(dòng)UdpReceiver線程
		UdpReceiver receiver = new UdpReceiver();
		receiver.start();
		//啟動(dòng)UdpSender線程
		UdpSender sender = new UdpSender();
		sender.start();
	}
}

測(cè)試結(jié)果

輸入方讀取鍵盤輸入作為輸出,接收方接收消息并顯示發(fā)送方的ip和主機(jī)名

總結(jié)

以上就是本文關(guān)于Java編程使用UDP建立群聊系統(tǒng)代碼實(shí)例的全部?jī)?nèi)容，希望對(duì)大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題，如有不足之處，歡迎留言指出。感謝朋友們對(duì)本站的支持！

最新評(píng)論