DatagramSocket只允許數(shù)據(jù)報(bào)發(fā)送給指定的目標(biāo)地址，而MulticastSocket可以將數(shù)據(jù)報(bào)以廣播方式發(fā)送到數(shù)量不等的多個(gè)客戶端。

若要使用多點(diǎn)廣播時(shí)，則需要讓一個(gè)數(shù)據(jù)報(bào)標(biāo)有一組目標(biāo)主機(jī)地址，當(dāng)數(shù)據(jù)報(bào)發(fā)出后，整個(gè)組的所有主機(jī)都能收到該數(shù)據(jù)報(bào)。IP多點(diǎn)廣播實(shí)現(xiàn)了將單一信息發(fā)送到多個(gè)接收者的廣播，其思想是設(shè)置一組特殊網(wǎng)絡(luò)地址作為廣播地址，每個(gè)多點(diǎn)廣播地址都被看做一個(gè)組，當(dāng)客戶端主要發(fā)送、接收信息時(shí)，加入到該組即可。

IP協(xié)議為多點(diǎn)廣播提供了這批特殊的IP地址，這些地址的IP地址范圍是224.0.0.0至239.255.255.255。

通過Java實(shí)現(xiàn)多點(diǎn)廣播時(shí)，MulticastSocket類是實(shí)現(xiàn)這一功能的關(guān)鍵，當(dāng)MulticastSocket把一個(gè)DatagramPacket發(fā)送到多點(diǎn)廣播的IP地址，該數(shù)據(jù)報(bào)將被自動(dòng)廣播到加入該地址的所有MulticastSocket類既可以發(fā)送數(shù)據(jù)報(bào)到多點(diǎn)廣播地址，也可以接受其他主機(jī)的廣播信息。

MulticastSocket有點(diǎn)像DatagramSocket，事實(shí)上MulticastSocket是特殊的DatagramSocket。若要發(fā)送一個(gè)數(shù)據(jù)報(bào)時(shí)，可使用隨機(jī)端口段間MulticastSocket，也可以指定端口來創(chuàng)建MulticastSocket。

MulticastSocket提供了如下三個(gè)構(gòu)造器

public MulticastSocket():使用本機(jī)默認(rèn)地址、隨機(jī)端口來創(chuàng)建一個(gè)MulticastSocket對(duì)象。
public MulticastSocket(int number):使用本機(jī)默認(rèn)地址、指定端口來創(chuàng)建一個(gè)MulticastSocket對(duì)象。
public MulticastSocket(SocketAddress bindaddr):使用本機(jī)指定IP地址、指定端口來創(chuàng)建一個(gè)MulticastSocket對(duì)象。

創(chuàng)建一個(gè)MulticastSocket對(duì)象后，還需要將該MulticastSocket加入到指定的多點(diǎn)廣播地址，MulticastSocket使用joinGroup()方法來加入指定組；使用leaveGroup()方法脫離一個(gè)組。

joinGroup(InetAddress multicastAddr)：將該MulticastSocket加入指定的多點(diǎn)廣播地址
leaveGroup(InetAddress multicastAddr)：讓該MulticastSocket離開指定的多點(diǎn)廣播地址。

在某些系統(tǒng)中，可能有多個(gè)網(wǎng)絡(luò)接口。這可能會(huì)對(duì)多點(diǎn)廣播帶來問題，這時(shí)候程序需要在一個(gè)指定的網(wǎng)絡(luò)接口上監(jiān)聽，通過調(diào)用setInterface可選擇MulticastSocket所使用的網(wǎng)絡(luò)接口；頁可以使用getInterface方法查詢MulticastSocket監(jiān)聽的網(wǎng)絡(luò)接口。

如果創(chuàng)建僅用于發(fā)送數(shù)據(jù)報(bào)的MulticastSocket對(duì)象，則使用默認(rèn)地址、隨機(jī)端口即可。但如果創(chuàng)建接收用的MulticastSocket對(duì)象，則該MulticastSocket對(duì)象必須有指定端口，否則發(fā)送方無法確定發(fā)送的數(shù)據(jù)報(bào)的目標(biāo)端口。

MulticastSocket用于發(fā)送，接收數(shù)據(jù)報(bào)的方法與DatagramSocket的完全一樣。但MulticastSocket比DatagramSocket多一個(gè)setTimeToLive(int ttl)的方法，該ttl參數(shù)設(shè)置數(shù)據(jù)報(bào)最多可以跨過幾個(gè)網(wǎng)絡(luò)，當(dāng)ttl為0時(shí)，指定數(shù)據(jù)報(bào)應(yīng)停留在本地主機(jī)；當(dāng)ttl的值為1時(shí)，指定數(shù)據(jù)報(bào)發(fā)送到本地局域網(wǎng)；當(dāng)ttl的值為32時(shí)，意味著只能發(fā)送到本站點(diǎn)的網(wǎng)絡(luò)上；當(dāng)ttl為64時(shí)，意味著數(shù)據(jù)報(bào)應(yīng)保留在本地區(qū)。當(dāng)ttl為128時(shí)，意味著數(shù)據(jù)報(bào)應(yīng)保留在本大洲。當(dāng)ttl為255時(shí)，意味著數(shù)據(jù)報(bào)可發(fā)送到所有地方。默認(rèn)情況下，該ttl的值為1。

