пристань 7 продолжений

я использую jetty-7.4.1.v20110513 и servlet-api-2.5

я пытался использовать продолжение в следующем сервлете.

 import java.io.*;
 import java.util.*;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServlet;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;

 import org.eclipse.jetty.continuation.*;



public class cs extends HttpServlet {

public void service(HttpServletRequest req, HttpServletResponse res)
throws java.io.IOException {

String reqId = req.getParameter("id");

Continuation cc = ContinuationSupport.getContinuation(req);

res.setContentType("text/plain");
res.getWriter().println("Request: "+reqId+"\tstart:\t"+new Date());
res.getWriter().flush();

cc.setTimeout(2000);
cc.suspend();

res.getWriter().println("Request: "+reqId+"\tend:\t"+new Date());
cc.complete();
}
}

Я ожидаю 2-секундную задержку, но когда я запускаю сервлет из браузера, я получаю следующий вывод без каких-либо задержек:

Request: null   start:  Sat May 21 15:25:02 IST 2011
Request: null   end:    Sat May 21 15:25:02 IST 2011

java jetty continuations
person ravi    schedule 22.05.2011    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Я полагаю, вы читаете это руководство. Задержка в 2 секунды может быть достигнута одним из следующих способов:

  • Либо добавьте Thread.sleep(2000) перед вторым res.getWriter().println().

  • Или удалите вызов Continuation.complete(), который заставит продолжение ожидать максимальное время, указанное в Continuation.setTimeout(). Что происходит сейчас, так это то, что вы немедленно уведомляете, что ваш «расчет» выполнен (через вызов cc.complete())

person Michael Spector    schedule 19.06.2011

arrow_upward
1
arrow_downward

Наконец-то я разобрался с продолжениями api. следующий код работал у меня. Спасибо за вашу поддержку, ребята.

import java.io.*;
import java.util.*;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.eclipse.jetty.continuation.*;

public class cs extends HttpServlet {

  public void doGet(HttpServletRequest req, HttpServletResponse res)
      throws java.io.IOException {

    String reqId = req.getParameter("id");

    Continuation cc = ContinuationSupport.getContinuation(req);

    res.setContentType("text/plain");
    res.getWriter().println("Request: " + reqId + "\tstart:\t" + new Date());
    res.getWriter().flush();

    cc.setTimeout(2000);
    cc.suspend();

    res.getWriter().println("Request: " + reqId + "\tend:\t" + new Date());
    if (cc.isInitial() != true) {
      cc.complete();
    }
  }
}

вывод:

Request: null   start:  Sat May 21 15:25:02 IST 2011
Request: null   end:    Sat May 21 15:25:02 IST 2011
Request: null   start:  Sat May 21 15:25:04 IST 2011
Request: null   end:    Sat May 21 15:25:04 IST 2011
person ravi    schedule 20.06.2011