ssh2-multiplexer
v0.0.8
Published
Node.js ssh2 exec multiplexer.
Downloads
2
Readme
ssh2-multiplexer
Uses ssh2 module's connections.
Allows to enqueue/backpressure/multiplex'ish the available SSH channels in order to send a larger number of commands.
Check the examples.
More about ssh channels limit: http://pedromadias.wordpress.com/2013/06/03/ssh-connections-channel-limit-and-node-js/
Example
var Connection = require('ssh2'),
ConnectionQueuer = require('ssh2-multiplexer'),
var conn = new Connection();
//...
var queuer = new ConnectionQueuer(conn);
queuer.exec('sleep 1; uptime;', function(err, stream) {
if (err) throw err;
stream.on('data', function(data, extended) {
console.log((extended === 'stderr' ? 'STDERR: ' : 'STDOUT: ') + data);
});
stream.on('end', function() {
console.log('Stream :: EOF');
});
stream.on('close', function() {
console.log('Stream :: close');
});
stream.on('exit', function(code, signal) {
console.log('Stream :: exit :: code: ' + code + ', signal: ' + signal);
});
});
Complete example
var Connection = require('ssh2');
var ConnectionQueuer = require('ssh2-multiplexer');
var c = new Connection();
var queuer = new ConnectionQueuer(c);
c.on('ready', function() {
console.log('Connection :: ready');
for (var i = 50; i >= 0; i--) {
//if you use 'c' instead of 'queuer' in this exec, it will crash due to channel limit. Openssh allows 8 channels by default.
queuer.exec('sleep 1; uptime;', function(err, stream) {
if (err) throw err;
stream.on('data', function(data, extended) {
console.log((extended === 'stderr' ? 'STDERR: ' : 'STDOUT: ') + data);
});
stream.on('end', function() {
console.log('Stream :: EOF');
});
stream.on('close', function() {
console.log('Stream :: close');
});
stream.on('exit', function(code, signal) {
console.log('Stream :: exit :: code: ' + code + ', signal: ' + signal);
});
});
}
});
c.on('error', function(err) {
console.log('Connection :: error :: ' + err);
});
c.on('end', function() {
console.log('Connection :: end');
});
c.on('close', function(had_error) {
console.log('Connection :: close');
});
c.connect({
host: '127.0.0.1',
port: 22,
username: 'root',
passphrase: 'passphrase',
privateKey: require('fs').readFileSync(process.env.HOME + '/.ssh/id_rsa')
});