Java網絡編程之組播小案例

網絡數據傳輸分為三類，單播，廣播，組播，其中組播是兼容前兩者特點。發送者每次發送的數據可以被組內的所有

接受者收到。在組內的發送者和每一個接受者之間實現點到多點網絡傳輸，也稱多點傳送。

組播是一種介於單播傳輸和廣播傳輸之間的一種中間技術。當采用組播方式傳送數據包時，發送方只需要發送一份

相同的數據包，通過路由器動態決定數據包的路由，即尋找組播組的地址，只有必要時才賦值數據，然后將數據發送到

這個組的每一個主機中。它可以大大提高數據傳送效率，減少了骨干網絡出現網絡擁塞的可能性。比前兩種方式效率都

很好。

下面來演示一下使用Java Socket的組播類實現一個組播的小案例

首先是接收端

package com.bird.test; import java.net.DatagramPacket; import java.net.InetAddress; import java.net.MulticastSocket; import java.util.Date; /** * 組播的客戶端 * @author Bird * */ public class MulticastReceive { public static void main(String[] args) throws Exception { test(); } public static void test() throws Exception{ InetAddress group = InetAddress.getByName("224.0.0.2");//組播地址 int port = 8888; MulticastSocket msr = null;//創建組播套接字 try { msr = new MulticastSocket(port); msr.joinGroup(group);//加入連接 byte[] buffer = new byte[8192]; System.out.println("接收數據包啟動！(啟動時間: "+new Date()+")"); while(true){ //建立一個指定緩沖區大小的數據包 DatagramPacket dp = new DatagramPacket(buffer, buffer.length); msr.receive(dp); String s = new String(dp.getData(),0,dp.getLength()); //解碼組播數據包 System.out.println(s); } } catch (Exception e) { e.printStackTrace(); }finally{ if(msr!=null){ try { msr.leaveGroup(group); msr.close(); } catch (Exception e2) { // TODO: handle exception } } } } }
然后是發送端

package com.bird.test; import java.net.DatagramPacket; import java.net.InetAddress; import java.net.MulticastSocket; import java.util.Date; /** * 組播的服務端 * @author Bird * */ public class MulticastSender { public static void server() throws Exception{ InetAddress group = InetAddress.getByName("224.0.0.2");//組播地址 int port = 8888; MulticastSocket mss = null; try { mss = new MulticastSocket(port); mss.joinGroup(group); System.out.println("發送數據包啟動！（啟動時間"+new Date()+")"); while(true){ String message = "Hello "+new Date(); byte[] buffer = message.getBytes(); DatagramPacket dp = new DatagramPacket(buffer, buffer.length,group,port); mss.send(dp); System.out.println("發送數據包給 "+group+":"+port); Thread.sleep(1000); } } catch (Exception e) { e.printStackTrace(); }finally{ try { if(mss!=null){ mss.leaveGroup(group); mss.close(); } } catch (Exception e2) { // TODO: handle exception } } } public static void main(String[] args) throws Exception { server(); } }
通過開啟多個接收端，然后開啟發送端，就可以實現組播的效果