Java P2P 實戰：基於 IP 多播的對等節點自動發現機制

對等節點發現機制對比

IP 多播發現原理

• 多播為無連線、不可靠傳輸（UDP 基礎），一份封包可同時送達多個主機。
• 節點定期向多播群組（如 230.0.0.1:7777）發送宣告封包，內含主機名與通訊埠。
• 其他節點監聽該群組，解析宣告資訊，建立直接通訊通道。

核心框架設計：五大介面/類別

1. Member：管理通訊細節，內含 MemberClient（發送宣告）與 MemberServer（接收宣告）兩個執行緒。
2. MemberManager：維護已知節點參考集合。
3. Reference：抽象類別，定義節點參考的 equals/hashCode 邏輯，應用層實作具體欄位（如 host/port）。
4. Message：介面，定義高層訊息結構與位元組陣列雙向轉換，含參考讀寫方法。
5. MessageFactory：抽象類別，建立發送/接收訊息實例，擁有隨機 ID 過濾自我發送的封包。

關鍵程式碼片段

MemberClient：定期廣播宣告

private class MemberClient extends Thread {
    public void run() {
        while (true) {
            Message msg = factory.createSendMessage();
            Reference ref = msg.createReference();
            msg.writeReference(ref);
            msg.sync();
            byte[] data = msg.getByteArray();
            DatagramPacket pkt = new DatagramPacket(data, data.length, groupAddr, port);
            new MulticastSocket().send(pkt);
            wait(period); // 間隔發送
        }
    }
}

MemberServer：接收並解碼宣告

private class MemberServer extends Thread {
    public void run() {
        MulticastSocket socket = new MulticastSocket(port);
        socket.joinGroup(groupAddr);
        while (true) {
            Message msg = factory.createReceiveMessage();
            socket.receive(new DatagramPacket(msg.getByteArray(), msg.getByteArray().length));
            msg.sync();
            if (!factory.isMine(msg)) { // 過濾自己發的
                Reference ref = msg.createReference();
                msg.readReference(ref);
                manager.addReference(ref);
            }
        }
    }
}

整合至 P2P 應用

• 移除原有靜態配置檔中的節點列表，改用發現機制動態維護。
• 重新設計錯誤處理：節點隨時可能消失，應用層需具備重連與容錯能力。

下一步挑戰：跨越防火牆、NAT 與閘道的直接通訊。