Bun Redis 集成指南：ioredis、Upstash 客户端配置与数据结构操作教程

Bun Redis by secondsky/claude-skills

93 GitHub Stars

GitHub

安装命令

npx skills add https://github.com/secondsky/claude-skills --skill 'Bun Redis'

Node.js 开发数据库

🇨🇳中文介绍

Bun Redis

使用流行的 Redis 客户端实现 Bun 与 Redis 的集成。

客户端选项

客户端	最佳适用场景	安装
`ioredis`	自托管 Redis	`bun add ioredis`
`@upstash/redis`	无服务器/边缘计算	`bun add @upstash/redis`
`redis`	官方 Node 客户端	`bun add redis`

广告位招租

在这里展示您的产品或服务

触达数万 AI 开发者，精准高效

联系我们

相关 Skills

find-skills 技能搜索工具 - Vercel Labs 开源智能体技能包管理器

794,900 周安装

Vercel React 最佳实践指南 | 58条Next.js性能优化规则与代码重构

265,000 周安装

Vercel Web界面规范检查工具 - 自动检测代码是否符合Web设计指南

213,800 周安装

agent-browser 浏览器自动化工具 - Vercel Labs 命令行网页操作与测试

144,300 周安装

import Redis from "ioredis";

// 默认连接
const redis = new Redis();

// 带选项连接
const redis = new Redis({
  host: "localhost",
  port: 6379,
  password: "secret",
  db: 0,
});

// 连接字符串
const redis = new Redis("redis://:password@localhost:6379/0");

// TLS 连接
const redis = new Redis({
  host: "redis.example.com",
  port: 6380,
  tls: {},
});

import Redis from "ioredis";

const redis = new Redis();

// 字符串
await redis.set("name", "Alice");
await redis.set("count", "100");
await redis.setex("temp", 60, "expires in 60s"); // 带 TTL

const name = await redis.get("name"); // "Alice"
const count = await redis.incr("count"); // 101
await redis.del("name");

// 检查存在性
const exists = await redis.exists("name"); // 0 或 1

// TTL
await redis.expire("key", 3600); // 设置 1 小时 TTL
const ttl = await redis.ttl("key"); // 获取剩余 TTL

// 设置哈希字段
await redis.hset("user:1", {
  name: "Alice",
  email: "alice@example.com",
  age: "30",
});

// 获取单个字段
const name = await redis.hget("user:1", "name");

// 获取所有字段
const user = await redis.hgetall("user:1");
// { name: "Alice", email: "...", age: "30" }

// 递增字段
await redis.hincrby("user:1", "visits", 1);

// 添加到列表
await redis.rpush("queue", "task1", "task2");
await redis.lpush("queue", "urgent");

// 从列表弹出
const task = await redis.lpop("queue"); // "urgent"
const blocking = await redis.blpop("queue", 5); // 等待 5 秒

// 范围查询
const items = await redis.lrange("queue", 0, -1);

// 添加成员
await redis.sadd("tags", "javascript", "typescript", "bun");

// 检查成员资格
const isMember = await redis.sismember("tags", "bun"); // 1

// 获取所有成员
const tags = await redis.smembers("tags");

// 集合操作
await redis.sinter("tags1", "tags2"); // 交集
await redis.sunion("tags1", "tags2"); // 并集

// 带分数添加
await redis.zadd("leaderboard", 100, "alice", 200, "bob", 150, "charlie");

// 按排名获取
const top3 = await redis.zrevrange("leaderboard", 0, 2, "WITHSCORES");

// 按分数范围获取
const highScores = await redis.zrangebyscore("leaderboard", 100, 200);

// 递增分数
await redis.zincrby("leaderboard", 50, "alice");

// 需要 RedisJSON 模块
await redis.call("JSON.SET", "user:1", "$", JSON.stringify({
  name: "Alice",
  settings: { theme: "dark" },
}));

const user = await redis.call("JSON.GET", "user:1");
const settings = await redis.call("JSON.GET", "user:1", "$.settings");

