VertX vs Jettyパフォーマンスの問題

Question

私はJettyとVertX.3のベンチマークテストを非同期サポートしています。以下は私のVertXのサンプルコードです。

public class VertXSampleServer extends AbstractVerticle{ 
    @Override 
    public void start(){ 
     HttpServer server=vertx.createHttpServer(); 
     server.requestHandler(new Handler<HttpServerRequest>() { 

    @Override 
    public void handle(HttpServerRequest request) { 
     HttpServerResponse response=request.response(); 
     response.setStatusCode(HttpStatus.SC_OK); 
     System.out.println("re received"); 
     response.putHeader("Content-Length", Integer.toString(5)); 
     response.write("Hello"); 
    } 
    }).listen(9091); 
    } 
} 

桟橋サンプルサーバ：

public class JettySampleAsyncServer 
{ 
public static class EmbeddedAsyncServlet extends HttpServlet 
{ 
@Override 
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException 
{ 
final AsyncContext ctxt = req.startAsync(); 

ctxt.start(new Runnable() 
{ 
@Override 
public void run() 
{ 
System.out.println("In AsyncContext/Start/Runnable/run"); 
ServletResponse response=ctxt.getResponse(); 
byte[] result="<h1>Hello World</h1>".getBytes(); 
try { 
response.setContentType("text/html"); 
response.setCharacterEncoding("UTF-8"); 
response.setContentLength(result.length); 
response.getOutputStream().write(result); 

} catch (IOException e) { 
e.printStackTrace(); 
} 
ctxt.setTimeout(new Long(1000)); 
ctxt.complete(); 
} 
}); 
} 
} 
public static void main(String[] args) throws Exception 
{ 
Server server = new Server(); 
QueuedThreadPool queuedThreadPool=(QueuedThreadPool) server.getThreadPool(); 
queuedThreadPool.setMaxThreads(8); 
ServerConnector serverConnector=new ServerConnector(server,1,4); 
serverConnector.setHost("localhost"); 
serverConnector.setPort(9090); 
// serverConnector.setAcceptQueueSize(100); 
server.addConnector(serverConnector); 
ServletContextHandler context = new ServletContextHandler(); 
context.setContextPath("/"); 
ServletHolder asyncHolder = context.addServlet(EmbeddedAsyncServlet.class,"/*"); 
asyncHolder.setAsyncSupported(true); 
server.setHandler(context); 
server.start(); 
server.join(); 
} 
} 

VERTXをテストしながら、私は31件のリクエスト/分のスループットを取得しています。しかしテスト桟橋ながら、私は310 REQ /秒を取得しています。 誰も私にexaplinパフォーマンスのこの非常に高いギャップの理由を教えてください。また、私はベンチマークテストにApache Jmeterを使用しています。

Answer 1

Vert.xの実装にはいくつかの問題があります。たとえば、接続が終了していないと、タイムアウトが発生して完了することがあります。

public class VertXSampleServer extends AbstractVerticle { 
    @Override 
    public void start() { 
    HttpServer server=vertx.createHttpServer(); 
    server.requestHandler(new Handler<HttpServerRequest>() { 
     @Override 
     public void handle(HttpServerRequest request) { 
     HttpServerResponse response=request.response(); 
     // by default it is 200 so this is optional 
     response.setStatusCode(HttpStatus.SC_OK); 
     System.out.println("re received"); 
     response.putHeader("Content-Length", Integer.toString(5)); 
     // what you're doing here is wrong you should end the response 
     // response.write("Hello"); 
     response.end("Hello"); 
     // You should use write if you are going to use chunked responses 
     // and the last one should be a end to notify that the request 
     // is finished 
     } 
    }).listen(9091); 
    } 
} 

http応答を処理する方法に関する完全なドキュメントはhereです。

チャンク書き込み（あなたがしたこと）と応答の終了の違いについて説明します。