Express集成Couchbase Node.js SDK时循环依赖及连接读取错误如何解决？

1. 初始版本循环依赖警告 #

你初始代码的依赖链路是app.js → 路由文件 → AuthorModel → app.js，形成了完整的循环引用链。Node.js处理循环依赖时只会返回未完成的module.exports副本，此时你在Model里读取的bucket属性还未被赋值，因此抛出对应的警告。

2. 拆分后调用方法报错的原因 #

couchbase.connect是异步回调逻辑，你执行require('../config/connection')时，连接回调还没有执行完成，module.exports上挂载的bucket、defaultCollection等属性还不存在，因此Model里拿到的data_collection是undefined，调用get方法自然报错。

步骤1：重写connection.js连接逻辑 #

改用Promise+单例模式管理连接，避免异步赋值exports的问题，同时保证连接不会重复初始化：

const couchbase = require('couchbase');

// 缓存连接单例
let cluster = null;
let bucket = null;
let defaultCollection = null;

// 导出异步初始化方法
async function initCouchbase() {
  // 已初始化直接返回缓存
  if (defaultCollection) {
    return { cluster, bucket, defaultCollection };
  }

  // 用Promise写法替代回调
  cluster = await couchbase.connect('couchbase://localhost', {
    username: 'admin',
    password: '5121451214'
  });
  bucket = cluster.bucket('test_data_bucket');
  const defaultScope = bucket.scope('_default');
  defaultCollection = defaultScope.collection('_default');

  return { cluster, bucket, defaultCollection };
}

module.exports = initCouchbase;

步骤2：修改app.js启动逻辑 #

确保Couchbase连接初始化完成后再挂载路由、启动服务，避免请求进来时连接还未就绪：

const express = require('express');
const bodyParser = require('body-parser');
const initCouchbase = require('./config/connection');

const app = express();

app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));

async function startServer() {
  try {
    // 先完成Couchbase初始化
    await initCouchbase();
    // 初始化完成后再引入路由
    const userRoutes = require('./routes/route');
    app.use('/', userRoutes);

    const port = process.env.port || 3000;
    app.listen(port, () => {
      console.log('Web Server is listening at port '+ port);
    });
  } catch (err) {
    console.error('服务启动失败，Couchbase连接异常：', err);
    process.exit(1);
  }
}

startServer();

步骤3：修改Model逻辑 #

调用方法时先获取已初始化的连接实例，同时修正原代码中err变量名写错的笔误：

const initCouchbase = require('../config/connection');
    
module.exports = {
  async getUsers() {
    const { defaultCollection } = await initCouchbase();
    const res = await defaultCollection.get('invoice_32212100000218');
    console.log(res);
    return 'Hello from express';
  }
}

该方案彻底解决了循环依赖问题，所有代码仅依赖connection.js，没有反向引用。单例缓存逻辑也不会造成重复建立连接的性能损耗，所有数据库操作采用async/await写法更易维护，错误处理也更清晰。

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