組播是一種允許源進(jìn)程將數(shù)據(jù)包發(fā)送到多個(gè)目標(biāo)進(jìn)程的網(wǎng)絡(luò)技術(shù)。組播源將數(shù)據(jù)包發(fā)送到特定組播組，只有屬于該組播組的進(jìn)程才能接收到數(shù)據(jù)包。這些進(jìn)程可以是在同一個(gè)物理網(wǎng)絡(luò)，也可以來自不同的物理網(wǎng)絡(luò)（只要有組播路由器支持）。
組播分為無連接和面向連接組播，但是基本的組播機(jī)制是無連接的，我們這里所講的也是無連接組播。
我們說過使用multicastsocket類，這個(gè)類叫組播數(shù)據(jù)報(bào)套接字類，主要用來發(fā)送和接收ip組播報(bào)文。multicastsocket是datagramsocket的子類，它增加了加入和離開組播組的功能。組播組通過一個(gè)d類ip地址和一個(gè)標(biāo)準(zhǔn)udp端口號(hào)的組合來定義。d類ip地址的范圍是224.0.0.0～239.255.255.255，除了224.0.0.0是保留地址，不應(yīng)使用。
下面我們用一個(gè)簡單的示例演示兩個(gè)進(jìn)程如何使用組播進(jìn)行通信，這兩個(gè)進(jìn)程一個(gè)是發(fā)送端進(jìn)程，另一個(gè)是接收端進(jìn)程。
我們看代碼：
sender.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
import java.net.datagrampacket;import java.net.inetaddress;import java.net.multicastsocket; public class sender { public static void main(string[] args) { try { byte[] msg = new byte[] { 'h', 'e', 'l', 'l', 'o' }; inetaddress inetaddress = inetaddress.getbyname("230.0.0.1");//根據(jù)主機(jī)名返回主機(jī)的ip地址 datagrampacket datagrampacket = new datagrampacket(msg, msg.length, inetaddress, 7777);//數(shù)據(jù)包包含消息內(nèi)容，消息長度，組播ip和端口 multicastsocket multicastsocket = new multicastsocket(); multicastsocket.send(datagrampacket);//發(fā)送數(shù)據(jù)包 } catch (exception exception) { exception.printstacktrace(); } }} |
receiver.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
import java.net.datagrampacket;import java.net.inetaddress;import java.net.multicastsocket; public class receiver { public static void main(string[] arstring) { try { multicastsocket multicastsocket = new multicastsocket(7777);//創(chuàng)建組播套接字并綁定到發(fā)送端口 inetaddress inetaddress = inetaddress.getbyname("230.0.0.1"); multicastsocket.joingroup(inetaddress);//組播套接字加入組播組 while (true) { byte[] data = new byte[100]; datagrampacket datagrampacket = new datagrampacket(data,data.length);//創(chuàng)建一個(gè)用于接收數(shù)據(jù)的數(shù)據(jù)包 multicastsocket.receive(datagrampacket);//接收數(shù)據(jù)包 system.out.println(new string(data)); } } catch (exception exception) { exception.printstacktrace(); } }} |
使用multicastsocket實(shí)現(xiàn)組播的要點(diǎn)如下：
接收方：加入組播組；
發(fā)送方：發(fā)送包含組地址的數(shù)據(jù)報(bào)。
順便提一下組播實(shí)現(xiàn)私信的做法：我們可以在消息頭部加上指定接收者地址，然后使用組播的方式發(fā)送，關(guān)鍵在接收的時(shí)候檢查該地址，如果跟匹配該地址，就接收并處理;如果不匹配當(dāng)然就拋棄。當(dāng)然這明顯有安全問題，以后找到解決辦法或者單播機(jī)制再另寫一篇博文了。
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/whoami021/article/details/21337651
