【发布时间】:2023-04-10 14:32:01
【问题描述】:
我已经构建了一个应用程序。它的后端位于 vertx (java) 中,我使用 sockJs 从客户端访问它。我想为此应用程序进行负载测试(基准测试/性能测试)。我之前没有做过任何负载测试。有人可以帮我吗,怎么办?就像,我想通过许多连接同时访问服务器,看看它何时失败以及我能做些什么来改进它。这是一个基本代码
HttpVerticle.java
package sockjs;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.http.HttpServer;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.handler.sockjs.SockJSHandler;
import io.vertx.ext.web.handler.sockjs.SockJSHandlerOptions;
import io.vertx.ext.web.handler.sockjs.SockJSSocket;
public class HttpVerticle extends AbstractVerticle {
static int count = 0;
@Override
public void start() throws Exception {
HttpServer server = vertx.createHttpServer();
Router router = Router.router(Vertx.vertx());
SockJSHandlerOptions options = new SockJSHandlerOptions();
options.setHeartbeatInterval(20000);
SockJSHandler sockJSHandler = SockJSHandler.create(vertx, options);
sockJSHandler.socketHandler(this::myHandler);
router.route("/myapp/*").handler(sockJSHandler);
router.route("/myway/*").handler(sockJSHandler);
server.requestHandler(router::accept).listen(8080);
}
private void myHandler(SockJSSocket sockJSSocket) {
System.out.println("Connection established " + count); //Calls when the connection is established
count++;
System.out.println(sockJSSocket);
//sockJSSocket.handler(this::processMessage);
sockJSSocket.handler(buffer -> { //everytime a message is received, a reply is sent back in uppercase.
System.out.println(buffer.toString());
String reply = buffer.toString();
reply = reply.toUpperCase();
sockJSSocket.write((Buffer.buffer(reply)));
});
}
private void processMessage(Buffer buffer) {
System.out.println(buffer.toString());
}
}
Main.java
package sockjs;
import io.vertx.core.Vertx;
public class Main {
public static void main(String[] args) {
System.out.println("Vertx server started");
Vertx vertx = Vertx.vertx();
vertx.deployVerticle(new HttpVerticle());
}
}
而客户端可能是这样的:
var sockJsUrl = "https://cdnjs.cloudflare.com/ajax/libs/sockjs-client/1.1.1/sockjs.min.js";
var head = document.querySelector("head");
var script = document.createElement("script");
script.type = "text/javascript";
script.src = sockJsUrl;
head.appendChild(script);
var sock = new SockJS("http://localhost:8080/myapp");
sock.onopen = function() {
console.log("Connection open", sock.readyState);
}
sock.onmessage = function(event) {
console.log("Message from server");
console.log(event);
}
sock.onclose = function() {
console.log("Connection closed", sock.readyState);
}
sock.onerror = function() {
console.log("Connection error", sock.readyState);
}
坦率地说,我对性能测试一无所知。因此,如果有人给我详细信息,我将不胜感激。
【问题讨论】:
-
我的项目在 sockJs 中,而不是在 WebSockets 中。那么我该如何使用 thor,因为文档说 Thor 只采用 ws 协议?
标签: performance benchmarking load-testing vert.x sockjs