使用纯Java实现一个WebSSH项目的示例代码

实现一个WebSSH项目需要分为两部分，前端和后端。前端需要使用WebSocket技术与后端进行通信，后端需要使用SSH协议与远程服务器进行通信。

下面是完整的实现步骤：

步骤一：编写前端页面

前端页面需要包含以下功能：

1. 输入服务器地址、端口号、用户名、密码等信息。
2. 点击连接按钮，建立WebSocket连接。
3. 发送SSH命令到后端。
4. 接收后端返回的结果，并在页面上展示。

以下是一个示例代码，基于Vue.js实现：

<template>
  <div>
    <form>
      <label>服务器地址:</label><input type="text" name="server" v-model="server"><br>
      <label>端口号:</label><input type="text" name="port" v-model="port"><br>
      <label>用户名:</label><input type="text" name="username" v-model="username"><br>
      <label>密码:</label><input type="password" name="password" v-model="password"><br>
    </form>
    <button @click="connect">连接</button>
    <div>
      <textarea v-model="terminal"></textarea>
    </div>
  </div>
</template>

<script>
  export default {
    data () {
      return {
        socket: null,
        server: '',
        port: '',
        username: '',
        password: '',
        terminal: ''
      }
    },
    methods: {
      connect () {
        this.socket = new WebSocket('ws://' + this.server + ':' + this.port)
        this.socket.onopen = () => {
          this.socket.send(`{"username": "${this.username}", "password": "${this.password}"}`)
        }
        this.socket.onmessage = (event) => {
          this.terminal += event.data + '\n'
        }
      }
    }
  }
</script>

步骤二：编写后端代码

后端代码需要使用Java实现，需要使用开源库jsch实现SSH连接。

以下是一个示例代码：

package com.example.webssh;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.*;

import javax.websocket.CloseReason;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.io.InputStream;

@SpringBootApplication
@RestController
@ServerEndpoint("/{username}/{password}")
public class WebSSHApplication {
    private Session sshSession;

    @OnOpen
    public void onOpen(Session webSocketSession,
                       @PathParam("username") String username,
                       @PathParam("password") String password) throws Exception {
        JSch jsch = new JSch();
        sshSession = jsch.getSession(username, "localhost", 22);
        sshSession.setPassword(password);
        sshSession.setConfig("StrictHostKeyChecking", "no"); //临时规避公钥
        sshSession.connect();
        Channel channel = sshSession.openChannel("shell");
        channel.setInputStream(webSocketSession.getInputStream());
        channel.setOutputStream(webSocketSession.getBasicRemote().getSendWriter());
        channel.connect();
    }

    @OnMessage
    public void onMessage(String command) throws Exception {
        if (sshSession != null) {
            Channel channel = sshSession.getChannel();
            channel.getOutputStream().write((command + "\r").getBytes());
            channel.getOutputStream().flush();
        }
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) throws IOException {
        if (sshSession != null && sshSession.isConnected()) {
            sshSession.disconnect();
        }
    }

    public static void main(String[] args) {
        SpringApplication.run(WebSSHApplication.class, args);
    }
}

示例解释

示例一：执行命令

在连接成功后，用户可以在页面上输入Linux命令，并点击“执行”按钮，发送命令到后端。

以下是示例代码：

<button @click="execute">执行</button>

execute () {
  let command = this.terminalInput;
  this.socket.send(command);
  this.terminalInput = "";
}

@OnMessage
public void onMessage(String command) throws Exception {
    if (sshSession != null) {
        Channel channel = sshSession.getChannel();
        channel.getOutputStream().write((command + "\r").getBytes());
        channel.getOutputStream().flush();
    }
}

示例二：展示返回结果

后端处理完用户发来的命令后，将执行结果返回给前端，前端需要将结果展示在页面上。

以下是示例代码：

@OnMessage
public void onMessage(String command) throws Exception {
    if (sshSession != null) {
        Channel channel = sshSession.getChannel();
        channel.getOutputStream().write((command + "\r").getBytes());
        channel.getOutputStream().flush();
        InputStream in = channel.getInputStream();
        byte[] buffer = new byte[1024];
        int len;
        while ((len = in.read(buffer)) != -1) {
            String result = new String(buffer, 0, len, "UTF-8");
            session.getBasicRemote().sendText(result);
        }
    }
}

socket.onmessage = (event) => {
  this.terminal += event.data + '\n'
}

这个示例代码中，我们使用了InputStream从SSH的Channel中读取命令执行结果，并将结果通过WebSocket发送给前端。最终前端收到结果后，将其显示在页面上。