使用MulticastSocket進(jìn)行多點(diǎn)廣播時(shí)所有通信實(shí)體都是平等的，他們都將自己的數(shù)據(jù)報(bào)發(fā)送到多點(diǎn)廣播IP地址，并使用MulticastSocket接收其他人發(fā)送的廣播數(shù)據(jù)報(bào)。

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.Scanner;
 
//讓該類實(shí)現(xiàn)Runnable接口，該類的實(shí)例可作為線程的target
public class Test implements Runnable {
 // 使用常量作為本程序的多點(diǎn)廣播IP地址
 private static final String BROADCAST_IP = "230.0.0.1";
 // 使用常量作為本程序的多點(diǎn)廣播目的的端口
 public static final int BROADCAST_PORT = 30000;
 // 定義每個(gè)數(shù)據(jù)報(bào)的最大大小為4K
 private static final int DATA_LEN = 4096;
 // 定義本程序的MulticastSocket實(shí)例
 private MulticastSocket socket = null;
 private InetAddress broadcastAddress = null;
 private Scanner scan = null;
 // 定義接收網(wǎng)絡(luò)數(shù)據(jù)的字節(jié)數(shù)組
 byte[] inBuff = new byte[DATA_LEN];
 // 以指定字節(jié)數(shù)組創(chuàng)建準(zhǔn)備接受數(shù)據(jù)的DatagramPacket對(duì)象
 private DatagramPacket inPacket = new DatagramPacket(inBuff, inBuff.length);
 // 定義一個(gè)用于發(fā)送的DatagramPacket對(duì)象
 private DatagramPacket outPacket = null;
 
 public void init() throws IOException {
 try {
  // 創(chuàng)建用于發(fā)送、接收數(shù)據(jù)的MulticastSocket對(duì)象
  // 因?yàn)樵揗ulticastSocket對(duì)象需要接收，所以有指定端口
  socket = new MulticastSocket(BROADCAST_PORT);
  broadcastAddress = InetAddress.getByName(BROADCAST_IP);
  // 將該socket加入指定的多點(diǎn)廣播地址
  socket.joinGroup(broadcastAddress);
  // 設(shè)置本MulticastSocket發(fā)送的數(shù)據(jù)報(bào)被回送到自身
  socket.setLoopbackMode(false);
  // 初始化發(fā)送用的DatagramSocket，它包含一個(gè)長度為0的字節(jié)數(shù)組
  outPacket = new DatagramPacket(new byte[0], 0, broadcastAddress, BROADCAST_PORT);
  // 啟動(dòng)以本實(shí)例的run()方法作為線程體的線程
  new Thread(this).start();
  // 創(chuàng)建鍵盤輸入流
  scan = new Scanner(System.in);
  // 不斷讀取鍵盤輸入
  while (scan.hasNextLine()) {
  // 將鍵盤輸入的一行字符串轉(zhuǎn)換字節(jié)數(shù)組
  byte[] buff = scan.nextLine().getBytes();
  // 設(shè)置發(fā)送用的DatagramPacket里的字節(jié)數(shù)據(jù)
  outPacket.setData(buff);
  // 發(fā)送數(shù)據(jù)報(bào)
  socket.send(outPacket);
  }
 } finally {
  socket.close();
 }
 }
 
 public void run() {
 try {
  while (true) {
  // 讀取Socket中的數(shù)據(jù)，讀到的數(shù)據(jù)放在inPacket所封裝的字節(jié)數(shù)組里。
  socket.receive(inPacket);
  // 打印輸出從socket中讀取的內(nèi)容
  System.out.println("聊天信息：" + new String(inBuff, 0, inPacket.getLength()));
  }
 }
 // 捕捉異常
 catch (IOException ex) {
  ex.printStackTrace();
  try {
  if (socket != null) {
   // 讓該Socket離開該多點(diǎn)IP廣播地址
   socket.leaveGroup(broadcastAddress);
   // 關(guān)閉該Socket對(duì)象
   socket.close();
  }
  System.exit(1);
  } catch (IOException e) {
  e.printStackTrace();
  }
 }
 }
 
 public static void main(String[] args) throws IOException {
 new Test().init();
 }
}

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

最新評(píng)論