RK
это в том файле, который запускается?
Size: a a a
2019 June 04
А
нет это вообще в разных файлах\классах
RK
process.on('SIGINT'
по идее должно быть в том файле, который ты запускаешь
node server.js
по идее должно быть в том файле, который ты запускаешь
node server.js
RK
тут в server.js
А
да в главном есть, потом я передаю наследникам метод для обратоки. В Cluster'ax всё отрабатывает а в chilprocess не могу кинуть сигнал
А
static spawner(command, args, options, onStderr, onStdout) {
const stdout = [];
const stderr = [];
const promise = spawn(command, args, options);
const { childProcess } = promise;
process.on('SIGINT', (code, signal) => {
console.log('from spawner', code, signal);
});
// var eventEmitter = new process.EventEmitter();
// eventEmitter.emmit('SIGINT', { test: 'test' });
// childProcess.on('SIGINT', (code, signal) => {
// console.log('SIGNAL ::', signal);
// // stdout.push(signal);
//
// // childProcess.disconnect();
// });
// childProcess.on('close', (code, signal) => {
// console.log('close ::', signal);
// // stdout.push(signal);
//
// // childProcess.disconnect();
// });
// childProcess.on('disconnect', (code, signal) => {
// console.log('disconnect ::', signal);
// // childProcess.disconnect();
// });
// childProcess.on('exit', (code, signal) => {
// console.log('exit ::', signal);
// // childProcess.disconnect();
// });
childProcess.stderr.on('data', data => {
console.log('stderr', data);
stderr.push(data);
onStderr(data);
});
childProcess.stdout.on('data', data => {
console.log('stdout', data);
stdout.push(data);
onStdout(data);
});
console.log('events', childProcess._events);
return promise.then(() => Buffer.concat(stdout)).catch(err => {
err.message = Buffer.concat(stderr).toString();
console.log('message', err.message);
return Promise.reject(err);
});
}А
в Childprocess._events есть слушатели
А
причём все
RK
хз, с этим не работал(
O
привіт всім! якщо хтось останім часом займався парсингом pdf, підкажіть які пакети юзали? дивлюсь на цей https://www.npmjs.com/package/pdf-parse, але в він має останній мейнтейн 7 місяців тому. Або цей https://www.npmjs.com/package/pdf2json . Поділіться досідом якщо юзали якийсь з них.
A
Привет, вопрос : jwt.decode(token) возвращает null, хотя токен передаю, почему такое может быть?
KR
че за модуль?
KR
если там коллбек, то в ноде обычно первым аргументом идет ошибка, а значение вторым
KR
и ошибка нулл
BY
Андрей
Доброго дня, помогите разобраться. Задача ловить сигнал SIGINT и убивать воркеров созданных через child-process.spawn()
https://youtu.be/CubdrUt-G3c смотри с половины. Должно помочь
TS
@tigermax139 это видео вообще не о том, вопрос был про child_process.spawn, а не про cluster
BY
@tigermax139 это видео вообще не о том, вопрос был про child_process.spawn, а не про cluster
там в примерах должно быть про child_process
и про отлавливание
и про отлавливание
SIGINTTS
там в примерах должно быть про child_process
и про отлавливание
и про отлавливание
SIGINTнету, человек же говорит, что у него с кластером работает, а с child_process нет. Ему вообще даже балансировать сокеты не нужно, он процессы плодит для обработки чего-то а не для сервера
TS
Андрей
static spawner(command, args, options, onStderr, onStdout) {
const stdout = [];
const stderr = [];
const promise = spawn(command, args, options);
const { childProcess } = promise;
process.on('SIGINT', (code, signal) => {
console.log('from spawner', code, signal);
});
// var eventEmitter = new process.EventEmitter();
// eventEmitter.emmit('SIGINT', { test: 'test' });
// childProcess.on('SIGINT', (code, signal) => {
// console.log('SIGNAL ::', signal);
// // stdout.push(signal);
//
// // childProcess.disconnect();
// });
// childProcess.on('close', (code, signal) => {
// console.log('close ::', signal);
// // stdout.push(signal);
//
// // childProcess.disconnect();
// });
// childProcess.on('disconnect', (code, signal) => {
// console.log('disconnect ::', signal);
// // childProcess.disconnect();
// });
// childProcess.on('exit', (code, signal) => {
// console.log('exit ::', signal);
// // childProcess.disconnect();
// });
childProcess.stderr.on('data', data => {
console.log('stderr', data);
stderr.push(data);
onStderr(data);
});
childProcess.stdout.on('data', data => {
console.log('stdout', data);
stdout.push(data);
onStdout(data);
});
console.log('events', childProcess._events);
return promise.then(() => Buffer.concat(stdout)).catch(err => {
err.message = Buffer.concat(stderr).toString();
console.log('message', err.message);
return Promise.reject(err);
});
}В этом коде невозможно не запутаться, полная каша:
- не может быть
- не emmit, а emit
- SIGINT передавать через ивентемиттер бессмысленно
- нету childProcess.stderr, но есть у самих форкнутых процессов stderr
и много чего еще
- не может быть
new process.EventEmitter(); EventEmitter находится в библиотеке events- не emmit, а emit
- SIGINT передавать через ивентемиттер бессмысленно
- нету childProcess.stderr, но есть у самих форкнутых процессов stderr
и много чего еще
TS
Андрей
да в главном есть, потом я передаю наследникам метод для обратоки. В Cluster'ax всё отрабатывает а в chilprocess не могу кинуть сигнал
Код в гитхаб или гист по ссылке, и лапшу перед этим нужно разобрать