Metodi per implementare le attività associate alla CPU nei nodi

Question

Sto usando nodejs per un server Web che decodifica i parametri GET e restituisce i dati in qualche formato codificato. La decodifica/codifica viene eseguita utilizzando il modulo crittografico di nodejs, che sembra essere sincrono. Mentre il tempo necessario per servire una singola richiesta è abbastanza veloce, il blocco del ciclo degli eventi ha reso il servizio scarso con la concorrenza.

Il mio requisito è semplice, rendere la funzionalità di codifica/decodifica al di fuori del ciclo degli eventi.

1. separato processo (child_process o gruppo)

Questo può essere un processo separato esclusivamente per questo scopo, ma dal momento che la codifica/decodifica sarà il blocco nel processo figlio Questo fermerà il processo figlio per ricevere nuovi messaggi, cioè non ci sarà mai una situazione in cui due stringhe sono codificate mentre il processo figlio sarà anche a thread singolo.

1. filettatura separata per ogni richiesta (thread-a-gogo o fibra o nodo WebWorker)

creare un thread separato per ciascuna richiesta di effettuare l'operazione di codifica/decodifica, ma nessuno dei i moduli sembrano funzionare come previsto, ovvero thread-a-gogo non si installa tramite npm, fibra non ha creato un thread separato su run(), node-webworker not working.

Qualcuno ha riscontrato un problema simile o esiste un modo per creare facilmente thread in nodejs con un semplice passaggio di messaggi.

Answer 1

Questo è incorporato nei processi figli del nodo. Documenti qui:

http://nodejs.org/api/child_process.html#child_process_child_send_message_sendhandle

Si potrebbe anche usare cluster:

http://nodejs.org/api/cluster.html#cluster_cluster_fork_env

Con cluster, che avrebbe funzionato qualcosa come:

if (cluster.isMaster) { 
    var worker = cluster.fork(); 
    worker.send('encodeThisString'); 

} else if (cluster.isWorker) { 
    process.on('message', function(msg) { 
    var encrypted = crypto.doSomeEncryption(msg); 
    process.send(encrypted); 
    }); 
}