MulticastSocket 是一個 (UDP) DatagramSocket，具有加入 Internet 上其他多播主機「群組」的附加功能。
import java.net.*;
import java.io.*;
import java.util.*;
public class GroupChat {
private static final String TERMINATE = "Exit";
static String name;
static volatile boolean finished = false;
public static void main(String[] args) {
if (args.length != 2)
System.out.println("Two arguments required: <multicast-host> <port-number>");
else {
try {
InetAddress group = InetAddress.getByName(args[0]);
int port = Integer.parseInt(args[1]);
Scanner sc = new Scanner(System.in);
System.out.print("Enter your name: ");
name = sc.nextLine();
MulticastSocket socket = new MulticastSocket(port);
// Since we are deploying
socket.setTimeToLive(0);
// this on localhost only (For a subnet set it as 1)
socket.joinGroup(group);
Thread t = new Thread(new ReadThread(socket, group, port));
// Spawn a thread for reading messages
t.start();
// sent to the current group
System.out.println("Start typing messages...\n");
while (true) {
String message;
message = sc.nextLine();
if (message.equalsIgnoreCase(GroupChat.TERMINATE)) {
finished = true;
socket.leaveGroup(group);
socket.close();
break;
}
message = name + ": " + message;
byte[] buffer = message.getBytes();
DatagramPacket datagram = new DatagramPacket(buffer, buffer.length, group, port);
socket.send(datagram);
}
} catch (SocketException se) {
System.out.println("Error creating socket");
se.printStackTrace();
} catch (IOException ie) {
System.out.println("Error reading/writing from/to socket");
ie.printStackTrace();
}
}
}
}
class ReadThread implements Runnable {
private MulticastSocket socket;
private InetAddress group;
private int port;
private static final int MAX_LEN = 1000;
ReadThread(MulticastSocket socket, InetAddress group, int port) {
this.socket = socket;
this.group = group;
this.port = port;
}
@Override
public void run() {
while (!GroupChat.finished) {
byte[] buffer = new byte[ReadThread.MAX_LEN];
DatagramPacket datagram = new DatagramPacket(buffer, buffer.length, group, port);
String message;
try {
socket.receive(datagram);
message = new String(buffer, 0, datagram.getLength(), "UTF-8");
if (!message.startsWith(GroupChat.name))
System.out.println(message);
} catch (IOException e) {
System.out.println("Socket closed!");
}
}
}
}登入後複製
將檔案另存為 GroupChat.java 並使用 javac 編譯它，然後使用指定的兩個命令列參數來執行程式。多播主機由 D 類 IP 位址和標準 UDP 連接埠號碼指定。 D 類 IP 位址的範圍為 224.0.0.0 到 239.255.255.255（含）。位址 224.0.0.0 是保留位址，不應使用。
以下是上述程式的範例輸出：
我們使用多重播送主機IP位址為239.0.0.0，連接埠號碼為1234（因為連接埠號碼0 到1023 被保留）。該群組有 3 名成員：Ironman、CaptainAmerica 和 Groot。在發送訊息之前首先啟動所有三個終端，否則在啟動終端之前發送的訊息將丟失（因為沒有合併緩衝區來儲存訊息。）我們在這個應用程式中需要兩個線程。一個用於接受使用者輸入（使用 java.util.Scanner 類別），另一個用於讀取從其他客戶端發送的訊息。因此，我將執行讀取工作的執行緒分開到 ReadThreadclass 中。要離開群組，任何使用者都可以鍵入退出以終止會話。
上述程式在單機上執行。套接字程式設計適用於分散式程式設計。相同的程式碼片段出現在安裝了 Java 的不同機器上時可以滿足該要求。這只是最基本的服務邏輯。如果前端開發出來，這個專案會更吸引人。您可以使用 Java 的 AWT（抽象視窗工具包）或其高階對應 Java Swing 來開發前端。由於這不是 Socket 程式設計的一部分，因此我將在不深入了解細節的情況下保持不變。
附加點：
您可以透過在透過網路傳送訊息之前執行加密來合併網路安全功能。
凱撒密碼等原始技術或 RSA 等進階方法可用於執行加解密。您可以嘗試使用 Java 的 RMI（遠端方法呼叫）來執行相同的任務。
在這裡，您可以最大限度地利用 Java 提供的抽象。但是，如果您的主要目標是效率，那麼 Socket 程式設計是最佳選擇。由於它不需要任何運行時支持，因此與 RMI 相比要快一些。
以上是Java程式實作群組聊天應用程序，使用MulticastSocket實現的詳細內容。更多資訊請關注PHP中文網其他相關文章！
