use uws

benchmarks/package.json

@@ -21,6 +21,7 @@
     "node-fetch": "^3.3.2",
     "request": "^2.88.2",
     "superagent": "^10.0.0",
-    "wait-on": "^7.2.0"
+    "wait-on": "^7.2.0",
+    "uWebSockets.js": "uNetworking/uWebSockets.js#v20.47.0"
   }
 }

benchmarks/websocket/server/echo.mjs

@@ -1,11 +1,43 @@
-import cluster from 'node:cluster'
-import { cpus } from 'node:os'
+import worker_threads from "node:worker_threads";
+import { cpus } from "node:os";
+import url from "node:url";
+import path from "node:path";
+import uws from "uWebSockets.js";
 
-if (cluster.isPrimary) {
-  let cpu = cpus().length
-  while (cpu-- > 0) {
-    cluster.fork()
+var __filename = url.fileURLToPath(import.meta.url);
+var __dirname = path.dirname(__filename);
+
+if (worker_threads.isMainThread) {
+  for (let i = cpus().length - 1; i >= 0; --i) {
+    new worker_threads.Worker(__filename);
   }
 } else {
-  // use uws?
+  const app = uws.App();
+
+  app
+    .ws("/*", {
+      compression: uws.DISABLED,
+      maxPayloadLength: 512 * 1024 * 1024,
+      maxBackpressure: 128 * 1024,
+      idleTimeout: 60,
+      message: (ws, message, isBinary) => {
+        /* Here we echo the message back, using compression if available */
+        const ok = ws.send(message, isBinary);
+      },
+    })
+    .get("/*", (res, req) => {
+      /* It does Http as well */
+      res
+        .writeStatus("200 OK")
+        .end("Hello there!");
+    })
+    .listen(5001, (listenSocket) => {
+      if (listenSocket) {
+        if (worker_threads.threadId === 0) {
+          console.log("Listening to port 5001");
+        } else {
+          console.log(`Listening to port 5001 from thread ${worker_threads.threadId}`)
+        }
+      }
+    });
 }