近期,Bun 发布了 v1.1.25 版本,并高调宣布在最新的性能测试中,每秒可以处理 129 万个 HTTP 请求,我们一起来看看这个版本究竟做了哪些改进吧。
node:cluster 支持Bun 现在支持 node:cluster API。
通过使用这个 API,你可以在同一个端口上运行一组 Bun workers,从而实现更高的吞吐量和利用率。对于拥有多个 CPU 核心的机器来说,这是在生产环境中进行负载均衡的最佳选择。
下面是一个工作原理的示例:
主要的 worker 会创建 n 个子 worker,一般数量与 CPU 核心数相同;每个子 worker 都会监听相同的端口(使用 reusePort);传入的 HTTP 请求会在子 worker 之间进行负载均衡分配处理。import cluster from "node:cluster";import http from "node:http";import { cpus } from "node:os";import process from "node:process";if (cluster.isPrimary) { console.log(`主进程 ${process.pid} 正在运行`); // 根据 CPU 核心数创建 N 个子进程 for (let i = 0; i < cpus().length; i++) { cluster.fork(); } cluster.on("exit", (worker, code, signal) => { console.log(`工作进程 ${worker.process.pid} 退出`); });} else { // 请求会由子进程池中的工作进程处理,而不是主进程 http .createServer((req, res) => { res.writeHead(200); res.end("hello world\n"); }) .listen(3000); console.log(`工作进程 ${process.pid} 已启动`);}这个示例代码可以与 node:http API 以及 Bun.serve() API 一起使用。
import cluster from "node:cluster";import { cpus } from "node:os";if (cluster.isPrimary) { // 主进程逻辑:根据 CPU 核心数创建子进程 for (let i = 0; i < cpus().length; i++) { cluster.fork(); }} else { // 工作进程逻辑:使用 Bun 框架提供的 API 运行服务器 Bun.serve({ port: 3000, // 监听的端口号 fetch(request) { return new Response(`你好,来自工作进程 ${process.pid}`); }, });}注意,目前 reusePort 只在 Linux 系统上有效。在 Windows 和 macOS 上,操作系统无法像预期那样对 HTTP 连接进行负载均衡处理。
开始支持 V8 公开 C++ APIBun 现在支持了 V8 的公开 C++ API,这使得像 cpu-features 这样的软件包可以在 Bun 中正常工作。
这是一个值得注意的变化,因为 Bun 不是像 Node.js 一样构建在 V8 之上。相反,Bun 是构建在 JavaScriptCore 上的,JavaScriptCore 是 Safari 使用的 JavaScript 引擎。
这意味着官方需要实现一个自己的 C++ 翻译层,将 V8 的 API 与 JavaScriptCore 进行对接。
#include "v8.h"#include "V8Primitive.h"#include "V8MaybeLocal.h"#include "V8Isolate.h"namespace v8 {enum NewStringType { /* ... */ };class String : Primitive {public: enum WriteOptions { /* ... */ }; BUN_EXPORT static MaybeLocal<String> NewFromUtf8(Isolate* isolate, char const* data, NewStringType type, int length = -1); BUN_EXPORT int WriteUtf8(Isolate* isolate, char* buffer, int length = -1, int* nchars_ref = nullptr, int options = NO_OPTIONS) const; BUN_EXPORT int Length() const; // 将本地字符串对象转换为JavaScriptCore的JSString对象 JSC::JSString* localToJSString() { return localToObjectPointer<JSC::JSString>(); }};}这是一项非常艰巨的工程,JavaScriptCore 和 V8 以不同的方式表示 JavaScript 值。V8 使用了移动式、并发的垃圾收集器,并且有明确的句柄作用域,而 JavaScriptCore 使用了非移动式的并发垃圾收集器,它会扫描堆栈内存(类似于隐式句柄作用域)。
在此之前,如果你尝试导入一个使用这些API的软件包,你会得到如下的错误提示:
console.log(require("cpu-features")());dyld[94465]: missing symbol calledfish: Job 1, 'bun index.ts' terminated by signal SIGABRT (Abort)现在,像 cpu-features 这样的包可以导入并在 Bun 中运行。
$ bun index.ts{ arch: "aarch64", flags: { fp: true, asimd: true, // ... },}为什么要支持 V8 的内部 API 么?
最初 Bun 并没有打算支持这些 API,但是在发现许多受欢迎的软件包依赖于这些 API 后,开始决定加以支持,这些软件包包括:
cpu-featuresnode-canvas@v2node-sqlite3libxmljs以及许多使用nan的软件包在这个版本中,只有cpu-features从上述列表中受到支持,其他 API 正在努力支持中。
使用 @aws-sdk/client-s3 实现的 S3 上传速度提高了5倍Bun 修复了 node:http 客户端实现中的一个 bug,这使得上传到 S3 的速度提高了5倍。
独立可执行文件中的 WorkerBun 的单文件独立可执行文件现在支持绑定 Worker 和 node:worker_threads。
// main.tsconsole.log("Hello from main thread!");new Worker("./my-worker.ts");// my-worker.tsconsole.log("Hello from another thread!");要使用 worker 编译独立可执行文件,可以将文件入口传递给 bun build --compile 命令:
bun build --compile ./main.ts ./my-worker.ts这将在生成的可执行文件中将 my-worker.ts 和 main.ts 作为独立的入口点进行打包。
使用 OMGJIT 在 Windows 上实现更快的 WebAssemblyWindows 上的 WebAssembly 现在支持 JavaScriptCore 的优化即时编译器 (JIT),称为 OMGJIT。
Node.js兼容性改进execa 现在可以正常工作了。
Bun 修复了一个不能正确支持 EventTarget的setMaxListeners 的 bug。这个问题影响到了像 execa 这样的包,会导致错误报 undefined is not a function。
import { execa } from "execa";const { stdout } = await execa`echo "test"`如果你遇到类似的错误,现在已经得到修复:
91 | const controller = new AbortController();92 | setMaxListeners(Number.POSITIVE_INFINITY, controller.signal); ^TypeError: undefined is not a function at node:events:101:30 at spawnSubprocessAsync (/node_modules/execa/lib/methods/main-async.js:92:2) at execaCoreAsync (/node_modules/execa/lib/methods/main-async.js:26:32) at index.mjs:3:26问题已修复:在调用 destroy() 关闭 TCP 连接后,与 node:net 的连接出现挂起
也是一个 bug 修复,在调用 destroy() 关闭 TCP 连接后,进程没有始终正确退出,因为事件循环仍然处于活动状态。这有时会导致像 postgres 这样的包无限期地挂起。
import net from "node:net";const server = net.createServer((socket) => { // 当socket连接成功时触发connect事件 socket.on("connect", (data) => { socket.destroy(); // 这会销毁连接, // 但是事件循环仍然处于活动状态 });});server.listen(3000);