我正在使用ssh2和socket.io为Meteor 1.8.1 应用程序的用户启用到远程服务器的实时 ssh 连接。该应用程序在 Nginx 和 Phusion Passenger 下的 Ubuntu 上运行。这是应用程序需要做的事情：
- 每个授权用户已经在远程服务器上拥有一个帐户。
- 用户将通过输入他们的凭据并单击应用程序中的“连接”按钮来启动会话。
- 用户可以在远程服务器上的主目录中浏览目录列表。
- 任何用户都不应有权访问其他用户的 ssh 会话。
- 当用户单击“断开连接”按钮时，应从服务器中删除他们的 ssh 会话。
我的 ssh 连接正常工作，但我不知道如何在用户会话结束时破坏 ssh 连接。每次他们按下“断开连接”然后“连接”时，都会启动另一个 ssh 会话，并且旧的 ssh 会话仍在运行，因此发送的每个 ssh 命令都会执行多次，并且会向浏览器发送多个响应。
我也担心连接不安全。在开发中，我正在使用 require('http').createServer(); 创建服务器。在生产中，在我配置了 SSL 的 Ubuntu 服务器上，使用 require('https').createServer(); 是否足够？或者是否需要其他配置，例如 Nginx？当 websocket 不可用时，Socket.io 会回退到旧技术；那是如何保证的？
主要问题：为什么每次用户断开连接然后连接时我都会看到重复的 SSH 会话？
第二个问题：我在哪里可以找到有关如何保护 socket.io 的最新说明？还是我应该放弃 socket.io 并使用 WebSocket？
我已经阅读了很多文章和堆栈溢出帖子，但我发现这非常令人困惑，并且大多数材料都已过时。例如socketio-auth不被维护。我在Socket.io 文档中几乎找不到关于身份验证或授权的任何内容 - 有一个握手条目，但我不清楚这是我需要的功能还是如何使用它。
这是我的代码。
服务器
io.on('connection', (socket) => {
console.log('socket id', socket.id); // this shows a new id after disconnect / reconnect
const conn = new SSHClient();
socket.on('disconnect', () => {
console.log('disconnect on server');
conn.end();
});
conn.on('ready', () => {
socket.emit('message', '*** SSH CONNECTION ESTABLISHED ***');
socket.emit('ready', 'ready');
conn.shell((err, stream) => {
stream.write('stty -echo \n'); // don't echo our own command back, or the user's password...
if (err) {
return socket.emit('message', `*** SSH SHELL ERROR: ' ${err.message} ***`);
}
socket.on('path', (path) => {
// path is a request for a directory listing
if (typeof path === 'string') {
const bashCommand = `ls -l ${path} --time-style=full-iso`;
console.log('*** WRITE'); // if you disconnect and reconnect this runs twice. Disconnect and reconnect again, it runs 3 times.
console.log('socket id again', socket.id); // this shows the same new socket id each time
stream.write(`${bashCommand} \n`);
}
});
stream.on('data', (d) => {
socket.emit('data', response); // tell the browser!
}).on('close', () => {
conn.end();
});
});
}).on('close', () => {
socket.emit('message', '*** SSH CONNECTION CLOSED ***');
}).on('error', (err) => {
socket.emit('message', `*** SSH CONNECTION ERROR: ${err.message} ***`);
}).connect({
'host': hosturl,
'username': ausername,
'agent': anagent, // just for dev I'm using public / private key from my local machine but this will be replaced with the user's entered credentials
});
}).on('disconnect', () => {
console.log('user disconnected');
});
server.listen(8080);
客户：
const io = require('socket.io-client');
const EventEmitter = require('events');
class MyEmitter extends EventEmitter {};
const myEmitter = new MyEmitter();
const PORT = 8080;
let socket;
myEmitter.on('connectClicked', () => {
if (socket) {
this.connected.set(socket.connected);
}
if (this.connected.get() === false) {
socket = io(`http://localhost:${PORT}`);
socket.on('connect', () => {
this.connected.set(true);
socket.on('ready', () => {
console.log('ready');
});
// Backend -> Browser
socket.on('message', (data) => {
console.log('socket on message', data);
});
// Backend -> Browser
socket.on('data', (data) => {
console.log('got data', data);
this.parseResponse(data); // client function to handle data, not shown here
});
// Browser -> Backend
myEmitter.on('selectDirectory', () => {
console.log('*** SELECT DIRECTORY');
socket.emit('path', pathArray.join('/')); // path array is set in client code, it is a simple array of directory names
});
socket.on('disconnect', () => {
console.log('\r\n*** Disconnected from backend***\r\n');
this.connected.set(false);
});
});
}
myEmitter.on('disconnectClicked', () => {
socket.disconnect();
});
});