如何使用 applet 和 servlet 在两个客户端和仅两个客户端之间发起聊天？

Question

我首先需要为我之前的问题道歉。 （你可以查看我的个人资料）他们似乎提出的问题多于给出的答案。因此，我提出了引发所有这些荒谬问题的实际问题。

我正在尝试设计一个聊天小程序。到目前为止，我已经编写了applet、servlet 以及applet 和servlet 之间的通信。 servlet 端的代码使得我能够使用小程序在客户端之间建立聊天，但该代码更像是广播所有功能，即所有客户端都将相互聊天。这是我开始设计聊天小程序时的第一个目标。第二步是仅在两个特定用户之间聊天，就像我们拥有的任何其他聊天应用程序一样。这就是我的想法：

1. 我创建一个具有“broadcast-all”代码的 servlet 实例。
2. 然后，我将此实例的地址传递给相应的客户端。
3. 2 个客户端小程序使用该地址进行聊天。从技术上讲，该代码是“全部广播”，但由于只有 2 个客户端连接到它，因此它提供了两个客户端之间的聊天功能。因此，2 个客户端组成的组具有同一 servlet 的不同实例，并且每个实例最多处理两个客户端之间的聊天。

然而，正如预料的那样，这个想法并没有实现！

我尝试创建 servlet 的实例，但唯一的解决方案是在 servlet 端使用会话，而且我不知道如何使用此会话进行以后的通信。

我现在知道如何使用 request.getSession()。因此，我在小程序的 param 标记中设置了会话，并使用它与 servlet 进行进一步的通信。但是我如何使用这些数据在两个客户端之间建立聊天？正如我之前所写，我的broadcast_all聊天代码如下：

public class CustomerServlet extends HttpServlet {

public String getNextMessage() {
    // Create a message sink to wait for a new message from the
    // message source.
    return new MessageSink().getNextMessage(source);
}

@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
    ObjectOutputStream dout = new ObjectOutputStream(response.getOutputStream());
    String recMSG = getNextMessage();
    dout.writeObject(recMSG);
    dout.flush();
}

public void broadcastMessage(String message) {
    // Send the message to all the HTTP-connected clients by giving the
    // message to the message source
    source.sendMessage(message);
}

@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
    try {
        ObjectInputStream din= new ObjectInputStream(request.getInputStream());
        String message = (String)din.readObject();
        ObjectOutputStream dout = new ObjectOutputStream(response.getOutputStream());
        dout.writeObject("1");
        dout.flush();
        if (message != null) {
            broadcastMessage(message);
        }
        // Set the status code to indicate there will be no response
        response.setStatus(response.SC_NO_CONTENT);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
MessageSource source = new MessageSource();
}

class MessageSource extends Observable {
public void sendMessage(String message) {
    setChanged();
    notifyObservers(message);
}
}
class MessageSink implements Observer {
String message = null;  // set by update() and read by getNextMessage()
// Called by the message source when it gets a new message
synchronized public void update(Observable o, Object arg) {
    // Get the new message
    message = (String)arg;
    // Wake up our waiting thread
    notify();
}
// Gets the next message sent out from the message source
synchronized public String getNextMessage(MessageSource source) {
    // Tell source we want to be told about new messages
    source.addObserver(this);
    // Wait until our update() method receives a message
    while (message == null) {
        try {
            wait();
        } catch (Exception e) {
            System.out.println("Exception has occured! ERR ERR ERR");
        }
    }
    // Tell source to stop telling us about new messages
    source.deleteObserver(this);
    // Now return the message we received
    // But first set the message instance variable to null
    // so update() and getNextMessage() can be called again.
    String messageCopy = message;
    message = null;
    return messageCopy;
}
}

在小程序方面，我有一个线程将使用 GET 方法连接到上面的 servlet 以获取新消息。它使用 while 循环，并阻塞直到从 servlet 收到消息。每当客户端输入消息时，主线程都会使用 POST 方法与 servlet 进行通信。目前所有客户都在与大家聊天。我想使用上面使用的相同方法（或者如果可能的话任何其他方式）来建立两个客户端之间和仅两个客户端之间的聊天。我可能会在小程序中设置另一个线程来检查是否有任何其他用户希望与其聊天，然后交换一些数据，以便只有这两个用户聊天...

然后我尝试修改我的广播所有代码。在该代码中，我使用了实现 Observer 和 Observable 接口的类。所以我得到的下一个想法是：

1. 创建一个 Observable 类的新对象（比如 class_1）。该对象为 2 个客户端所共有。
2. 想要聊天的 2 个客户端将使用 class_1 的相同对象。
3. 其他 2 个客户端将使用 class_1 的不同对象。

但这里的问题在于实现 Observer 接口的类（比如 class_2）。由于观察者监视同一类型的类，即 class_1，我如何建立一个观察者监视 class_1 的一个对象，另一个观察者监视同一类 class_1 的另一个对象（因为 notifyObservers() 会通知所有观察者，我可以' t 将特定观察者分配给特定对象）？

我首先决定问一些个人问题，比如如何在 stackoverflow 中创建 servlet 的实例、使用 observable 和observer 的对象等等……但我更加困惑了。谁能给我一个想法如何仅在两个客户端之间建立聊天？（我使用的是 Http 而不是套接字或 RMI）。

问候， 米图恩.

PS感谢所有回复我之前（荒谬）问题的人。我应该早点说出目的，这样你们才能更好地帮助我。

Answer 1

您需要使用 ServletContext#setAttribute() 将所有连接的用户存储在 application 范围内的 Map 中。 String 表示唯一的用户标识符（聊天昵称？）。您还需要使用 HttpSession#setAttribute() 将特定聊天 User 存储在 session 范围内。您还需要将各个聊天中的其他用户存储在相关用户的会话范围内的Map中。您可以通过getAttribute()方法获取属性。

这样您就可以知道哪些用户全部可用、哪些用户在当前会话中以及正在与哪些用户单独聊天。

Answer 2

这是一种粗略的方法，但我就是找不到可行的解决方案。我所做的是让所有用户连接到具有broadcastAll 代码的servlet。 每个用户都会知道他正在与哪个其他用户聊天。因此，在发送消息时，用户会将他的姓名以及正在与他聊天的用户的姓名附加到消息中。由于它是广播所有代码，因此每个连接的用户都会收到该消息。用户收到消息后，解析该消息以获取发送该消息的用户以及该消息的目标用户的名称。它将这两个名称与其记录进行比较 - 请参阅前面粗体的声明。如果匹配，它将显示该消息，否则忽略它。

再说一遍，这是一种粗略的方法，我相信有更好的解决方案。