使用 Redis 缓存和 Node.js 时，套接字已打开问题

Question

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

我正在尝试将数据库结果缓存到 Redis 缓存中。当 Redis 键不为空时，我将从 Redis 键中选择记录。当它为空时，我将从 DB 中选择并设置为 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. 还可以实现服务器的graceful shutdown，以便以干净的方式关闭与数据库客户端的连接。
2. mysql 连接也是如此：它只能在服务器启动时打开一次。
3. 您可能更喜欢调用client.quit() 而不是client.disconnect()，以确保所有命令都得到执行 - 如documented。