前端使用xterm通過(guò)socket.io-client和后端通信，后端使用nodejs+utf8+socket.io+ssh2

實(shí)現(xiàn)效果如下：

22.png

前端代碼：

前端主要依賴包：xterm、 xterm-addon-fit、 socket.io-client

react組件：

import "xterm/css/xterm.css";
import io from "socket.io-client";
import { Terminal } from "xterm";
import { FitAddon } from "xterm-addon-fit";
import { Form, Input, Button } from "antd";
import "./index.less";

function WebShell({ host }) {
  const { Item } = Form;
  const [term, setTerm] = useState();
  const [socket, setSocket] = useState();
  const fitAddonRef = useRef(null);

  const addTerm = (val) => {
    if (!val.username) {
      return;
    }
    setTerm(null);
    const termInstance = new Terminal({
      cursorBlink: true,
      scrollback: 50,
    });
    setTerm(termInstance);
    const fitAddon = new FitAddon();
    fitAddonRef.current = fitAddon;
    document.querySelector(".termbox").innerHTML = "";
    termInstance.open(document.querySelector(".termbox"));
    termInstance.loadAddon(fitAddon);
    fitAddon.fit();
    termInstance.focus();

    socket.emit("createNewServer", {
      msgId: "termbox",
      ip: host,
      username: val.username,
      password: val.password,
      cols: 100,
      rows: 20,
    });

    termInstance.onData((data) => {
      console.log(data);
      socket.emit("termbox", data);
    });

    socket.on("termbox", (data) => {
      termInstance.write(data);
    });

    // window.addEventListener(
    //   "resize",
    //   () => {
    //     fitAddon.fit();
    //     socket.emit("resize", {
    //       cols: 100,
    //       rows: 20,
    //     });
    //   },
    //   false
    // );
  };

  useEffect(() => {
    const socketInstance = io("http://XXXX:5000");
    setSocket(socketInstance);
  }, []);

  return (
    <div className="app-container">
      <Form
        className="query-form"
        labelCol={{ span: 4 }}
        wrapperCol={{ span: 16 }}
        onFinish={addTerm}
        initialValues={{
          host: host, // 設(shè)置默認(rèn)值
        }}
      >
        <Item label="地址" name="host">
          <Input disabled />
        </Item>
        <Item label="用戶名" name="username">
          <Input />
        </Item>
        <Item label="密碼" name="password">
          <Input.Password />
        </Item>
        <Button type="primary" htmlType="submit">
          連接
        </Button>
      </Form>
      <div
        style={{
          flex: 1,
          display: "flex",
          paddingBottom: "10px",
          marginTop: "10px",
        }}
      >
        <div
          style={{ paddingLeft: "10px", paddingRight: "10px" }}
          ref={fitAddonRef}
          className="termbox"
        ></div>
      </div>
    </div>
  );
}

export default WebShell;

index.less

.termbox {
  flex: 1;
  width: 100%;
  height: 100%;
  padding: 0 1rem;
}

后端代碼

1、先創(chuàng)建一個(gè)文件夾npm init 一個(gè)新項(xiàng)目
2、安裝依賴express 、utf8、socket.io、ssh2
3、index.js里面代碼如下
4、啟動(dòng)服務(wù) node ./index.js

var app = require('express')();
/**用來(lái)實(shí)現(xiàn)多個(gè)webssh功能**/
const http = require('http').Server(app);
const io = require('socket.io')(http, {cors: true});
const utf8 = require('utf8');
const SSHClient = require('ssh2').Client;


function createNewServer(machineConfig, socket) {
  var ssh = new SSHClient();
  let {msgId, ip, username, password} = machineConfig;
  ssh
    .on('ready', function () {
      socket.emit(msgId, '\r\n*** ' + ip + ' SSH CONNECTION ESTABLISHED ***\r\n');
      // ssh設(shè)置cols和rows處理界面輸入字符過(guò)長(zhǎng)顯示問(wèn)題
      ssh.shell({cols: machineConfig.cols, rows: machineConfig.rows}, function (err, stream) {
        if (err) {
          return socket.emit(msgId, '\r\n*** SSH SHELL ERROR: ' + err.message + ' ***\r\n');
        }
        socket.on(msgId, function (data) {
          stream.write(data);
        });
        stream.on('data', function (d) {
          socket.emit(msgId, utf8.decode(d.toString('binary')));
        }).on('close', function () {
          ssh.end();
        });
        socket.on('resize', function socketOnResize (data) {
          stream.setWindow(data.rows, data.cols);
        });
      })
    })
    .on('close', function () {
      socket.emit(msgId, '\r\n*** SSH CONNECTION CLOSED ***\r\n');
    })
    .on('error', function (err) {
      console.log(err);
      socket.emit(msgId, '\r\n*** SSH CONNECTION ERROR: ' + err.message + ' ***\r\n');
    }).connect({
      host: ip,
      port: 22,
      username: username,
      password: password
  });
}

io.on('connection', function (socket) {
  socket.on('createNewServer', function (machineConfig) {
    // 新建一個(gè)ssh連接
    console.log("createNewServer")
    createNewServer(machineConfig, socket);
  })

  socket.on('disconnect', function () {
    console.log('user disconnected');
  });
})

http.listen(5000, function () {
  console.log('listening on * 5000');
});