node.js - 将 Redis 缓存与 Node.js 一起使用时，套接字已打开问题

Question

当我将 Redis 与我的 node.js 项目一起使用时，我遇到了“错误:套接字已打开问题”。

我正在尝试将数据库结果缓存到 Redis 缓存中。当 Redis 键不为空时，我将从 Redis 键中选取记录。当它为空时，我会从数据库中选择并设置为 Redis Key。

这是我的代码:

const { response } = require('express');
var express = require('express');
var mysql = require('mysql');
const redis = require('redis');
const client = redis.createClient();

function GetLatestPosts() {
    return new Promise(async function(resolve, reject) {
        await client.connect();
        const value = await client.get('indexitems');
        if (value != null) {
            await client.disconnect();
            resolve(JSON.parse(value));
        }
        else {
            var PostsList;
            mysqldb.getConnection(function (err, connection) {
                var sql = "CALL PRC_GetPostsList()";
                connection.query(sql, async function (err, data, fields) {
                    if (err) throw err;
                    PostsList = data[0];
                    await client.set('indexitems', JSON.stringify(PostsList));
                    await client.expire('indexitems', 86400);
                    await client.disconnect();
                    resolve(PostsList);  
                });
            });
        }
    })
}

我随机遇到“错误:套接字已打开问题”。有时它可以毫无问题地工作。有时它会显示错误:套接字已打开。

请帮我解决这个问题。谢谢。

这是我的完整错误:

Error: Socket already opened
RedisSocket.connect (/home/ubuntu/Projects/Site/Web/node_modules/@node-redis/client/dist/lib/client/socket.js:48:19)
Commander.connect (/home/ubuntu/Projects/Site/Web/node_modules/@node-redis/client/dist/lib/client/index.js:156:70)
/home/ubuntu/Projects/Site/Web/routes/index.js:224:22
new Promise (<anonymous>)
GetPostItems (/home/ubuntu/Projects/Site/Web/routes/index.js:223:12)
/home/ubuntu/Projects/Site/Web/routes/index.js:23:29
Layer.handle [as handle_request] (/home/ubuntu/Projects/Site/Web/node_modules/express/lib/router/layer.js:95:5)
next (/home/ubuntu/Projects/Site/Web/node_modules/express/lib/router/route.js:137:13)
Route.dispatch (/home/ubuntu/Projects/Site/Web/node_modules/express/lib/router/route.js:112:3)
Layer.handle [as handle_request] (/home/ubuntu/Projects/Site/Web/node_modules/express/lib/router/layer.js:95:5)

Answer 1

问题发生在 client.connect() 被调用时，而 redis 客户端已经连接。

每当 client.get('indexitems') 返回一个值时，连接就会被 await client.disconnect(); 正确关闭

但是，如果没有值，则会对 mySQL 进行异步调用，并且仅在该请求的回调中进行断开连接。

由于这个 mySQL 调用是异步发生的，函数 GetLatestPosts 可能会在 redis 连接关闭之前再次执行，并且 client.connect() 会被第二次调用，引发错误。

解决方案

与redis客户端的连接可能只在服务器启动时打开一次，并保持打开状态。

这减少了在每次请求时打开一个新的然后关闭它的开销。

修改后的代码可能如下所示:

const { response } = require('express');
var express = require('express');
var mysql = require('mysql');
const redis = require('redis');
const client = redis.createClient();

async function start() {

    await client.connect();

    function GetLatestPosts() {
        return new Promise(async function(resolve, reject) {
            const value = await client.get('indexitems');
            if (value != null) {
                resolve(JSON.parse(value));
            }
            else {
                var PostsList;
                mysqldb.getConnection(function (err, connection) {
                    var sql = "CALL PRC_GetPostsList()";
                    connection.query(sql, async function (err, data, fields) {
                        if (err) throw err;
                        PostsList = data[0];
                        await client.set('indexitems', JSON.stringify(PostsList));
                        await client.expire('indexitems', 86400);
                        resolve(PostsList);  
                    });
                });
            }
        })
    }
}

start()

补充说明:

1. A graceful shutdown也可以实现服务器的连接，以便以干净的方式关闭与数据库客户端的连接。
2. 同样适用于 mysql 连接:它只能在服务器启动时打开一次。
3. 您可能更喜欢调用 client.quit() 而不是 client.disconnect()，以确保所有命令都得到执行 - documented .