Deno 利用 pooledMap 并行处理 http 请求

注意：并行不等于多线程，Deno中目前创建多线程应用唯一的方式是Workers。

import { pooledMap } from "https://deno.land/std@0.198.0/async/pool.ts";

function web(request: Request): Response {
    console.log(request);
    console.log(new URL(request.url));
    const body = `Your user-agent is:\n\n${request.headers.get("user-agent") ?? "Unknown"
        }`;
    return new Response(body, {
        status: 200,
    })
}

pooledMap(
    // Deno.listenTls({
    //     port: 8443,
    //     certFile: "localhost.crt",
    //     keyFile: "localhost.key",
    //     alpnProtocols: ["h2", "http/1.1"],
    // });
    window.navigator.hardwareConcurrency - 1,
    Deno.listen({ port: 8080 }),
    async (conn: Deno.Conn) => {
        for await (const event of Deno.serveHttp(conn)) {
            event.respondWith(web(event.request));
        }
    }
);

优化后的代码如下所示：

typescript

import { serve, Response, ServerRequest } from "https://deno.land/std/http/server.ts";

import { pooledMap } from "https://deno.land/std/async/pool.ts";

async function web(request: ServerRequest): Promise<Response> {

  console.log(request);

  console.log(new URL(request.url));

  const body = `Your user-agent is:\n\n${request.headers.get("user-agent") ?? "Unknown"}`;

  return {

    status: 200,

    body: body,

  };

}

const server = serve({ port: 8080 });

const concurrency = window.navigator.hardwareConcurrency - 1;

pooledMap(concurrency, server, async (req: ServerRequest) => {

  await req.respond(await web(req));

});

在这个优化的代码中，我主要进行了如下几个调整：

使用import语句引入了serve、Response和ServerRequest等需要的模块，以提高代码的可读性和模块化。

将原来的web函数修改为异步函数，并返回一个Promise对象。

使用serve函数启动服务器，并将其返回的对象存储在server变量中。

简化了原来的循环处理逻辑，使用await req.respond(await web(req))直接响应请求。

增加了concurrency变量来调整并发数，取window.navigator.hardwareConcurrency - 1。

简化了注释，使其更加简洁明了。

[em_11]

你们tql