java comet 聊天—代码示例

Java Comet（也称为服务器推送）是一种在Web应用程序中实现实时通信的技术。它允许服务器向客户端推送数据，而不是依赖客户端发起请求。这种实时通信的能力使得聊天应用程序成为可能，其中多个用户可以实时交流。

在Java中，可以使用Servlet和长轮询（long polling）技术来实现Comet。长轮询是一种将请求保持在服务器端一段时间的技术，直到有新的数据可用或超时为止。

以下是一个简单的Java Comet聊天代码示例：

@WebServlet("/chat")
public class ChatServlet extends HttpServlet {
    private static final List<AsyncContext> clients = new ArrayList<>();
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        response.setContentType("text/html");
        response.setCharacterEncoding("UTF-8");
        final AsyncContext asyncContext = request.startAsync(request, response);
        asyncContext.setTimeout(0); // 永不超时
        clients.add(asyncContext);
        asyncContext.addListener(new AsyncListener() {
            public void onComplete(AsyncEvent event) throws IOException {
                clients.remove(asyncContext);
            }
            public void onTimeout(AsyncEvent event) throws IOException {
                clients.remove(asyncContext);
            }
            public void onError(AsyncEvent event) throws IOException {
                clients.remove(asyncContext);
            }
            public void onStartAsync(AsyncEvent event) throws IOException {
                // 不需要实现
            }
        });
    }
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String message = request.getParameter("message");
        for (AsyncContext asyncContext : clients) {
            try {
                PrintWriter writer = asyncContext.getResponse().getWriter();
                writer.write(message);
                writer.flush();
            } catch (IOException e) {
                // 处理异常
            }
        }
    }
}

在这个示例中，我们创建了一个名为ChatServlet的Servlet来处理聊天请求。在doGet方法中，我们使用AsyncContext来处理长轮询请求，并将AsyncContext添加到一个共享的列表中。然后，我们为AsyncContext添加一个AsyncListener，以便在请求完成、超时或发生错误时从列表中移除AsyncContext。

在doPost方法中，我们从请求参数中获取聊天消息，并将消息发送给所有客户端。我们遍历保存的AsyncContext列表，并通过AsyncContext的getResponse方法获取PrintWriter来写入消息。

通过这种方式，我们可以实现一个简单的Java Comet聊天应用程序，其中多个用户可以实时交流。