Node.js如何同步建立Elasticsearch等数据库连接且不使用callback函数

首先明确：Node.js 是单线程事件驱动架构，不建议也不需要通过强制暂停整个代码执行的方式等待异步连接操作，这种方式会卡死整个事件循环，导致所有IO任务阻塞，完全没有实际使用价值。

你要的「等前一个操作完成再执行下一个」的需求，用ES6+的async/await语法就能实现，完全不需要嵌套callback，代码逻辑是线性的，可读性和可维护性都很高。

实现步骤 #

1. 把所有初始化逻辑封装为返回Promise的async函数

// 加载配置文件
async function loadConfFile() {
  // 示例：异步读取本地配置文件，所有异步操作都可以用await包裹
  const fs = require('fs/promises')
  const configRaw = await fs.readFile('./config.json', 'utf-8')
  return JSON.parse(configRaw)
}

// 初始化ES连接，官方ES客户端原生支持Promise
async function createESConnection(config) {
  const { Client } = require('@elastic/elasticsearch')
  const esClient = new Client({ node: config.es.host })
  // 等待连接测试通过再返回
  await esClient.ping()
  console.log('ES 集群连接成功')
  return esClient
}

// 初始化MongoDB连接，mongoose原生支持Promise
async function createMongoDBConnection(config) {
  const mongoose = require('mongoose')
  await mongoose.connect(config.mongo.uri)
  console.log('MongoDB 连接成功')
  return mongoose.connection
}

2. 编写启动入口函数，按顺序await所有初始化操作，全部完成后再启动express服务

async function bootstrap() {
  try {
    // 串行执行初始化，前一个完成才会走下一个
    const config = await loadConfFile()
    const esClient = await createESConnection(config)
    const mongoConn = await createMongoDBConnection(config)

    // 所有资源初始化完成后再启动web服务
    const express = require('express')
    const app = express()

    // 可以把连接实例挂载到app全局，方便路由里调用
    app.locals.es = esClient
    app.locals.mongo = mongoConn

    // 注册中间件、路由等逻辑
    app.get('/', (req, res) => res.send('服务启动正常'))

    // 监听端口对外提供服务
    app.listen(3000, () => {
      console.log('Express 服务启动完成，端口：3000')
    })
  } catch (err) {
    // 任意一步初始化失败直接退出进程，避免启动异常服务
    console.error('服务初始化失败：', err)
    process.exit(1)
  }
}

// 执行启动逻辑
bootstrap()

优化方案 #

如果ES和MongoDB的初始化没有依赖关系，可以用Promise.all并行执行两个连接操作，加快启动速度：

async function bootstrap() {
  try {
    const config = await loadConfFile()
    // 并行初始化两个数据库，耗时是两个操作的最大值，而非总和
    const [esClient, mongoConn] = await Promise.all([
      createESConnection(config),
      createMongoDBConnection(config)
    ])
    // 后续启动逻辑不变
  } catch (err) {
    console.error('服务初始化失败：', err)
    process.exit(1)
  }
}

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