Nodejs+redis+sqlserver查询数据示例 加急 跪求

Nodejs+redis+sqlserver查询数据示例 加急 跪求

打算用nodejs+redis+sqlserver做站点，.Net开发的伤不起啊。 打算用nodejs到redis里面取静态页上的一些动态数据，取不到则走sqlserver数据库查询。 谁能给一个简单的搭建示例，重赏啊，有北京的朋友我请大餐。

4 回复

当然可以。以下是一个使用 Node.js、Redis 和 SQL Server 进行数据查询的简单示例。该示例展示了如何从 Redis 中获取数据，如果 Redis 中没有数据，则从 SQL Server 数据库中查询数据。

环境准备

  1. 安装 Node.js：确保你已经安装了 Node.js。
  2. 安装必要的 npm 包：
    • express：用于创建 Web 服务器。
    • ioredis：用于连接和操作 Redis。
    • mssql：用于连接和操作 SQL Server 数据库。

你可以通过以下命令安装这些包：

npm install express ioredis mssql

示例代码

app.js

const express = require('express');
const Redis = require('ioredis');
const sql = require('mssql');

// 配置 Redis
const redisClient = new Redis({
    host: 'localhost',
    port: 6379
});

// 配置 SQL Server
const config = {
    user: 'yourusername',
    password: 'yourpassword',
    server: 'yourserver',
    database: 'yourdatabase'
};

const pool = new sql.ConnectionPool(config);

async function getDynamicData(key) {
    // 从 Redis 获取数据
    const data = await redisClient.get(key);
    if (data) {
        return JSON.parse(data);
    }

    // 如果 Redis 中没有数据，则从 SQL Server 查询
    try {
        await pool.connect();
        const result = await pool.request().query(`SELECT * FROM YourTable WHERE KeyColumn = '${key}'`);
        const rows = result.recordset;
        
        // 将查询结果存入 Redis 并返回
        await redisClient.set(key, JSON.stringify(rows));
        return rows;
    } catch (err) {
        console.error(err);
        throw err;
    } finally {
        await pool.close();
    }
}

const app = express();

app.get('/dynamic-data/:key', async (req, res) => {
    try {
        const key = req.params.key;
        const data = await getDynamicData(key);
        res.json(data);
    } catch (err) {
        res.status(500).json({ error: 'Internal Server Error' });
    }
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`Server is running on port ${PORT}`);
});

解释

  1. Redis 连接：使用 ioredis 创建一个 Redis 客户端实例。
  2. SQL Server 连接：使用 mssql 创建一个 SQL Server 连接池。
  3. getDynamicData 函数：尝试从 Redis 获取数据，如果没有找到，则从 SQL Server 查询数据，并将查询结果存储到 Redis 中。
  4. Express 路由：定义了一个路由 /dynamic-data/:key，根据请求的键从 Redis 或 SQL Server 获取数据并返回。

注意事项

  • 确保 Redis 和 SQL Server 的配置正确。
  • 在生产环境中，需要处理更多的异常情况和安全问题，例如 SQL 注入防护。
  • 根据实际情况调整 Redis 缓存策略（如过期时间）。

希望这个示例对你有所帮助！


不太明白 你要问什么 ？ 使用redis 就npm redis 驱动… sqlserver 也有相关驱动…

是想要一个nodejs取redis缓存数据取不到再到sqlserver查询的功能模块

根据您的需求，可以构建一个简单的Node.js应用，结合Redis和SQL Server来实现数据缓存和查询。下面我会提供一些示例代码，并简单解释每个部分的功能。

1. 安装必要的npm包

首先需要安装redis, tedious（用于连接SQL Server）和express（用于创建Web服务器）：

npm install redis tedious express

2. 连接Redis和SQL Server

创建一个文件index.js，初始化Redis和SQL Server连接：

const redis = require('redis');
const { Connection, Request } = require("tedious");

// 创建Redis客户端
const client = redis.createClient({
    host: 'localhost',
    port: 6379,
});

client.on("error", function (error) {
    console.error(error);
});

// SQL Server配置
const config = {
    server: 'your_server.database.windows.net',
    authentication: {
        type: 'default',
        options: {
            userName: 'your_username',
            password: 'your_password'
        }
    },
    options: {
        database: 'your_database',
        encrypt: true,
        rowCollectionOnDone: true
    }
};

const connection = new Connection(config);

connection.on('connect', err => {
    if (err) {
        console.error(err.message);
    } else {
        console.log('SQL Server连接成功');
    }
});

3. 查询逻辑

定义一个函数来检查Redis中是否存在数据，如果不存在，则从SQL Server查询并将结果存储到Redis中：

function getDataFromDB(sqlQuery, res) {
    const request = new Request(sqlQuery, (err, rowCount) => {
        if (err) {
            console.error(err.message);
            res.status(500).send('内部服务器错误');
            return;
        }
        res.json(request.resultSet);
    });

    request.on('row', columns => {
        const row = {};
        columns.forEach(column => {
            row[column.metadata.colName] = column.value;
        });
        client.setex('dynamicData', 3600, JSON.stringify(row), () => {}); // 设置过期时间为1小时
    });

    connection.execSql(request);
}

app.get('/data', (req, res) => {
    client.get('dynamicData', (err, reply) => {
        if (err) {
            console.error(err.message);
            res.status(500).send('内部服务器错误');
            return;
        }

        if (reply) {
            res.json(JSON.parse(reply));
        } else {
            const sqlQuery = "SELECT * FROM your_table"; // 替换为实际的SQL查询语句
            getDataFromDB(sqlQuery, res);
        }
    });
});

4. 启动Express服务器

最后，启动Express服务器监听端口：

const express = require('express');
const app = express();

app.listen(3000, () => {
    console.log('服务器运行在 http://localhost:3000');
});

这样就完成了一个基本的Node.js + Redis + SQL Server架构。Redis用来缓存SQL Server查询的结果，从而提高性能。如果Redis中存在所需的数据，将直接返回缓存数据；否则，会从SQL Server查询数据并将其存入Redis。

回到顶部