在这篇文章中，讨论了一个使用 MulticastSocket (Java Platform SE 7) 类的群聊应用程序。 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: ");
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 相比要快一些。