Moleculer执行createProduct时this.adapter为undefined的问题求助

问题根源 #

this.adapter未初始化，说明你的Products服务没有正确配置MongoDB/Mongoose适配器，导致服务实例无法关联数据库操作对象。

解决步骤 #

1. 确保安装依赖 #

首先确认已安装moleculer-db-mongoose及相关依赖：

npm install moleculer-db-mongoose mongoose --save

2. 配置服务的Mongoose适配器 #

在products.service.js中，必须在服务的settings字段里指定Mongoose适配器和对应的模型：

方式一：对象式服务定义

const MongooseAdapter = require("moleculer-db-mongoose");
const ProductModel = require("../models/product.model"); // 替换为你的Product模型路径

module.exports = {
  name: "products",
  settings: {
    // 配置MongoDB连接字符串，替换为你的数据库地址
    adapter: new MongooseAdapter("mongodb://localhost:27017/你的数据库名"),
    // 关联Mongoose模型
    model: ProductModel
  },
  actions: {
    createProduct: {
      rest: {
        method: "PUT",
        path: "/product"
      },
      params: {
        name: "string",
        price: "number",
        quantity: "number"
      },
      async handler(ctx) {
        const { name, price, quantity } = ctx.params;
        try {
          const product = await this.adapter.insert({ name, price, quantity });
          return product;
        } catch (err) {
          throw new MoleculerError("Could not create product", 500, "CREATE_PRODUCT_ERR", { error: err.message });
        }
      }
    }
  }
};

方式二：类式服务定义

const { Service } = require("moleculer");
const MongooseAdapter = require("moleculer-db-mongoose");
const ProductModel = require("../models/product.model");

module.exports = class ProductsService extends Service {
  constructor(broker) {
    super(broker);
    this.parseServiceSchema({
      name: "products",
      settings: {
        adapter: new MongooseAdapter("mongodb://localhost:27017/你的数据库名"),
        model: ProductModel
      },
      actions: {
        // 你的createProduct action代码
      }
    });
  }
};

3. 验证MongoDB连接 #

确保MongoDB服务正在运行，且连接字符串中的地址、端口、数据库名正确。如果使用远程MongoDB，需额外检查权限配置与网络连通性。

额外注意事项 #

• 不要在action的handler中使用箭头函数，否则会改变this指向，导致无法访问服务实例的adapter属性。
• 你的Product模型需正确定义Mongoose Schema，示例：

const mongoose = require("mongoose");

const ProductSchema = new mongoose.Schema({
  name: { type: String, required: true },
  price: { type: Number, required: true },
  quantity: { type: Number, required: true }
});

module.exports = mongoose.model("Product", ProductSchema);

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