如何在Node.js中实现Cassandra数据库的单例连接

在Node.js中使用cassandra-driver时，每次请求创建新的Client实例会浪费资源——因为Client本身已经内置了连接池管理机制。通过单例模式可以确保全局只存在一个Client实例，复用已建立的连接。

实现单例连接模块 #

创建单独的模块（如cassandra-client.js），封装单例逻辑：

const cassandra = require('cassandra-driver');

// 存储单例Client实例
let cassClient = null;

/**
 * 获取Cassandra Client单例实例
 * @returns {cassandra.Client}
 */
function getCassandraClient() {
  // 仅当实例未初始化时创建新连接
  if (!cassClient) {
    cassClient = new cassandra.Client({
      contactPoints: ['yourip'],
      pooling: {
        coreConnectionsPerHost: {
          // 正确引用HostDistance枚举值
          [cassandra.types.HostDistance.LOCAL]: 2,
          [cassandra.types.HostDistance.REMOTE]: 1
        },
        maxRequestsPerConnection: 32768
      },
      localDataCenter: 'ap-south-1',
      keyspace: 'test',
      credentials: { username: 'admin', password: 'admin' }
    });

    // 可选：提前建立连接，避免首次请求延迟
    cassClient.connect()
      .then(() => console.log('Cassandra连接初始化完成'))
      .catch(err => console.error('Cassandra连接初始化失败:', err));
  }

  return cassClient;
}

module.exports = getCassandraClient;

在业务代码中使用单例 #

在需要操作数据库的模块或请求处理逻辑中，引入并复用单例实例：

const getCassandraClient = require('./cassandra-client');

// 示例：Express请求处理
app.get('/fetch-data', async (req, res) => {
  const client = getCassandraClient();
  
  try {
    const query = 'SELECT * FROM your_table LIMIT 10';
    const result = await client.execute(query);
    res.json({ data: result.rows });
  } catch (err) {
    console.error('查询失败:', err);
    res.status(500).json({ error: '数据查询失败' });
  }
});

关键注意事项 #

• 避免重复初始化：所有数据库操作必须通过getCassandraClient()获取实例，禁止在任何地方直接new cassandra.Client()
• 连接池复用：Client初始化时的pooling参数已经定义了连接池规则，单例模式会自动复用这个连接池
• 优雅关闭：应用退出前，调用getCassandraClient().shutdown()关闭所有连接，避免资源泄漏
• 枚举值修正：原代码中HostDistance:{LOCAL : 2,REMOTE : 1}写法错误，必须通过cassandra.types.HostDistance枚举引用正确的常量值

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