Не удается запустить клиент websocket как дочерний процесс
Я хочу создать проект на основе узла, который будет иметь несколько разных подключений к веб-сокетам, я в порядке с самим кодом для того, что я хочу сделать, но, похоже, не могу понять, как запустить модули веб-сокетов (код уже написан и перемещен в файл с именем ws.js) для запуска из основного файла server.js.
Я пробовал нереститься как дочерний процесс, но просто получил
Error: spawn ws.js ENOENT
Я удалил весь другой код из каждого файла, чтобы предотвратить скрытые ошибки, содержимое файлов ниже.
Server.js
var child = require('child_process').spawn('node', ['ws.js']);
child.stdout.on('data', function (data) {
console.info('stdout: ' + data);
});
child.stderr.on('data', function (data) {
console.info('stderr: ' + data);
});
child.on('exit', function (code) {
console.info('child process exited with code ' + code);
});
setTimeout(function() {
child.stdin.write('echo %PATH%');
}, 2000);
ws.js
const Gdax = require('gdax');
const publicClient = new Gdax.PublicClient();
const websocket = new Gdax.WebsocketClient(['BTC-USD', 'ETH-USD']);
websocket.on('message', data => {
/* work with data */
console.info("data received");
});
websocket.on('error', err => {
/* handle error */
});
websocket.on('close', () => {
/* ... */
});
РЕДАКТИРОВАТЬ -------------------------- Спасибо за ответ Elliot server.js, приведенный ниже, теперь работает без ошибок, однако дочерний элемент ws.js никогда не записывает данные в консоль, поэтому либо не работает, либо не работает. Любая помощь приветствуется, чтобы заставить это работать.
Ваше здоровье
Да, пробовал, и ошибки нет, но ws.js никогда не записывает в консоль, поэтому можно только предположить, что он не работает или не работает тихо.
Можете ли вы обновить свой код до последней версии
Обновлено, чтобы включить мод, предложенный Эллиотом.
Ответы 1
Что касается журналов консоли, вы должны помнить, что дочерний процесс - это новый процесс, который не использует консоль совместно. Вы можете заставить его работать с spawn(), однако, поскольку вы используете дочерний процесс для выполнения файла nodeJs, я рекомендую использовать child_process.fork() вместо spawn. Он похож на spawn, но специально используется для других процессов nodeJs. Преимущество состоит в том, что это значительно упрощает взаимодействие двух процессов.
Имея это в виду, вы можете сделать следующие обновления:
Server.js:
var child = require('child_process').fork('./ws.js');
child.on('message', function (data) {
console.info('stdout: ' + data);
});
child.on('error', function (data) {
console.info('stderr: ' + data);
});
child.on('exit', function (code) {
console.info('child process exited with code ' + code);
});
ws.js
const Gdax = require('gdax');
const publicClient = new Gdax.PublicClient();
const websocket = new Gdax.WebsocketClient(['BTC-USD', 'ETH-USD']);
websocket.on('message', data => {
/* work with data */
process.send("data received");
});
websocket.on('error', err => {
/* handle error */
});
websocket.on('close', () => {
/* ... */
});
process.send() отправляет данные своему родительскому процессу, где слушатель (т.е.
child.on('message', callback)) ожидает его получения.
Вы пробовали запускать его с исполняемым файлом, например,
child_process.spawn('node', ['ws.js']);?