import Redis from "ioredis";

// 发布者
const pub = new Redis();

// 订阅者
const sub = new Redis();

// 订阅频道
sub.subscribe("notifications", (err, count) => {
  console.log(`已订阅 ${count} 个频道`);
});

// 处理消息
sub.on("message", (channel, message) => {
  console.log(`${channel}: ${message}`);
});

// 发布
await pub.publish("notifications", JSON.stringify({
  type: "alert",
  message: "Hello!",
}));

// 模式订阅
sub.psubscribe("user:*");
sub.on("pmessage", (pattern, channel, message) => {
  console.log(`${pattern} -> ${channel}: ${message}`);
});

// Multi/Exec
const results = await redis
  .multi()
  .set("key1", "value1")
  .set("key2", "value2")
  .incr("counter")
  .exec();

// 管道（非原子性，性能更好）
const pipeline = redis.pipeline();
pipeline.set("key1", "value1");
pipeline.set("key2", "value2");
pipeline.incr("counter");
const results = await pipeline.exec();

Upstash Redis (无服务器)

import { Redis } from "@upstash/redis";

const redis = new Redis({
  url: process.env.UPSTASH_REDIS_REST_URL,
  token: process.env.UPSTASH_REDIS_REST_TOKEN,
});

// 与 ioredis 相同的 API
await redis.set("key", "value");
const value = await redis.get("key");

// 自动 JSON 序列化
await redis.set("user", { name: "Alice", age: 30 });
const user = await redis.get<{ name: string; age: number }>("user");

async function getUser(id: string) {
  // 检查缓存
  const cached = await redis.get(`user:${id}`);
  if (cached) {
    return JSON.parse(cached);
  }

  // 从数据库获取
  const user = await db.query.users.findFirst({
    where: eq(users.id, id),
  });

  // 缓存 1 小时
  if (user) {
    await redis.setex(`user:${id}`, 3600, JSON.stringify(user));
  }

  return user;
}

async function updateUser(id: string, data: UserUpdate) {
  // 更新数据库
  await db.update(users).set(data).where(eq(users.id, id));

  // 更新缓存
  const user = await db.query.users.findFirst({
    where: eq(users.id, id),
  });
  await redis.setex(`user:${id}`, 3600, JSON.stringify(user));

  return user;
}

async function rateLimit(key: string, limit: number, window: number) {
  const current = await redis.incr(key);

  if (current === 1) {
    await redis.expire(key, window);
  }

  return current <= limit;
}

// 使用示例
const allowed = await rateLimit(`rate:${userId}`, 100, 60);
if (!allowed) {
  throw new Error("超出速率限制");
}

import { Hono } from "hono";
import Redis from "ioredis";
import { v4 as uuid } from "uuid";

const redis = new Redis();
const app = new Hono();

app.use("*", async (c, next) => {
  const sessionId = c.req.header("X-Session-Id") || uuid();
  const session = await redis.hgetall(`session:${sessionId}`);

  c.set("session", session);
  c.set("sessionId", sessionId);

  await next();

  // 保存会话
  const updatedSession = c.get("session");
  if (Object.keys(updatedSession).length > 0) {
    await redis.hset(`session:${sessionId}`, updatedSession);
    await redis.expire(`session:${sessionId}`, 86400); // 24 小时
  }
});

错误	原因	修复方法
`ECONNREFUSED`	Redis 未运行	启动 Redis 服务器
`NOAUTH`	需要身份验证	提供密码
`WRONGTYPE`	错误的数据类型	检查键类型
`OOM`	内存不足	配置 maxmemory

何时加载参考文档

当需要以下内容时加载 references/clustering.md：

Redis 集群设置
Sentinel 配置
高可用性模式

当需要以下内容时加载 references/lua-scripts.md：

自定义 Lua 脚本
原子操作
复杂事务

🇺🇸English

Bun Redis

Redis integration with Bun using popular Redis clients.

Client Options

