Node-RED全局可用连接池配置：Redis与PostgreSQL共享方案

当然可以在整个Node-RED实例里共享这些连接池，而且在启动时初始化并全局导出是非常合理的方案——毕竟连接池的核心价值就是复用连接，全局共享才能最大化性能收益。下面我给你一步步讲具体怎么做：

1. 编写连接池初始化脚本 #

首先在你的Node-RED用户目录（通常是~/.node-red/）下创建一个名为connection-pools.js的文件，用来统一初始化和管理两个连接池：

const RedisPool = require('redis-connection-pool');
const { Pool } = require('pg');
// 建议把配置抽成单独文件，用环境变量存敏感信息（比如密码）
const config = require('./config');

// 初始化Redis连接池
const redisPool = new RedisPool('globalRedisPool', {
  host: config.redis.host,
  port: config.redis.port,
  max_clients: config.redis.max_clients,
  perform_checks: true,
  database: config.redis.database,
  password: config.redis.password
});

// 初始化PostgreSQL连接池
const pgPool = new Pool({
  user: config.postgres.user,
  host: config.postgres.host,
  database: config.postgres.database,
  password: config.postgres.password,
  port: config.postgres.port,
  max: config.postgres.max // 按需调整最大连接数
});

// 监听PG连接池的状态（可选，方便排查问题）
pgPool.on('connect', () => {
  console.log('✅ PostgreSQL连接池已建立连接');
});

pgPool.on('error', (err) => {
  console.error('❌ PostgreSQL连接池出错:', err);
});

// 将连接池挂载到Node-RED的全局上下文
module.exports = function(RED) {
  // 通过RED的全局上下文对象，把连接池暴露给所有节点
  RED.settings.functionGlobalContext.redisPool = redisPool;
  RED.settings.functionGlobalContext.pgPool = pgPool;
  
  console.log('✅ 全局连接池初始化完成');
};

如果需要单独的配置文件，就再创建一个config.js：

// config.js
module.exports = {
  redis: {
    host: 'localhost',
    port: 6379,
    max_clients: 10,
    database: 0,
    password: process.env.REDIS_PASSWORD // 用环境变量避免硬编码敏感信息
  },
  postgres: {
    user: process.env.PG_USER,
    host: 'localhost',
    database: 'your_database_name',
    password: process.env.PG_PASSWORD,
    port: 5432,
    max: 20
  }
};

2. 修改Node-RED配置，启动时加载连接池 #

打开Node-RED用户目录下的settings.js文件，找到并添加onStarted钩子函数，用来在Node-RED启动时执行我们的连接池初始化脚本：

// 加载我们的连接池初始化模块
const initConnectionPools = require('./connection-pools');

module.exports = {
  // ... 保留其他原有配置 ...

  // 配置全局上下文（这里不用额外添加，我们在初始化脚本里直接挂载）
  functionGlobalContext: {
    // 其他全局变量...
  },

  // Node-RED启动完成后触发的钩子
  onStarted: function(RED) {
    initConnectionPools(RED);
  }
};

3. 在节点中使用全局连接池 #

现在不管是函数节点还是你自己开发的自定义节点，都可以直接获取全局的连接池对象来使用，不用重复创建：

函数节点示例： #

// 从全局上下文获取连接池
const redisPool = global.get('redisPool');
const pgPool = global.get('pgPool');

// 使用Redis连接池读取数据
redisPool.get('user:123', (err, value) => {
  if (err) {
    node.error('Redis读取失败:', err);
    return;
  }
  node.send({ payload: { redisData: value } });
});

// 使用PostgreSQL连接池执行查询
pgPool.query('SELECT * FROM users WHERE id = $1', [123], (err, res) => {
  if (err) {
    node.error('PG查询失败:', err);
    return;
  }
  node.send({ payload: { pgData: res.rows[0] } });
});

自定义节点示例： #

如果是开发自定义节点，直接在节点代码里通过RED.settings.functionGlobalContext获取即可：

module.exports = function(RED) {
  function CustomNode(config) {
    RED.nodes.createNode(this, config);
    const node = this;

    // 获取全局连接池
    const redisPool = RED.settings.functionGlobalContext.redisPool;

    node.on('input', function(msg) {
      redisPool.set(msg.key, msg.payload, (err) => {
        if (err) {
          node.error('Redis写入失败:', err);
        } else {
          node.send({ payload: '写入成功' });
        }
      });
    });
  }
  RED.nodes.registerType('custom-redis-node', CustomNode);
};

注意事项 #

• 连接池参数优化：根据你的业务并发量调整max_clients（Redis）和max（PG）参数，避免连接数过多导致数据库压力过大。
• 错误处理：一定要监听连接池的错误事件，避免因连接异常导致整个Node-RED实例崩溃。
• 敏感信息管理：绝对不要把密码等敏感信息硬编码到代码里，用环境变量或者配置文件（不要提交到版本库）来管理。
• 单例保证：通过全局上下文挂载的连接池是单例的，确保整个Node-RED实例只会创建一次连接池，最大化复用效率。

内容的提问来源于stack exchange，提问作者cogitoergosum