Java聊天服务器

发布于 2024-07-27 20:55:29 字数 446 浏览 6 评论 0原文

我正在编写一个基于 java 的聊天服务器，目前我的设计基于以下内容：- 当聊天室中的一个人发送消息时，服务器端的聊天室类会循环发送相同的消息给房间中的每个参与者。显然，这是一个糟糕的设计，因为网络调用是在循环中对各个参与者进行的。因此，举例来说，假设聊天室中有 10 个人。当一个用户发送一条消息时，聊天室类将循环发送相同的消息给所有 10 个人。如果可以说，循环中的第五个人的连接很差，那么第六个人..第十个人看到该消息的时间就会受到影响。

如果我从每个房间的单播转移到多播，那么我如何获得每个聊天室的私有多播组 IP？此外，每个聊天室都有单独的组似乎有些过分了。主要问题之一是，当我通过循环回复房间中的用户时，通过套接字连接发送数据的方法被阻塞。因此，我在想如果我使用非阻塞 NIO 套接字，然后循环发送消息给收件人，是否可以解决问题？是否还有其他巧妙的技巧可以优化向房间内的收件人发送数据？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

记忆消瘦 2024-08-03 20:55:29

简单的实现是每个客户端使用两个线程。一个线程从套接字读取数据，另一个线程向套接字写入数据。如果你的客户很少，那就没问题了。你必须了解蔚来才能处理许多客户。（“很多”意味着线程模型不能很好地工作。）

客户端的读取线程从套接字读取整个消息并将其放入 ChatRoom 对象的队列中。聊天室有一个线程从队列中取出消息并将它们放入客户端的队列中。客户端写入线程轮询其队列并将消息写入套接字。

ChatRoom 有一个线程来接受连接并创建 Client 对象并将它们放入 Collection 中。它有另一个线程来轮询其消息队列并将消息分发到客户端队列。

Apache Mina 有一个使用 NIO 的示例

回复收藏 0 原文

眼藏柔 2024-08-03 20:55:29

我同意连续循环你的收件人是一个坏主意。为此，您可以考虑使用线程池来提供帮助。但是，我认为多播将是您最好的选择。它非常适合聊天室模型。您只需要发送一次，您的迭代方法就会得到解决。您可以通过在地址中指定不同的端口来获取唯一的组 ID。

回复收藏 0 原文

咋地 2024-08-03 20:55:29

简单的方法是每个客户端连接使用两个线程。一个线程负责从客户端读取消息，另一个线程负责发送消息，从而可以同时从客户端发送/接收消息。

为了避免在循环客户端连接以广播消息时发生网络调用，服务器线程应将消息添加到队列中以发送到客户端。 java.util.concurrent 中的 LinkedBlockingQueue 非常适合此目的。下面是一个例子：

/**
 * Handles outgoing communication with client
 */
public class ClientConnection extends Thread {
    private Queue<String> outgoingMessages = new LinkedBlockingQueue<String>(MAX_OUTGOING);
    // ...
    public void queueOutgoing(String message) {
        if (!outgoingMessages.offer(message)) {
            // Kick slow clients
            kick();
        }
    }

    public void run() {
        // ...
        while (isConnected) {
            List<String> messages = new LinkedList<String>();
            outgoingMessages.drainTo(messages);
            for (String message : messages) {
                send(message);
            }
            // ...
        }
    }
}

public class Server {
    // ...
    public void broadcast(String message) {
        for (ClientConnection client : clients) {
            client.queueOutgoing(message);
        }
    }
}

The simple approach is to use two threads per client connection. One thread handles reading messages from the client the other for sending messages, thereby can send/receive messages from the client simultaneously.

To avoid network calls when looping over the client connections to broadcast a message, the server thread should add the messages into a queue to send to the client. LinkedBlockingQueue in java.util.concurrent is perfect for this. Below is an example:

/**
 * Handles outgoing communication with client
 */
public class ClientConnection extends Thread {
    private Queue<String> outgoingMessages = new LinkedBlockingQueue<String>(MAX_OUTGOING);
    // ...
    public void queueOutgoing(String message) {
        if (!outgoingMessages.offer(message)) {
            // Kick slow clients
            kick();
        }
    }

    public void run() {
        // ...
        while (isConnected) {
            List<String> messages = new LinkedList<String>();
            outgoingMessages.drainTo(messages);
            for (String message : messages) {
                send(message);
            }
            // ...
        }
    }
}

public class Server {
    // ...
    public void broadcast(String message) {
        for (ClientConnection client : clients) {
            client.queueOutgoing(message);
        }
    }
}

回复收藏 0 原文

~没有更多了~