Client	Best For	Install
`ioredis`	Self-hosted Redis	`bun add ioredis`
`@upstash/redis`	Serverless/Edge	`bun add @upstash/redis`
`redis`	Official Node client	`bun add redis`

ioredis Setup

import Redis from "ioredis";

// Default connection
const redis = new Redis();

// With options
const redis = new Redis({
  host: "localhost",
  port: 6379,
  password: "secret",
  db: 0,
});

// Connection string
const redis = new Redis("redis://:password@localhost:6379/0");

// TLS connection
const redis = new Redis({
  host: "redis.example.com",
  port: 6380,
  tls: {},
});

Basic Operations

import Redis from "ioredis";

const redis = new Redis();

// Strings
await redis.set("name", "Alice");
await redis.set("count", "100");
await redis.setex("temp", 60, "expires in 60s"); // With TTL

const name = await redis.get("name"); // "Alice"
const count = await redis.incr("count"); // 101
await redis.del("name");

// Check existence
const exists = await redis.exists("name"); // 0 or 1

// TTL
await redis.expire("key", 3600); // Set 1 hour TTL
const ttl = await redis.ttl("key"); // Get remaining TTL

Data Structures

Hashes

// Set hash fields
await redis.hset("user:1", {
  name: "Alice",
  email: "alice@example.com",
  age: "30",
});

// Get single field
const name = await redis.hget("user:1", "name");

// Get all fields
const user = await redis.hgetall("user:1");
// { name: "Alice", email: "...", age: "30" }

// Increment field
await redis.hincrby("user:1", "visits", 1);

Lists

// Add to list
await redis.rpush("queue", "task1", "task2");
await redis.lpush("queue", "urgent");

// Pop from list
const task = await redis.lpop("queue"); // "urgent"
const blocking = await redis.blpop("queue", 5); // Wait 5s

// Range
const items = await redis.lrange("queue", 0, -1);

Sets

// Add members
await redis.sadd("tags", "javascript", "typescript", "bun");

// Check membership
const isMember = await redis.sismember("tags", "bun"); // 1

// Get all members
const tags = await redis.smembers("tags");

// Set operations
await redis.sinter("tags1", "tags2"); // Intersection
await redis.sunion("tags1", "tags2"); // Union

Sorted Sets

// Add with scores
await redis.zadd("leaderboard", 100, "alice", 200, "bob", 150, "charlie");

// Get by rank
const top3 = await redis.zrevrange("leaderboard", 0, 2, "WITHSCORES");

// Get by score range
const highScores = await redis.zrangebyscore("leaderboard", 100, 200);

// Increment score
await redis.zincrby("leaderboard", 50, "alice");

JSON (RedisJSON)

// Requires RedisJSON module
await redis.call("JSON.SET", "user:1", "$", JSON.stringify({
  name: "Alice",
  settings: { theme: "dark" },
}));

const user = await redis.call("JSON.GET", "user:1");
const settings = await redis.call("JSON.GET", "user:1", "$.settings");

Pub/Sub

import Redis from "ioredis";

// Publisher
const pub = new Redis();

// Subscriber
const sub = new Redis();

// Subscribe to channel
sub.subscribe("notifications", (err, count) => {
  console.log(`Subscribed to ${count} channels`);
});

// Handle messages
sub.on("message", (channel, message) => {
  console.log(`${channel}: ${message}`);
});

// Publish
await pub.publish("notifications", JSON.stringify({
  type: "alert",
  message: "Hello!",
}));

// Pattern subscribe
sub.psubscribe("user:*");
sub.on("pmessage", (pattern, channel, message) => {
  console.log(`${pattern} -> ${channel}: ${message}`);
});

Transactions

// Multi/Exec
const results = await redis
  .multi()
  .set("key1", "value1")
  .set("key2", "value2")
  .incr("counter")
  .exec();

// Pipeline (no atomicity, better performance)
const pipeline = redis.pipeline();
pipeline.set("key1", "value1");
pipeline.set("key2", "value2");
pipeline.incr("counter");
const results = await pipeline.exec();

Upstash Redis (Serverless)

import { Redis } from "@upstash/redis";

const redis = new Redis({
  url: process.env.UPSTASH_REDIS_REST_URL,
  token: process.env.UPSTASH_REDIS_REST_TOKEN,
});

// Same API as ioredis
await redis.set("key", "value");
const value = await redis.get("key");

// With automatic JSON serialization
await redis.set("user", { name: "Alice", age: 30 });
const user = await redis.get<{ name: string; age: number }>("user");

Caching Patterns

Cache-Aside

async function getUser(id: string) {
  // Check cache
  const cached = await redis.get(`user:${id}`);
  if (cached) {
    return JSON.parse(cached);
  }

  // Fetch from database
  const user = await db.query.users.findFirst({
    where: eq(users.id, id),
  });

  // Cache for 1 hour
  if (user) {
    await redis.setex(`user:${id}`, 3600, JSON.stringify(user));
  }

  return user;
}

Write-Through

async function updateUser(id: string, data: UserUpdate) {
  // Update database
  await db.update(users).set(data).where(eq(users.id, id));

  // Update cache
  const user = await db.query.users.findFirst({
    where: eq(users.id, id),
  });
  await redis.setex(`user:${id}`, 3600, JSON.stringify(user));

  return user;
}

Rate Limiting

async function rateLimit(key: string, limit: number, window: number) {
  const current = await redis.incr(key);

  if (current === 1) {
    await redis.expire(key, window);
  }

  return current <= limit;
}

// Usage
const allowed = await rateLimit(`rate:${userId}`, 100, 60);
if (!allowed) {
  throw new Error("Rate limit exceeded");
}

Session Storage

import { Hono } from "hono";
import Redis from "ioredis";
import { v4 as uuid } from "uuid";

const redis = new Redis();
const app = new Hono();

app.use("*", async (c, next) => {
  const sessionId = c.req.header("X-Session-Id") || uuid();
  const session = await redis.hgetall(`session:${sessionId}`);

  c.set("session", session);
  c.set("sessionId", sessionId);

  await next();

  // Save session
  const updatedSession = c.get("session");
  if (Object.keys(updatedSession).length > 0) {
    await redis.hset(`session:${sessionId}`, updatedSession);
    await redis.expire(`session:${sessionId}`, 86400); // 24h
  }
});

Common Errors

Error	Cause	Fix
`ECONNREFUSED`	Redis not running	Start Redis server
`NOAUTH`	Authentication required	Provide password
`WRONGTYPE`	Wrong data type	Check key type
`OOM`	Out of memory	Configure maxmemory

When to Load References

Load references/clustering.md when:

Redis Cluster setup
Sentinel configuration
High availability patterns

Load references/lua-scripts.md when:

Custom Lua scripts
Atomic operations
Complex transactions

Weekly Installs

–

Repository

secondsky/claude-skills

GitHub Stars

First Seen

–

Security Audits

Gen Agent Trust HubPass SocketPass SnykPass

React 组合模式指南：Vercel 组件架构最佳实践，提升代码可维护性

107,800 周安装

Bun Redis 集成指南：ioredis、Upstash 客户端配置与数据结构操作教程

🇨🇳中文介绍

Bun Redis

客户端选项

相关 Skills

ioredis 配置

基本操作

数据结构

哈希表

列表

集合

有序集合

JSON (RedisJSON)

发布/订阅

事务

Upstash Redis (无服务器)

缓存模式

旁路缓存

直写缓存

速率限制

会话存储

常见错误

何时加载参考文档

🇺🇸English

Bun Redis

Client Options

ioredis Setup

Basic Operations

Data Structures

Hashes

Lists

Sets

Sorted Sets

JSON (RedisJSON)

Pub/Sub

Transactions

Upstash Redis (Serverless)

Caching Patterns

Cache-Aside

Write-Through

Rate Limiting

Session Storage

Common Errors

When to Load References

最新 Skills