java多點傳播MulticastSocket

在單點傳播模式中有伺服器端和用戶端之分，而多點傳播模式與單點傳播模式不同，每個端都是以路由器或交換機做為中轉廣播站，任意一端向路由器或交換機發送消息，路由或交換機負責發送其他節點，每個節點都是同等的。是以在程式設計模式上用同一個類表示即可——MulticastSocket。

    MulticastSocket屬于jdk提供的類，類路徑為java.net.MulticastSocket，利用此類可以很友善地實作多點傳播功能，下面展示一個簡單例子，兩個節點之間通過多點傳播傳輸消息。

①節點一，指定多點傳播位址為228.0.0.4，端口為8000，節點一通過調用MulticastSocket的joinGroup方法申請将節點一加入到多點傳播隊伍中，接着使用一個無限循環往組裡發“Hello from node1”消息，這是為了友善節點2加入後接收節點1的消息做準備，需要說明的是多點傳播是通過DatagramPacket對象發送消息的，調用MulticastSocket的send方法即可把消息發送出去。這裡為了縮減例子長度省去了退出組及關閉套接字的一些操作，實際使用中需完善。

public class Node1 {

private static int port = 8000;

private static String address = "228.0.0.4";

public static void main(String[] args) throws Exception {

try {

InetAddress group = InetAddress.getByName(address); 

MulticastSocket mss = null;

mss = new MulticastSocket(port);

mss.joinGroup(group);

while (true) {

String message = "Hello from node1";

byte[] buffer = message.getBytes(); 

DatagramPacket dp = new DatagramPacket(buffer, buffer.length,

group, port);

mss.send(dp); 

Thread.sleep(1000);

}

} catch (IOException e) {

e.printStackTrace();

} 

②節點二，指定同樣的多點傳播位址與端口，申請加入與節點一相同的多點傳播組，接着通過循環不斷接收來自其他節點發送的消息，通過MulticastSocket的receive方法可讀到消息，将不斷接收到來自節點一發送的消息“receive from node1:Hello from node1”。當然節點2也可以往多點傳播組發送消息，因為每個節點都是同等的，隻要其他節點對多點傳播消息進行接收。如果你還想增加其他節點，盡管申請加入多點傳播組，所有節點都可以接收發送消息。

public class Node2 {

MulticastSocket msr = null;

msr = new MulticastSocket(port);

msr.joinGroup(group);

byte[] buffer = new byte[1024];

DatagramPacket dp = new DatagramPacket(buffer, buffer.length); 

msr.receive(dp); 

String s = new String(dp.getData(), 0, dp.getLength()); 

System.out.println("receive from node1:"+s);