java使用MulticastSocket實(shí)現(xiàn)組播

更新時(shí)間：2019年01月05日 13:15:08 作者：穆穆里

這篇文章主要為大家詳細(xì)介紹了java使用MulticastSocket實(shí)現(xiàn)組播，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

組播是一種允許源進(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ò)，也可以來(lái)自不同的物理網(wǎng)絡(luò)（只要有組播路由器支持）。

組播分為無(wú)連接和面向連接組播，但是基本的組播機(jī)制是無(wú)連接的，我們這里所講的也是無(wú)連接組播。

我們說(shuō)過(guò)使用MulticastSocket類(lèi)，這個(gè)類(lèi)叫組播數(shù)據(jù)報(bào)套接字類(lèi)，主要用來(lái)發(fā)送和接收IP組播報(bào)文。MulticastSocket是DatagramSocket的子類(lèi)，它增加了加入和離開(kāi)組播組的功能。組播組通過(guò)一個(gè)D類(lèi)IP地址和一個(gè)標(biāo)準(zhǔn)UDP端口號(hào)的組合來(lái)定義。D類(lèi)IP地址的范圍是224.0.0.0～239.255.255.255，除了224.0.0.0是保留地址，不應(yīng)使用。

下面我們用一個(gè)簡(jiǎn)單的示例演示兩個(gè)進(jìn)程如何使用組播進(jìn)行通信，這兩個(gè)進(jìn)程一個(gè)是發(fā)送端進(jìn)程，另一個(gè)是接收端進(jìn)程。

我們看代碼：

Sender.java

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)容，消息長(zhǎng)度，組播IP和端口
  MulticastSocket multicastSocket = new MulticastSocket();
  multicastSocket.send(datagramPacket);//發(fā)送數(shù)據(jù)包
 } catch (Exception exception) {
  exception.printStackTrace();
 }
 }
}

Receiver.java

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)然這明顯有安全問(wèn)題，以后找到解決辦法或者單播機(jī)制再另寫(xiě)一篇博文了。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: