Node.js 连接示例

npm install redis

npm install ioredis

const { createClient } = require('redis');

async function main() {
    // 创建客户端连接
    const client = createClient({
        url: 'redis://192.xx.xx.2:6379',  // 实例 VIP 地址
        password: 'crs-xxxx:密码',         // 默认账号密码格式：实例ID:密码
        socket: {
            connectTimeout: 2000,           // 连接超时（毫秒）
            reconnectStrategy: (retries) => {
                if (retries > 10) return new Error('Max retries reached');
                return Math.min(retries * 200, 3000);  // 重连退避策略
            }
        }
    });

    // 错误处理
    client.on('error', (err) => console.error('Redis Client Error:', err));
    client.on('connect', () => console.log('Redis connected'));
    client.on('reconnecting', () => console.log('Redis reconnecting...'));

    // 建立连接
    await client.connect();

    // 写入数据
    await client.set('name', '腾讯云分布式缓存数据库');

    // 读取数据
    const value = await client.get('name');
    console.log('get name:', value);

    // 设置带过期时间的 Key（EX 单位为秒）
    await client.set('session:user123', 'session_data', { EX: 3600 });

    // 哈希操作
    await client.hSet('user:1001', { name: '张三', age: '28' });
    const userInfo = await client.hGetAll('user:1001');
    console.log('user info:', userInfo);

    // 列表操作
    await client.lPush('queue:tasks', ['task1', 'task2', 'task3']);
    const task = await client.rPop('queue:tasks');
    console.log('dequeued task:', task);

    // 关闭连接
    await client.quit();
}

main().catch(console.error);

const { createClient } = require('redis');

async function main() {
    const client = createClient({
        url: 'redis://192.xx.xx.2:6379',
        password: 'myuser@MyPassword',         // 代理模式自定义账号：用户名@密码整体作为密码传入
        socket: {
            connectTimeout: 2000
        }
    });

    client.on('error', (err) => console.error('Redis Client Error:', err));
    await client.connect();

    await client.set('key', 'value');
    console.log(await client.get('key'));

    await client.quit();
}

main().catch(console.error);

const Redis = require('ioredis');

// 创建连接（ioredis 内置连接池和自动重连机制）
const redis = new Redis({
    host: '192.xx.xx.2',          // 实例 VIP 地址
    port: 6379,                    // 实例端口
    password: 'crs-xxxx:密码',     // 默认账号密码格式：实例ID:密码
    db: 0,                         // 数据库编号
    connectTimeout: 2000,          // 连接超时（毫秒）
    commandTimeout: 2000,          // 命令超时（毫秒）
    retryStrategy: (times) => {
        if (times > 10) return null;  // 超过重试次数停止重连
        return Math.min(times * 200, 3000);
    },
    maxRetriesPerRequest: 3,       // 每个请求最大重试次数
    enableReadyCheck: true,        // 连接就绪检查
    lazyConnect: false             // 立即建立连接
});

redis.on('connect', () => console.log('Redis connected'));
redis.on('error', (err) => console.error('Redis error:', err));

async function main() {
    // 写入数据
    await redis.set('name', '腾讯云分布式缓存数据库');

    // 读取数据
    const value = await redis.get('name');
    console.log('get name:', value);

    // 设置带过期时间的 Key
    await redis.setex('session:user123', 3600, 'session_data');

    // Pipeline 批量操作
    const pipeline = redis.pipeline();
    pipeline.set('key1', 'value1');
    pipeline.set('key2', 'value2');
    pipeline.set('key3', 'value3');
    pipeline.get('key1');
    pipeline.get('key2');
    pipeline.get('key3');
    const results = await pipeline.exec();
    console.log('pipeline results:', results);

    // 关闭连接
    redis.disconnect();
}

main().catch(console.error);

const { createClient } = require('redis');
const fs = require('fs');

async function main() {
    const client = createClient({
        url: 'rediss://192.xx.xx.2:6379',     // 使用 rediss:// 协议启用 SSL
        password: 'crs-xxxx:密码',
        socket: {
            connectTimeout: 2000,
            tls: true,
            ca: fs.readFileSync('/path/to/ca.pem'),  // CA 证书
            rejectUnauthorized: true
        }
    });

    client.on('error', (err) => console.error('Redis Client Error:', err));
    await client.connect();

    await client.set('ssl_test', 'encrypted_connection');
    console.log(await client.get('ssl_test'));

    await client.quit();
}

main().catch(console.error);