亲宝软件园·资讯

展开

Java群聊应用程序

allway2 人气:0

在这篇文章中,讨论了一个使用 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: <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 相比要快一些。

加载全部内容

相关教程
猜你喜欢
用户评论