NestJs微服务场景下MongoDB数据插入失败问题求助

核心问题推测 #

从日志可见，微服务端已成功打印待插入文档且提示"user created successful"，但后续查询返回空值，最可能的原因是主服务与微服务连接的MongoDB数据库/实例不一致——主控制器直接写入的数据库和register微服务写入的数据库并非同一个，导致查询时读取的库无对应数据。

代码问题排查与修复 #

1. 数据库连接配置核对 #

• 检查主服务（Hestia）和register微服务的MongoDB连接字符串，确认两者指向同一个数据库实例和数据库名称。
• 例如：确保两个服务的MONGODB_URI环境变量均为mongodb://localhost:27017/your_db_name，而非不同的库名或地址。

2. 微服务通信模式修正 #

当前HestiaService使用emit()发送单向无响应事件，若需获取创建结果或确保请求被正确处理，应改为请求-响应模式：

• 修改HestiaService的createNewUser方法：

async createNewUser(request: RequestCreateNewUser) {
  // 用send()替代emit()，转为Promise获取响应
  return this.registerClient.send('register_request', request).toPromise();
}

• 同步修改RegisterController的装饰器为@MessagePattern（支持请求-响应）：

@MessagePattern('register_request')
async handleRegisterRequest(@Payload() data: RequestCreateNewUser, @Ctx() context: RmqContext) {
  const channel = context.getChannelRef();
  const originalMsg = context.getMessage();
  try {
    const result = await this.registerService.register(data);
    channel.ack(originalMsg); // 手动确认消息处理完成
    return result; // 返回创建结果给调用方
  } catch (error) {
    channel.nack(originalMsg); // 处理失败时拒绝消息
    throw error;
  }
}

3. 数据写入验证 #

• 直接登录MongoDB客户端，查看register微服务连接的数据库中registers集合（NestJS Mongoose默认将类名转为小写复数）是否存在数据，确认写入操作确实成功。
• 若集合为空，为AbstractRepository的create方法添加错误捕获，排查静默失败：

async create(document: Omit<TDocument, '_id'>, options?: SaveOptions): Promise<TDocument> {
  const createdDocument = new this.model({
    ...document,
    _id: new Types.ObjectId(),
  });
  this.logger.log(createdDocument);
  try {
    const savedDoc = await createdDocument.save(options);
    this.logger.log(`文档已成功保存：${JSON.stringify(savedDoc)}`);
    return savedDoc.toJSON() as unknown as TDocument;
  } catch (error) {
    this.logger.error(`保存文档失败：${error.message}`);
    throw error;
  }
}

4. 查询逻辑验证 #

确保查询所有文档的代码使用与register微服务相同的数据库连接，且查询条件正确（比如空查询find({})）：

// 示例查询代码
async getAllUsers() {
  const users = await this.registerRepository.find({});
  this.logger.log(`查询到用户数量：${users.length}`);
  return users;
}

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