私のアプリケーションは組み込みの Jetty を http インターフェイスとして使用しており、2 ～ 3 週間の稼働時間後にハングしているようです。調べてみると、眠っているスレッドがたくさんあったので、jvisualvm を使ってローカルで実行し、pyplot と一連の単純な get を使って調べてみたところ、スレッドの数は常に増えていて、ほとんどが眠っていることがわかりました。
私のコードは、非同期リスナーを使用して非同期コンテキストで非同期要求を具体的に処理し、基本的に、メイン アプリによって入力された結果ハッシュで結果が見つかるまで断続的にスリープします。結果が表示されない場合、リクエストはタイムアウトになります。
同僚から、私がリクエストを適切にクローズしていない可能性があるとの指摘がありました。これは事実ですか？私はあなたの批判のために私のコードを以下に添付しました（jvisualvmプロットの後）。ありがとう！
桟橋サーバー:
public class APIRequestHandler extends HttpServlet
{
private static final long serialVersionUID = -446741424265391138L;
private ConcurrentLinkedQueue<APIMessage> queue;
private ConcurrentHashMap<String, String> collector;
private int timeout;
private Logger logger;
private Selector selector;
public APIRequestHandler(Logger logger, Selector selector, ConcurrentLinkedQueue<APIMessage> queue,
ConcurrentHashMap<String, String> collector, int timeout)
{
this.logger = logger;
this.selector = selector;
this.queue = queue;
this.collector = collector;
this.timeout = timeout;
}
public void doGet(HttpServletRequest req, HttpServletResponse res)
throws java.io.IOException
{
String rid = req.getParameter("rid");
String targetId = req.getParameter("id");
String msg = req.getParameter("json");
logger.info("requestId: "+rid);
logger.info("targetId: "+targetId);
logger.info("json: "+msg);
// Send to channel
APIMessage m = new APIMessage();
m.rid = rid;
m.id = targetId;
m.json = msg + "\r\n";
// create the async context, otherwise getAsyncContext() will be null
final AsyncContext ctx = req.startAsync();
// set the timeout
ctx.setTimeout(this.timeout);
ctx.getRequest().setAttribute("rid",rid);
ctx.getRequest().setAttribute("startTime",System.currentTimeMillis()); // start time
// set up selector/queue
queue.add(m);
this.selector.wakeup();
// attach listener to respond to lifecycle events of this AsyncContext
ctx.addListener(new AsyncListener() {
public void onComplete(AsyncEvent event) throws IOException {
log("onComplete called");
// NOTE: errors and timeouts are handled with other events.
// Successful comm with plug handled by AsyncHTTPRequestProcessor.
ServletRequest asyncContextReq = event.getAsyncContext().getRequest();
// Do the response
HttpServletResponse ctxRes = (HttpServletResponse)event.getAsyncContext().getResponse();
int httpStatusCode = (Integer) asyncContextReq.getAttribute("status");
long startTime = (Long) asyncContextReq.getAttribute("startTime");
long endTime = (Long) asyncContextReq.getAttribute("endTime");
long elapsedTime = endTime - startTime;
ctxRes.setStatus(httpStatusCode);
ctxRes.setContentType("application/json");
ctxRes.getWriter().println("{");
ctxRes.getWriter().println("\"rid\":"+"\""+ctx.getRequest().getParameter("rid")+"\"");
ctxRes.getWriter().println(",");
ctxRes.getWriter().println("\"rtime\":"+elapsedTime); // milliseconds
ctxRes.getWriter().println(",");
ctxRes.getWriter().println("\"startTime\":"+"\""+startTime/1000L+"\""); // unix time
ctxRes.getWriter().println(",");
ctxRes.getWriter().println("\"response\": "+event.getAsyncContext().getRequest().getAttribute("response"));
ctxRes.getWriter().println("}");
ctxRes.getWriter().flush();
}
public void onTimeout(AsyncEvent event) throws IOException {
log("onTimeout called");
// gateway timeout (on plug request)
ServletRequest asyncContextReq = event.getAsyncContext().getRequest();
asyncContextReq.setAttribute("endTime",System.currentTimeMillis());
asyncContextReq.setAttribute("status",504); // request timeout
asyncContextReq.setAttribute("response", "{}");
}
public void onError(AsyncEvent event) throws IOException {
log("onError called");
ServletRequest asyncContextReq = event.getAsyncContext().getRequest();
asyncContextReq.setAttribute("endTime",System.currentTimeMillis());
asyncContextReq.setAttribute("status",500); // request timeout
asyncContextReq.setAttribute("response", "{}");
}
public void onStartAsync(AsyncEvent event) throws IOException {
log("onStartAsync called");
}
});
// spawn some task in a background thread
ctx.start(new AsyncHTTPRequestProcessor(ctx,collector,logger));
}
}
非同期 HTTP リクエスト プロセッサ:
public class AsyncHTTPRequestProcessor implements Runnable {
private ConcurrentHashMap<String, String> collector;
private Logger logger;
private AsyncContext ctx;
//Defined this here because of strange behaviour when running junit
//tests and the response json string being empty...
private String responseStr = null;
public AsyncHTTPRequestProcessor(AsyncContext _ctx,
ConcurrentHashMap<String, String> _collector, Logger _logger) {
ctx = _ctx;
collector = _collector;
logger = _logger;
}
@Override
public void run() {
String rid = (String) ctx.getRequest().getAttribute("rid");
int elapsed = 0;
while(elapsed<1000)
{
if(collector.containsKey(rid)){
responseStr = collector.get(rid);
collector.remove(rid);
logger.info("--->API http request found response in collector!");
ctx.getRequest().setAttribute("status",200);
ctx.getRequest().setAttribute("response", responseStr);
ctx.getRequest().setAttribute("endTime",System.currentTimeMillis());
break;
}
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
ctx.complete();
}
}