New release is coming soon! If you want to try out the latest features, simply run npm i -s moleculer@next. The docs for the latest version are available here.

生命周期

服务管理器生命周期

本节描述服务管理器启动 & 停止时发生什么。

启动逻辑

启动时,服务器试图与 transporter 建立一个连接。 连接建立后,服务管理器此时还不能将本地服务列表发布到远程节点,因为此时它还不能接受任何请求。 服务管理器启动所有服务(通过调用所有service 提供的started处理器)。 一旦所有服务成功启动,服务管理器就会向远程节点发布本地服务列表。 因此,远程节点仅在所有本地服务正常初始化和启动后发送请求。

Broker starting lifecycle diagram
Avoid deadlocks

当两个服务相互等待对方,可能出现死锁。 例如: users 服务有 dependencies:["posts"]posts 服务有 dependencies:["users"] 若要避免死锁,请从 dependencies 删除依赖,在 started 处理器中使用this.waitForServices 方法替代依赖项配置。

停止逻辑

当您调用 broker.stop 或停止进程时,服务管理器首先会向远程节点发布一个空的服务列表,因此它们会将请求路由到其他实例而不是正在停止的服务。 接着,服务管理器开始 stopping 所有本地服务。 而后,transporter 断开所有连接并退出进程。

Broker stopping lifecycle diagram

服务生命周期

本节描述服务启动 & 停止时发生什么,以及您应如何使用生命周期事件处理器。

created 事件处理器

当创建服务实例时触发此处理程序(例如, broker.createServicebroker.loadService)。 您可以使用它来创建其它模块实例(例如http 服务器,数据库模块),并将它们保存在 this 中。

const http = require("http");

module.exports = {
name: "www",
created() {
// Create HTTP server
this.server = http.createServer(this.httpHandler);
}
};

这是一个同步事件处理器。 您 无法 返回 Promise 并且您 不能 使用 async/await

started 事件处理器

当调用 broker.start 并且经纪启动完所有本地服务时,触发此处理程序。 使用它来连接数据库、监听服务器…等。

module.exports = {
name: "users",
async started() {
try {
await this.db.connect();
} catch(e) {
throw new MoleculerServerError("Unable to connect to database.", e.message);
}
}
};

这是一个异步事件处理器。 可以返回 Promise 或者使用 async/await

stopped 事件处理器

当调用 broker.stop 并且服务管理器开始着手停止所有本地服务时,触发此处理程序。 使用它来关闭数据库连接,关闭套接字…等。

module.exports = {
name: "users",
async stopped() {
try {
await this.db.disconnect();
} catch(e) {
this.logger.warn("Unable to stop database connection gracefully.", e);
}
}
};

这是一个异步事件处理器。 可以返回 Promise 或者使用 async/await

merged 事件处理器

此处理器是在服务模式(包括 mixins) 合并后调用的,但在服务注册之前调用。 这意味着您可以在处理之前操纵已合并的服务方案。

// posts.service.js
module.exports = {
name: "posts",

settings: {},

actions: {
find: {
params: {
limit: "number"
},
handler(ctx) {
// ...
}
}
},

merged(schema) {
// Modify the service settings
schema.settings.myProp = "myValue";
// Modify the param validation schema in an action schema
schema.actions.find.params.offset = "number";
}
};