中间件正在破坏 redis / express 设置

Question

我是第一次使用 redis，我不太明白为什么我的中间件 'cache' 函数会破坏我的代码？没有它，它工作得很好，显示在浏览器中，如果我去我的终端并检查键值对，它工作得很好。

这是我的设置：

const express = require("express");
const redis = require("redis");
const axios = require("axios").default;

const PORT = process.env.PORT || 5000;
const REDIS_PORT = process.env.PORT || 6379;

const client = redis.createClient(REDIS_PORT);
client.connect();
const app = express();

function setResponse(username, repos) {
    return `<h2>${username} has ${repos} Github repos</h2>`;
}

// make req to github
async function getRepos(req, res, next) {
    try {
        console.log("fetching data...");
        const { username } = req.params;
        const response = await axios.get(
            `https://api.github.com/users/${username}`
        );

        const data = response.data;

        const repos = data.public_repos;

        // set to redis
        client.set(username, repos);

        res.send(setResponse(username, repos));
    } catch (err) {
        console.log(err);
        res.status(500);
    }
}

// Cache middleware
function cache(req, res, next) {
    const { username } = req.params;

    client.get(username, (err, data) => {
        if (err) throw err;
        if (data !== null) {
            res.send(setResponse(username, data));
        } else {
            next();
        }
    });
}

app.get("/repos/:username", cache, getRepos);

app.listen(5000, () => {
    console.log(`App listening on port ${PORT}`);
});

如有任何建议，我们将不胜感激！

Answer 1

你的缓存功能

function cache(req, res, next) {
    const { username } = req.params;

    client.get(username, (err, data) => {
        if (err) throw err;
        if (data !== null) {
            res.send(setResponse(username, data));
        } else {
            next();
        }
    });
}

使用 node redis 3“逻辑”所以它挂了

redis 4 是 promise led，所以你需要使用 async/await 或 .then/.catch

所以像这样的东西应该适用于 .then/.catch 方法

// Cache middleware
function cache(req, res, next) {
    console.log('caching for', req.params);
    const { username } = req.params;

    client.get(username)
        .then((data) => {
            if (data !== null) {
                res.send(setResponse(username, data));
            } else {
                next();
            }
        })
        .catch(err => {
            if (err) throw err;
        });
}

这将解决您最初的“为什么会卡住”的问题

中间件正在破坏 redis / express 设置

Middleware is breaking redis / express setup

javascript

redis

node.js

express