Корректное выключение сервиса - с ожиданием завершения работы дочерних процессов, обрабатывающих исходящие сообщения очереди обмена
This commit is contained in:
Mikhail Chechnev
parent
e6379ab50b
commit
4007020fe6
71
core/app.js
71
core/app.js
@ -28,20 +28,55 @@ class ParusAppServer {
|
||||
this.dbConn = null;
|
||||
//Обработчик очереди исходящих
|
||||
this.outQ = null;
|
||||
//Флаг остановки сервера
|
||||
this.bStopping = false;
|
||||
//Привяжем методы к указателю на себя для использования в обработчиках событий
|
||||
this.onDBConnected = this.onDBConnected.bind(this);
|
||||
this.onDBDisconnected = this.onDBDisconnected.bind(this);
|
||||
this.onOutQStarted = this.onOutQStarted.bind(this);
|
||||
this.onOutQStopped = this.onOutQStopped.bind(this);
|
||||
}
|
||||
//При подключении к БД
|
||||
async onDBConnected(connection) {
|
||||
//Укажем логгеру, что можно писать в базу
|
||||
this.logger.setDBConnector(this.dbConn, true);
|
||||
//Сообщим, что подключились к БД
|
||||
await this.logger.info("Сервер приложений подключен к БД");
|
||||
}
|
||||
//При отключении от БД
|
||||
async onDBDisconnected() {
|
||||
//Укажем логгеру, что писать в базу больше нельзя
|
||||
this.logger.removeDBConnector();
|
||||
//Сообщим, что отключились от БД
|
||||
await this.logger.warn("Сервер приложений отключен от БД");
|
||||
}
|
||||
//При запуске обработчика исходящих сообщений
|
||||
async onOutQStarted() {
|
||||
//Сообщим, что запустили обработчик
|
||||
await this.logger.info("Обработчик очереди исходящих сообщений запущен");
|
||||
}
|
||||
//При останове обработчика исходящих сообщений
|
||||
async onOutQStopped() {
|
||||
//Сообщим, что остановили обработчик
|
||||
await this.logger.warn("Обработчик очереди исходящих сообщений остановлен");
|
||||
//Отключение от БД
|
||||
if (this.dbConn) {
|
||||
if (this.dbConn.bConnected) {
|
||||
await this.logger.warn("Отключение сервера приложений от БД...");
|
||||
try {
|
||||
await this.dbConn.disconnect();
|
||||
process.exit(0);
|
||||
} catch (e) {
|
||||
await this.logger.error("Ошибка отключения от БД: " + e.sCODE + ": " + e.sMessage);
|
||||
process.exit(1);
|
||||
}
|
||||
} else {
|
||||
process.exit(0);
|
||||
}
|
||||
} else {
|
||||
process.exit(0);
|
||||
}
|
||||
}
|
||||
//Инициализация сервера
|
||||
async init(prms) {
|
||||
await this.logger.info("Инициализация сервера приложений...");
|
||||
@ -61,34 +96,38 @@ class ParusAppServer {
|
||||
}
|
||||
//Запуск сервера
|
||||
async run() {
|
||||
//Рапортуем, что начали запуск
|
||||
await this.logger.info("Запуск сервера приложений...");
|
||||
//Проверим, что сервер успешно инициализирован
|
||||
if (!this.logger || !this.dbConn || !this.outQ) {
|
||||
throw new ServerError(SERR_COMMON, "Не пройдена инициализация");
|
||||
}
|
||||
//Включим прослушивание событий БД (для подключения/отключения логгера к БД)
|
||||
this.dbConn.on(db.SEVT_DB_CONNECTOR_CONNECTED, this.onDBConnected);
|
||||
this.dbConn.on(db.SEVT_DB_CONNECTOR_DISCONNECTED, this.onDBDisconnected);
|
||||
//Включим прослушивание событий обработчика исходящих сообщений
|
||||
this.outQ.on(oq.SEVT_OUT_QUEUE_STARTED, this.onOutQStarted);
|
||||
this.outQ.on(oq.SEVT_OUT_QUEUE_STOPPED, this.onOutQStopped);
|
||||
//Подключаемся к БД
|
||||
await this.logger.info("Подключение сервера приложений к БД...");
|
||||
await this.dbConn.connect();
|
||||
await this.outQ.startProcessing();
|
||||
//Запускаем обслуживание очереди исходящих
|
||||
await this.logger.info("Запуск обработчика очереди исходящих сообщений...");
|
||||
this.outQ.startProcessing();
|
||||
//Рапортуем, что запустились
|
||||
await this.logger.info("Сервер приложений запущен");
|
||||
}
|
||||
//Останов сервера
|
||||
async stop() {
|
||||
await this.logger.warn("Останов сервера приложений...");
|
||||
if (this.outQ) await this.outQ.stopProcessing();
|
||||
if (this.dbConn) {
|
||||
if (this.dbConn.bConnected) {
|
||||
await this.logger.warn("Отключение сервера приложений от БД...");
|
||||
try {
|
||||
await this.dbConn.disconnect();
|
||||
process.exit(0);
|
||||
} catch (e) {
|
||||
await this.logger.error("Ошибка отключения от БД: " + e.sCODE + ": " + e.sMessage);
|
||||
process.exit(1);
|
||||
}
|
||||
} else {
|
||||
process.exit(0);
|
||||
}
|
||||
if (!this.bStopping) {
|
||||
//Установим флаг - остановка в процессе
|
||||
this.bStopping = true;
|
||||
//Сообщаем, что начала останов сервера
|
||||
await this.logger.warn("Останов сервера приложений...");
|
||||
//Останов обслуживания очереди исходящих
|
||||
await this.logger.warn("Останов обработчика очереди исходящих сообщений...");
|
||||
if (this.outQ) this.outQ.stopProcessing();
|
||||
else this.onOutQStopped();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
67
index.js
67
index.js
@ -29,31 +29,60 @@ process.on("exit", code => {
|
||||
appSrv.logger.warn("Сервер приложений остановлен (код: " + code + ") ");
|
||||
});
|
||||
|
||||
//Перехват CTRL + C (останова процесса)
|
||||
process.on("SIGINT", () => {
|
||||
//Перехват CTRL + C (останов процесса)
|
||||
process.on("SIGINT", async () => {
|
||||
console.log("SIGINT");
|
||||
//Инициируем выход из процесса
|
||||
await appSrv.stop();
|
||||
});
|
||||
|
||||
//Перехват CTRL + \ (останов процесса)
|
||||
process.on("SIGQUIT", () => {
|
||||
console.log("SIGQUIT");
|
||||
//Инициируем выход из процесса
|
||||
appSrv.stop();
|
||||
});
|
||||
|
||||
//Перехват мягкого останова процесса
|
||||
process.on("SIGTERM", () => {
|
||||
console.log("SIGTERM");
|
||||
//Инициируем выход из процесса
|
||||
appSrv.stop();
|
||||
});
|
||||
|
||||
//Грубый останов процесса (здесь сделать ничего нельзя, но мы пытаемся)
|
||||
process.on("SIGKILL", () => {
|
||||
console.log("SIGKILL");
|
||||
//Инициируем выход из процесса
|
||||
appSrv.stop();
|
||||
});
|
||||
|
||||
//Запуск сервера приложений
|
||||
const start = async () => {
|
||||
try {
|
||||
//Инициализируем сервер приложений
|
||||
await appSrv.init({ config: cfg });
|
||||
//Включаем его
|
||||
await appSrv.run();
|
||||
} catch (e) {
|
||||
//Если есть ошибки с которыми сервер не справился - ловим их, показываем...
|
||||
if (e instanceof ServerError) appSrv.logger.error(e.sCode + ": " + e.sMessage);
|
||||
else appSrv.logger.error(SERR_UNEXPECTED + ": " + e.message);
|
||||
//...и пытаемся остановить сервер нормально
|
||||
try {
|
||||
await appSrv.stop();
|
||||
} catch (e) {
|
||||
//Могут быть ошибки и при остановке - это аварийный выход
|
||||
if (e instanceof ServerError) appSrv.logger.error(e.sCode + ": " + e.sMessage);
|
||||
else appSrv.logger.error(SERR_UNEXPECTED + ": " + e.message);
|
||||
process.exit(1);
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
//------------
|
||||
// Точка входа
|
||||
//------------
|
||||
|
||||
//Старутем
|
||||
appSrv
|
||||
.init({ config: cfg })
|
||||
.then(r => {
|
||||
appSrv
|
||||
.run()
|
||||
.then(r => {})
|
||||
.catch(e => {
|
||||
if (e instanceof ServerError) appSrv.logger.error(e.sCode + ": " + e.sMessage);
|
||||
else appSrv.logger.error(SERR_UNEXPECTED + ": " + e.message);
|
||||
appSrv.stop();
|
||||
});
|
||||
})
|
||||
.catch(e => {
|
||||
if (e instanceof ServerError) appSrv.logger.error(e.sCode + ": " + e.sMessage);
|
||||
else appSrv.logger.error(SERR_UNEXPECTED + ": " + e.message);
|
||||
appSrv.stop();
|
||||
});
|
||||
start();
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user