任务队列有问题吗？

Question

我正在使用谷歌应用程序引擎任务队列。这是我第一次。我找到了一个教程，但遇到了一些问题。以下是我用来检查任务队列的两个 servlet：

 public class GAEJSignupSubscriberServlet extends HttpServlet {

   private static final Logger _logger = Logger.getLogger(GAEJSignupSubscriberServlet.class.getName());


public void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {


    resp.setContentType("text/plain");
    resp.getWriter().println("Hello, world");

    String strCallResult = "";
    resp.setContentType("text/plain");
    try {
        String strEmailId = req.getParameter("emailid");
        _logger.info("Got a Signup Subscriber Request for Email ID : " + strEmailId);
        //
        // PUT YOUR TASK CODE HERE
        //
        if(strEmailId.equals("mh")){
        System.out.println("email-id" + strEmailId);
        }
        strCallResult = "SUCCESS: Subscriber Signup";
        _logger.info(strCallResult);
        resp.getWriter().println(strCallResult);
        }
        catch (Exception ex) {
        strCallResult = "FAIL: Subscriber Signup : " + ex.getMessage();
        _logger.info(strCallResult);
        resp.getWriter().println(strCallResult);
        }
}
@Override
    public void doPost(HttpServletRequest req, HttpServletResponse resp)
       throws ServletException, IOException {
          doGet(req, resp);
    }

 }

第二个 servlet 是：

  public class GAEJCreateTaskServlet extends HttpServlet {

public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws IOException {
    this.doPost(req, resp);
}

public void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws IOException {
    resp.setContentType("text/plain");
    resp.getWriter().println("Hello, world");

    String strCallResult = "";
    resp.setContentType("text/plain");
    try {
        //Extract out the To, Subject and Body of the Email to be sent
        String strEmailId = req.getParameter("emailid");

        //Do validations here. Only basic ones i.e. cannot be null/empty

        if (strEmailId == null) throw new Exception("Email Id field cannot be empty.");

        //Trim the stuff
        strEmailId = strEmailId.trim();
        if (strEmailId.length() == 0) throw new Exception("Email Id field cannot be empty.");
        //Queue queue = QueueFactory.getDefaultQueue();
        Queue queue = QueueFactory.getQueue("subscription-queue");
        queue.add(TaskOptions.Builder.withUrl("/gaejsignupsubscriber").param("emailid",strEmailId));
        strCallResult = "Successfully created a Task in the Queue";
        resp.getWriter().println(strCallResult);
        }
        catch (Exception ex) {
        strCallResult = "Fail: " + ex.getMessage();
        resp.getWriter().println(strCallResult);
        }
}
    @Override
    public void doPost(HttpServletRequest req, HttpServletResponse resp)
       throws ServletException, IOException {
          doGet(req, resp);
    }

 }

我使用此 URL 调用 GAEJCreateTaskServlet：

 http://localhost:8080/[email protected]

现在的问题是，当我调用此 url 时，我看到创建任务的输出，但在开发控制台中我看不到任何任务在队列中。如果我从两个 servlet 中删除 doPost 函数，那么我会在队列中看到该任务，但是当我运行它时，什么也没有发生，任务仍然存在。为什么会这样，我该如何解决这个问题。提前致谢。

Answer 1

您很可能看不到该任务，因为它已经执行了。检查您的日志（开发中的控制台或生产中管理控制台上的日志记录页面）以查看任务处理程序抛出的异常（如果有）并修复它。

Answer 2

不确定您是否应该使用这个 doGet 方法。你有 2 个具有相同签名的，但是如果你说它打印成功消息，这应该不能解决你的问题。

public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws IOException {
    this.doPost(req, resp);
}

Answer 3

GAEJSignupSubscriberServlet 不需要设置响应内容类型，或写入响应。当从任务中调用 servlet 时，永远不会看到响应，想象一下它被发送到 /dev/null。您应该从 servlet 登录。

GAEJSignupSubscriberServlet 不需要任何 doGet 方法，只需要 doPost，因为默认情况下使用 POST 方法创建任务。如果您更喜欢使用 GET，请使用 method(TaskOptions.Method.GET) 配置 TaskOptions