个人中心
gpt4 book ai didi

ajax - 如何从网页调用此 Comets 应用程序

转载 作者：行者123 更新时间：2023-11-28 22:15:16 25 4
gpt4 key购买 nike

我已经实现了 http://tomcat.apache.org/tomcat-6.0-doc/aio.html 中显示的两个类它提供了一个使用 Tomcat 的 Comet 实现的 Messenger 应用程序。

如何将其连接到 Web 界面并显示一些内容。

我认为这些是基本步骤(我不知道细节)。

  1. 我应该创建一些传统事件 - 按钮点击或 AJAX 事件 - 调用 ChatServlet 并传入 CometEvent(以某种方式) - 也许开始
  2. 从那时起，每次我想使用 READ 事件作为输入参数向客户端发送内容时，我的代码都会调用事件方法。

我复制了以下两个类:

package controller;

import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.util.ArrayList;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.catalina.CometEvent;
import org.apache.catalina.CometProcessor;

public class ChatServlet extends HttpServlet implements CometProcessor {

protected ArrayList<HttpServletResponse> connections = new     ArrayList<HttpServletResponse>();
protected MessageSender messageSender = null;

public void init() throws ServletException {
    messageSender = new MessageSender();
    Thread messageSenderThread = new Thread(messageSender, "MessageSender["
            + getServletContext().getContextPath() + "]");
    messageSenderThread.setDaemon(true);
    messageSenderThread.start();
}

public void destroy() {
    connections.clear();
    messageSender.stop();
    messageSender = null;
}

    /**
     * Process the given Comet event.
     * 
     * @param event
     *            The Comet event that will be processed
     * @throws IOException
     * @throws ServletException
     */
public void event(CometEvent event) throws IOException, ServletException {
    HttpServletRequest request = event.getHttpServletRequest();
    HttpServletResponse response = event.getHttpServletResponse();
    if (event.getEventType() == CometEvent.EventType.BEGIN) {
        log("Begin for session: " + request.getSession(true).getId());
        PrintWriter writer = response.getWriter();
        writer
                .println("<!doctype html public \"-//w3c//dtd html 4.0 transitional//en\">");
        writer
                .println("<head><title>JSP Chat</title></head><body bgcolor=\"#FFFFFF\">");
        writer.flush();
        synchronized (connections) {
            connections.add(response);
        }
    } else if (event.getEventType() == CometEvent.EventType.ERROR) {
        log("Error for session: " + request.getSession(true).getId());
        synchronized (connections) {
            connections.remove(response);
        }
        event.close();
    } else if (event.getEventType() == CometEvent.EventType.END) {
        log("End for session: " + request.getSession(true).getId());
        synchronized (connections) {
            connections.remove(response);
        }
        PrintWriter writer = response.getWriter();
        writer.println("</body></html>");
        event.close();
    } else if (event.getEventType() == CometEvent.EventType.READ) {
        InputStream is = request.getInputStream();
        byte[] buf = new byte[512];
        do {
            int n = is.read(buf); // can throw an IOException
            if (n > 0) {
                log("Read " + n + " bytes: " + new String(buf, 0, n)
                        + " for session: "
                        + request.getSession(true).getId());
            } else if (n < 0) {
                // error(event, request, response);
                System.out.println("you have an error");

                return;
            }
        } while (is.available() > 0);
    }
}
}
package controller;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import javax.servlet.http.HttpServletResponse;

public class MessageSender implements Runnable {

protected boolean running = true;
protected ArrayList<String> messages = new ArrayList<String>();
protected ArrayList<HttpServletResponse> connections = new ArrayList<HttpServletResponse>();

public MessageSender() {
}

public void stop() {
    running = false;
}

/**
 * Add message for sending.
 */
public void send(String user, String message) {
    synchronized (messages) {
        messages.add("[" + user + "]: " + message);
        messages.notify();
    }
}

public void run() {

    while (running) {

        if (messages.size() == 0) {
            try {
                synchronized (messages) {
                    messages.wait();
                }
            } catch (InterruptedException e) {
                // Ignore
            }
        }

        synchronized (connections) {
            String[] pendingMessages = null;
            synchronized (messages) {
                pendingMessages = messages.toArray(new String[0]);
                messages.clear();
            }
            // Send any pending message on all the open connections
            for (int i = 0; i < connections.size(); i++) {
                try {
                    PrintWriter writer = connections.get(i).getWriter();
                    for (int j = 0; j < pendingMessages.length; j++) {
                        writer.println(pendingMessages[j] + "<br>");
                    }
                    writer.flush();
                } catch (IOException e) {
                    System.out.println("IOExeption sending message" + e);
                }
            }
        }

    }

}

}

最佳答案

这里有一个完整的 Tomcat 示例，底部有源代码可供下载:Developing with Comet and Java

关于ajax - 如何从网页调用此 Comets 应用程序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/1159819/

25 4 0
文章推荐： java - 如何使用旧的 JSESSIONID 创建 HttpSession？
文章推荐： iOS:CF 对象泄漏
文章推荐： ios - TTAtributedLabel 设置多色使用 UIColor，它在 header 中用 MACRO 定义？
文章推荐： google-app-engine - 如何配置 Tomcat 以在 Mac OS X 上运行 Google App Engine + GWT 应用程序？
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com