Как создать отдельную команду / процесс в Rust? - PullRequest
Новая
       9

Как создать отдельную команду / процесс в Rust?

0 голосов
/ 24 мая 2018

Я написал небольшой исполняемый файл для запуска сервера WebSocket для среды разработки Node.

В отдельном приложении NodeJS (запущенном в Electron) я использую child_process.spawn() для запуска двоичного файла и запускасервер при запуске приложения.

Этот дочерний процесс сервера перехватывает порожденную команду узла child_process и не завершается, поэтому я не могу перехватить код выхода или обработать сбои.Мне просто нужно знать, начался он или нет.

Как запустить этот процесс в Rust, чтобы я мог выйти (в случае успеха, сбоя и т. Д.), И ребенок продолжил бежать?

Соответствующие части моего main.rs: 

extern crate ws;

use std::env;
use std::process::Command;
use ws::{connect, CloseCode};

fn main() {
    let args: Vec<String> = env::args().collect();
    let command = &args[1];
    if command == "activate" {
        println!("Activating");
        stop_server_process();
        start_server_process();
    }
}

fn start_server_process() {
    let mut command;
    if cfg!(windows) {
        command = Command::new(".\\node_modules\\.bin\\ws.cmd");
    } else {
        command = Command::new("./node_modules/.bin/ws");
    }
    command.arg("--websocket");
    command.arg("test/mock-api/ws-server.js");
    command.arg("-p");
    command.arg("9401");
    match command.spawn() {
        Ok(child) => println!("Server process id is {}", child.id()),
        Err(e) => {
            println!("Server didn't start: {}", e);
            std::process::exit(1);
        },
    }
    std::process::exit(0);
}

fn stop_server_process() {
    connect("ws://localhost:9401", |out| {
        out.send("server-stop").unwrap();
        move |msg| {
            println!("Got message: {}", msg);
            out.close(CloseCode::Normal)
        }
    }).unwrap()
}

Я запускаю двоичный файл из моего приложения Electron следующим образом: 

/**
 * @return {Promise<Boolean>}
 */
static activate() {
  return new Promise((resolve, reject) => {
    const command = spawn(process.env.SERVER_LOCAL_PATH, ['activate']);
    command.stdout.on('data', (data) => {
      console.log(`stdout: ${data}`);
    });
    command.stderr.on('data', (data) => {
      console.log(`stderr: ${data}`);
    });
    command.on('close', code => resolve(code === 0));
    command.on('error', error => reject(error));
  });
}

Это никогда не разрешается как wsЗапускается websocket, и порожденный процесс теперь получает события из этого.Вывод моей консоли следующий: 

stdout: Activating <--- Rust binary output
Server process id is 78057 <--- Rust binary output
stderr: Serving at [various URL variations] <--- ws binary output
stdout: Client Connected <--- ws binary output

Сервер WebSocket основан на примерах и коде из этой библиотеки .Вот его воспроизводимая версия: 

module.exports = SocketBase => class Socket extends SocketBase {
  websocket(wss) {
    wss.on('connection', (ws) => {
      console.log('Client Connected');
      ws.on('message', (data) => {
        if (data === 'server-stop') {
          console.log('Stopping...');
          process.exit(0);
        }
        // do some faked JSON response data
      });
      ws.on('close', () => {
        console.log('Client Disconnected');
      });
      ws.on('error', (error) => {
        console.log(error.toString());
      });
    });
  }
};
...