Как обмениваться данными между службами в nodejs

Question

Я создал два класса обслуживания. Ниже приведено определение класса ShellService.

class ShellService { 

    create(data, params) { 
    if (Array.isArray(data)) { 
     return Promise.all(data.map(current => this.create(current))); 
    } 
    let hostname=params.query.hostname 
    let port = params.query.port 
    const id = _.uniqueId(); 

    this.shells[id] = spawn('mongo', ['--host', hostname, '--port', port]); 

    return Promise.resolve({id}); 
    } 
... 
} 
module.exports = function() { 
    // Initialize our service with any options it requires 
    let service =new ShellService() 

    return service; 
}; 

В своем методе создания он создает экземпляр оболочки и добавляет его в свой массив объектов оболочки. У меня есть еще один класс обслуживания отдыха и вы хотите получить доступ к объекту массива shells. Как я могу это сделать? Я пробовал ниже, но не работает:

const shellService = require('../shell-service') 
class SocketService { 
    ... 

Я объявил SocketService класс и требуют обслуживания оболочки. Но я не могу позвонить shellService.XXXX в мой класс SocketService. Что я должен сделать, чтобы достичь этого?

Answer 1

Поскольку вы уже хранят ссылку оболочки в this.shells[id] вы, вероятно, хотите реализовать .findservice method, который возвращает список всех доступных оболочек:

class ShellService { 
    find() { 
    const shellProcesses = this.shells; 
    const shells = Object.keys(shellProcesses).map(key => { 
     const shell = shellProcesses[key]; 

     return { 
     id: shell.pid 
     } 
    }); 

    return Promise.resolve(shells); 
    } 

    create(data, params) { 
    if (Array.isArray(data)) { 
     return Promise.all(data.map(current => this.create(current))); 
    } 
    let hostname=params.query.hostname 
    let port = params.query.port 
    const id = _.uniqueId(); 

    this.shells[id] = spawn('mongo', ['--host', hostname, '--port', port]); 

    return Promise.resolve({id}); 
    } 
} 
module.exports = function() { 
    // Initialize our service with any options it requires 
    let service =new ShellService() 

    return service; 
}; 

После зарегистрирован как Перья обслуживания, то вы можете использовать app.service('shells').find().then(shellInfo =>).