123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
import * as denoRedis from "https://deno.land/x/redis@v0.31.0/mod.ts";import { Redis } from "npm:ioredis@5.3.2";import { createClient } from "npm:redis@4.6.10";
import { RedisClient } from "./mod.ts";
const HOSTNAME = "127.0.0.1";const PORT = 6379;
const redisConn = await Deno.connect({ hostname: HOSTNAME, port: PORT });const redisClient = new RedisClient(redisConn);const denoRedisConn = await denoRedis.connect({  hostname: HOSTNAME,  port: PORT,});const ioRedis = new Redis();
const nodeRedisClient = await createClient().connect();
Deno.bench({  name: "r2d2",  baseline: true,  async fn() {    await redisClient.sendCommand(["PING"]);
    await redisClient.sendCommand(["SET", "mykey", "Hello"]);    await redisClient.sendCommand(["GET", "mykey"]);
    await redisClient.sendCommand(["HSET", "hash", "a", "foo", "b", "bar"]);    await redisClient.sendCommand(["HGETALL", "hash"]);
    await redisClient.pipelineCommands([      ["INCR", "X"],      ["INCR", "X"],      ["INCR", "X"],      ["INCR", "X"],    ]);  },});
Deno.bench({  name: "deno-redis",  async fn() {    await denoRedisConn.ping();
    await denoRedisConn.set("mykey", "Hello");    await denoRedisConn.get("mykey");
    await denoRedisConn.hset("hash", { a: "foo", b: "bar" });    await denoRedisConn.hgetall("hash");
    const pl = denoRedisConn.pipeline();    pl.incr("X");    pl.incr("X");    pl.incr("X");    pl.incr("X");    await pl.flush();  },});
Deno.bench({  name: "npm:ioredis",  async fn() {    await ioRedis.ping();
    await ioRedis.set("mykey", "Hello");    await ioRedis.get("mykey");
    await ioRedis.hset("hash", { a: "foo", b: "bar" });    await ioRedis.hgetall("hash");
    const pl = ioRedis.pipeline();    pl.incr("X");    pl.incr("X");    pl.incr("X");    pl.incr("X");    await pl.exec();  },});
Deno.bench({  name: "npm:redis",  async fn() {    await nodeRedisClient.ping();
    await nodeRedisClient.set("mykey", "Hello");    await nodeRedisClient.get("mykey");
    await nodeRedisClient.hSet("hash", { a: "foo", b: "bar" });    await nodeRedisClient.hGetAll("hash");
    /** Autopipelining */    await nodeRedisClient.incr("X");    await nodeRedisClient.incr("X");    await nodeRedisClient.incr("X");    await nodeRedisClient.incr("X");  },});
addEventListener("beforeunload", async () => {  ioRedis.disconnect();  await nodeRedisClient.disconnect();});
addEventListener("unload", () => {  denoRedisConn.close();  redisConn.close();});