go开源webssh终端源码main.go分析

1.地址:  

https://github.com/Jrohy/webssh.git

2.添加中文注释地址:

https://github.com/tonyimax/webssh_cn.git

main.go分析

主包名：main

package main //主包名

依赖包加载

//导入依赖包
import ("embed"                       //可执行文件资源嵌入"flag"                        //标志变量"fmt"                         //格式化"github.com/gin-contrib/gzip" //压缩库"github.com/gin-gonic/gin"    //网页框架"io/fs"                       //文件系统"net/http"                    //http通信"os"                          //系统信息"strconv"                     //字符串转换"strings"                     //字符串"time"                        //时间"webssh/controller"           //websocket通信
)
在可执行文件中嵌入文件夹dist
//go:embed web/dist/*

访问集成文件夹文件系统

var f embed.FS //集成文件集合，取go:embed中文件夹中文件与文件夹列表
变量声明
var (//整形标志声明，用于储存整形指针port = flag.Int("p", //标志名5032,     //标志值"服务运行端口") //标志描述v        = flag.Bool("v", false, "显示版本号")authInfo = flag.String("a", "", "开启账号密码登录验证, '-a user:pass'的格式传参")//普通变量声明timeout    int    //连接超时savePass   bool   //保存密码version    string //版本号buildDate  string //编译时间goVersion  string //go版本号gitVersion string //git版本号username   string //用户名password   string //密码
)

初始化函数分析

func init() {}

初始化变量为标志

//初始化timeout变量为标志flag.IntVar(&timeout, //标志指针"t",              //标志名120,              //标志值"ssh连接超时时间(min)") //标志描述//初始化savePass变量为标志flag.BoolVar(&savePass, //标志指针"s",       //标志名true,      //标志值"保存ssh密码") //标志描述flag.StringVar(&version,"ver","v1.0.0","程序版本号")flag.StringVar(&goVersion,"gover","v1.22","go版本号")flag.StringVar(&gitVersion,"gitver","2.45.2","git版本号")flag.StringVar(&buildDate,"d",time.Now().String(),"编译日期")

操作环境变量

//查找环境变量savePassif envVal, ok := os.LookupEnv("savePass"); ok {//转换环境变量值为Bool值if b, err := strconv.ParseBool(envVal); err == nil {savePass = b //如果环境变量有值保存到savePass}}//读取环境变量用户验证信息if envVal, ok := os.LookupEnv("authInfo"); ok {*authInfo = envVal}//读取环境变量通信端口信息if envVal, ok := os.LookupEnv("port"); ok {//转换为整数if b, err := strconv.Atoi(envVal); err == nil {*port = b}}//必须在标志定义之后及程序访问之前调用flag.Parse()

参数检测

//如果有-v参数，显示版本号信息if *v {fmt.Printf("Version: %s\n\n", version)fmt.Printf("BuildDate: %s\n\n", buildDate)fmt.Printf("GoVersion: %s\n\n", goVersion)fmt.Printf("GitVersion: %s\n\n", gitVersion)os.Exit(0)}

用户名与密码参数分割 (-a user:pass'的格式传参)

if *authInfo != "" {//分割用户名与密码accountInfo := strings.Split(*authInfo, ":")//非空判断if len(accountInfo) != 2 ||accountInfo[0] == "" ||accountInfo[1] == "" {fmt.Println("请按'user:pass'的格式来传参或设置环境变量, 且账号密码都不能为空!")os.Exit(0)}//保存用户名与密码username, password = accountInfo[0], accountInfo[1]}

静态路由函数分析

func staticRouter(router *gin.Engine) {}

创建用户键值对

//创建账户mapaccountList := map[string]string{username: password,}

授权并写页面

//授权路由//传入用户列表{用户:密码}authorized := router.Group("/", gin.BasicAuth(accountList))authorized.GET("", func(c *gin.Context) {//读取主页面indexHTML, _ := f.ReadFile("web/dist/" + "index.html")//向上下文写入主页面c.Writer.Write(indexHTML)})

http操作静态资源

staticFs, _ := fs.Sub(f, "web/dist/static")
router.StaticFS("/static", http.FS(staticFs))

main主函数分析

func main() {}

设置http服务参数并启用路由

//取web引擎实例server := gin.Default()//设置可信代理server.SetTrustedProxies(nil)//使用压缩中间件，支持资源压缩功能server.Use(gzip.Gzip(gzip.DefaultCompression))//启动路由staticRouter(server)

HTTP服务操作:

//HTTP服务操作//GET操作,连接终端websocketserver.GET("/term", func(c *gin.Context) {//调用终端websocketcontroller.TermWs(c, time.Duration(timeout)*time.Minute)})//GET操作,SSH服务检测server.GET("/check", func(c *gin.Context) {//检测SSH服务responseBody := controller.CheckSSH(c)//保存连接密码responseBody.Data = map[string]interface{}{"savePass": savePass,}//渲染JSON数据及HTTP状态码给客户端c.JSON(200, responseBody)})

文件资源操作：

//文件资源操作file := server.Group("/file"){//请求文件列表file.GET("/list", func(c *gin.Context) {c.JSON(200, controller.FileList(c))})//下载文件file.GET("/download", func(c *gin.Context) {controller.DownloadFile(c)})//上传文件file.POST("/upload", func(c *gin.Context) {c.JSON(200, controller.UploadFile(c))})//上传/下载进度处理file.GET("/progress", func(c *gin.Context) {controller.UploadProgressWs(c)})}

启动HTTP服务

//启动HTTP服务server.Run(fmt.Sprintf(":%d", *port))

启动成功输出 如下日志：

[GIN-debug] [WARNING] Creating an Engine instance with the Logger and Recovery middleware already attached.[GIN-debug] [WARNING] Running in "debug" mode. Switch to "release" mode in production.- using env:	export GIN_MODE=release- using code:	gin.SetMode(gin.ReleaseMode)[GIN-debug] GET    /                         --> main.staticRouter.func2 (4 handlers)
[GIN-debug] GET    /static/*filepath         --> github.com/gin-gonic/gin.(*RouterGroup).createStaticHandler.func1 (4 handlers)
[GIN-debug] HEAD   /static/*filepath         --> github.com/gin-gonic/gin.(*RouterGroup).createStaticHandler.func1 (4 handlers)
[GIN-debug] GET    /term                     --> main.main.func1 (4 handlers)
[GIN-debug] GET    /check                    --> main.main.func2 (4 handlers)
[GIN-debug] GET    /file/list                --> main.main.func3 (4 handlers)
[GIN-debug] GET    /file/download            --> main.main.func4 (4 handlers)
[GIN-debug] POST   /file/upload              --> main.main.func5 (4 handlers)
[GIN-debug] GET    /file/progress            --> main.main.func6 (4 handlers)
[GIN-debug] Listening and serving HTTP on :5032

main.go

package main //主包名
//导入依赖包
import ("embed"                       //可执行文件资源嵌入"flag"                        //标志变量"fmt"                         //格式化"github.com/gin-contrib/gzip" //压缩库"github.com/gin-gonic/gin"    //网页框架"io/fs"                       //文件系统"net/http"                    //http通信"os"                          //系统信息"strconv"                     //字符串转换"strings"                     //字符串"time"                        //时间"webssh/controller"           //websocket通信
)// 在可执行文件中嵌入文件夹dist
//
//go:embed web/dist/*
var f embed.FS //集成文件集合，取go:embed中文件夹中文件与文件夹列表
// 变量声明
var (//整形标志声明，用于储存整形指针port = flag.Int("p", //标志名5032,     //标志值"服务运行端口") //标志描述v        = flag.Bool("v", false, "显示版本号")authInfo = flag.String("a", "", "开启账号密码登录验证, '-a user:pass'的格式传参")//普通变量声明timeout    int    //连接超时savePass   bool   //保存密码version    string //版本号buildDate  string //编译时间goVersion  string //go版本号gitVersion string //git版本号username   string //用户名password   string //密码
)// 初始化
func init() {//初始化timeout变量为标志flag.IntVar(&timeout, //标志指针"t",              //标志名120,              //标志值"ssh连接超时时间(min)") //标志描述//初始化savePass变量为标志flag.BoolVar(&savePass, //标志指针"s",       //标志名true,      //标志值"保存ssh密码") //标志描述flag.StringVar(&version,"ver","v1.0.0","程序版本号")flag.StringVar(&goVersion,"gover","v1.22","go版本号")flag.StringVar(&gitVersion,"gitver","2.45.2","git版本号")flag.StringVar(&buildDate,"d",time.Now().String(),"编译日期")//查找环境变量savePassif envVal, ok := os.LookupEnv("savePass"); ok {//转换环境变量值为Bool值if b, err := strconv.ParseBool(envVal); err == nil {savePass = b //如果环境变量有值保存到savePass}}//读取环境变量用户验证信息if envVal, ok := os.LookupEnv("authInfo"); ok {*authInfo = envVal}//读取环境变量通信端口信息if envVal, ok := os.LookupEnv("port"); ok {//转换为整数if b, err := strconv.Atoi(envVal); err == nil {*port = b}}//必须在标志定义之后及程序访问之前调用flag.Parse()//如果有-v参数，显示版本号信息if *v {fmt.Printf("Version: %s\n\n", version)fmt.Printf("BuildDate: %s\n\n", buildDate)fmt.Printf("GoVersion: %s\n\n", goVersion)fmt.Printf("GitVersion: %s\n\n", gitVersion)os.Exit(0)}if *authInfo != "" {//分割用户名与密码accountInfo := strings.Split(*authInfo, ":")//非空判断if len(accountInfo) != 2 ||accountInfo[0] == "" ||accountInfo[1] == "" {fmt.Println("请按'user:pass'的格式来传参或设置环境变量, 且账号密码都不能为空!")os.Exit(0)}//保存用户名与密码username, password = accountInfo[0], accountInfo[1]}
}// 启动静态路由
func staticRouter(router *gin.Engine) {//如果密码不为空if password != "" {//创建账户mapaccountList := map[string]string{username: password,}//授权路由//传入用户列表{用户:密码}authorized := router.Group("/", gin.BasicAuth(accountList))authorized.GET("", func(c *gin.Context) {//读取主页面indexHTML, _ := f.ReadFile("web/dist/" + "index.html")//向上下文写入主页面c.Writer.Write(indexHTML)})} else {router.GET("/", func(c *gin.Context) {indexHTML, _ := f.ReadFile("web/dist/" + "index.html")c.Writer.Write(indexHTML)})}//http操作静态资源staticFs, _ := fs.Sub(f, "web/dist/static")router.StaticFS("/static", http.FS(staticFs))
}func main() {//取web引擎实例server := gin.Default()//设置可信代理server.SetTrustedProxies(nil)//使用压缩中间件，支持资源压缩功能server.Use(gzip.Gzip(gzip.DefaultCompression))//启动路由staticRouter(server)//HTTP服务操作//GET操作,连接终端websocketserver.GET("/term", func(c *gin.Context) {//调用终端websocketcontroller.TermWs(c, time.Duration(timeout)*time.Minute)})//GET操作,SSH服务检测server.GET("/check", func(c *gin.Context) {//检测SSH服务responseBody := controller.CheckSSH(c)//保存连接密码responseBody.Data = map[string]interface{}{"savePass": savePass,}//渲染JSON数据及HTTP状态码给客户端c.JSON(200, responseBody)})//文件资源操作file := server.Group("/file"){//请求文件列表file.GET("/list", func(c *gin.Context) {c.JSON(200, controller.FileList(c))})//下载文件file.GET("/download", func(c *gin.Context) {controller.DownloadFile(c)})//上传文件file.POST("/upload", func(c *gin.Context) {c.JSON(200, controller.UploadFile(c))})//上传/下载进度处理file.GET("/progress", func(c *gin.Context) {controller.UploadProgressWs(c)})}//启动HTTP服务server.Run(fmt.Sprintf(":%d", *port))
}

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/865833.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

为什么从Java程序粘贴数值到Excel 2024会变为两行？

为什么从Java程序粘贴数值到Excel 2024会变为两行？

问题描述 在从Java程序中粘贴一个数值到Excel 2024时，该数值会自动分成两行显示，而在Excel 2021中不会出现这个问题。 可能原因 这个问题可能是由于以下几个原因导致的： 换行符问题： Java程序在输出数据时可能包含了换行符&…
阅读更多...
中英双语介绍美国的州：内布拉斯加州（Nebraska）

中英双语介绍美国的州：内布拉斯加州（Nebraska）

中文版 内布拉斯加州（Nebraska）位于美国中部，以其广阔的平原、农业生产和丰富的历史遗产而闻名。以下是对内布拉斯加州的详细介绍，包括其地理位置、人口、经济、教育、文化和主要城市。 地理位置 内布拉斯加州东临爱荷华州和密…
阅读更多...
解决js对象解构赋值多行格式被prettier格式化为一行的问题

解决js对象解构赋值多行格式被prettier格式化为一行的问题

目前没有特别好的解决方法，但是有一个hack方法，就是在第一个解构参数后面加个空注释，骗过prettier。 代码示例如下： const {prop1, //prop2,prop3, } props 欢迎关注公众号：清晰编程，获取更多精彩内容
阅读更多...
方向导数和梯度

方向导数和梯度

方向导数和梯度 1 导数的回忆2 偏导数及其向量形式偏导数的几何意义偏导数的向量形式 3 方向导数向量形式几何意义方向导数和偏导的关系 4 梯度5 梯度下降算法 1 导数的回忆 导数的几何意义如图所示： 当 P 0 P_{0} P0​点不断接近 P P P时，导数如下定义…
阅读更多...
springboot私人诊所管理系统-计算机毕业设计源码93887

springboot私人诊所管理系统-计算机毕业设计源码93887

摘要 随着科技的不断发展和医疗服务的日益普及，私人诊所管理系统成为现代医疗管理的重要组成部分。该系统通过引入计算机技术和互联网平台，为患者提供方便快捷的就诊方式，同时也为诊所、医院提供高效的资源管理和服务优化的途径。本文将介绍私…
阅读更多...
[Mdp] lc 494. 目标和(01背包变种+dp+dfs)

[Mdp] lc 494. 目标和(01背包变种+dp+dfs)

文章目录 1. 题目来源2. 题目解析1. 题目来源 链接：494. 目标和 2. 题目解析 方法一：dfs 数据量比较小，长度只有 20，那么针对每一个数都有两种选择，正、负，即 2 20 = 100 w 2^{20} = 100w 220=100w 差不多的时间复杂度，dfs 解决即可。时间复杂度： O ( 2 n ) O(2^{n…
阅读更多...
RocketMQ 顺序消息

RocketMQ 顺序消息

顺序消息 顺序消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。 应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步&#…
阅读更多...
前后端交互常用的时间敏感算法

前后端交互常用的时间敏感算法

前后端交互常用的时间敏感算法 前后端交互中涉及时间敏感的算法主要用于确保数据传输的安全性、有效性和同步性。以下是一些常见的时间敏感算法和技术： 1. 基于时间戳的签名算法（HMAC）： 描述： HMAC（哈希…
阅读更多...
万字详解AI开发中的数据预处理(清洗)

万字详解AI开发中的数据预处理(清洗)

数据清洗（Data Cleaning）是通过修改、添加或删除数据的方式为数据分析做准备的过程，这个过程通常也被称为数据预处理（Data Preprocessing）。对于数据科学家和机器学习工程师来说，熟练掌握数据清洗全流程至关…
阅读更多...
21_硬件电路基础

21_硬件电路基础

目录 组合逻辑电路 组合逻辑电路原理 真值表 布尔代数 门电路 译码器 发光二极管LED 液晶字符显示器LCD 数据选择器 数据分配器 多路开关 时序逻辑电路 时序逻辑电路原理 时钟信号 触发器 电位触发方式触发器 边沿触发方式触发器 寄存器 移位器 计数器 总线…
阅读更多...
经营人心：Mrs. B的百年传奇

经营人心：Mrs. B的百年传奇

这个故事的主角是Rose Blumkin，也被称为Mrs. B，她是Nebraska Furniture Mart的创始人。 她的故事确实是一个关于用户思维、客户关系和创业精神的经典案例。 Rose Blumkin于1893年出生在俄罗斯的一个小村庄，她在1921年移民到美国。 1937年&…
阅读更多...
NEEP-EN2-2019-Text1

NEEP-EN2-2019-Text1

英二-2019-Text1摘自大西洋月刊《The Atlantic》2018年4月的一篇名为“When Guilt is Good”的文章。 以下为个人解析，非官方公开标准资料，可能有误，仅供参考。（单词解释仅摘出部分词性和意思） Paragraph 1 Unlike s…
阅读更多...
微信小程序利用第三方库xlsx导出excel

微信小程序利用第三方库xlsx导出excel

微信小程序导出excel 微信小程序利用第三方库xlsx导出excel： 参考： https://blog.csdn.net/weixin_57263939/article/details/128905216 https://blog.csdn.net/gao511147456/article/details/132009965 另外： 微信小程序中pdf的上传、下载及…
阅读更多...
ImportError cannot import name ‘uic‘ from ‘PyQt5‘

ImportError cannot import name ‘uic‘ from ‘PyQt5‘

ImportError cannot import name ‘uic’ from ‘PyQt5’ 1、描述 使用nuitka把PyQt5打包exe文件时报错： ImportError cannot import name ‘uic’ from ‘PyQt5’ 2、原因 这个是由于无法找到uic的目录导致的，在PyQt5的目录下是有uic文件的。 3、解决方案 找到导入uic…
阅读更多...
SQL Server 2022的组成

SQL Server 2022的组成

《SQL Server 2022从入门到精通（视频教学超值版）》图书介绍-CSDN博客 SQL Server 2022主要由4部分组成，分别是数据库引擎、分析服务、集成服务和报表服务。本节将详细介绍这些内容。 1.2.1 SQL Server 2022的数据库引擎 SQL Server 2022的…
阅读更多...
NGINX+KEEPALIVED | 一文搞懂NG+KL负载均衡高可用架构的实操教程（详细）

NGINX+KEEPALIVED | 一文搞懂NG+KL负载均衡高可用架构的实操教程（详细）

文章目录 NGINXKEEPALIVED负载均衡高可用架构为什么需要多节点应用为什么需要Nginx服务为什么需要Keepalived服务NGKL简述前期准备Linux服务器公共环境配置Server1 NGKL服务器配置Server2 NGKL服务器配置Server3 HTTP服务器配置Server4 HTTP服务器配置运行测试用例 NGINXKEEPAL…
阅读更多...
C# winform中权限页面的设计和开发

C# winform中权限页面的设计和开发

在C# WinForm应用中设计和开发权限页面，主要涉及到用户界面的创建、数据模型的构建以及业务逻辑的实现。以下是一个基本的步骤，可用来参考构建一个权限管理页面： 第一步：设计用户界面 创建一个新的WinForm：在Visual S…
阅读更多...
CPU/内存/综合性能评估工具汇总-1:lmbench

CPU/内存/综合性能评估工具汇总-1:lmbench

目录 一、概括二、lmbench 一、概括 嵌入式开发中对要设计的产品、立项的项目进行设计时，往往需要对关键芯片进行性能评估，本文主要总结基于linux系统的产品在性能评估时的工具使用总结，在aarch64(arm64平台下测试)，板卡根文件系…
阅读更多...
使用Keil将STM32部分程序放在RAM中运行

使用Keil将STM32部分程序放在RAM中运行

手动分配RAM区域,新建.sct文件,定义RAM_CODE区域,并指定其正确的起始地址和大小。 ; ************************************************************* ; *** Scatter-Loading Description File generated by uVision *** ; ************************************************…
阅读更多...
C语言 -- 函数

C语言 -- 函数

C语言 -- 函数 1. 函数的概念2. 库函数2.1 标准库和头文件2.2 库函数的使用方法2.2.1 功能2.2.2 头文件包含2.2.3 实践2.2.4 库函数文档的一般格式 3. 自定义函数3.1 函数的语法形式3.2 函数的举例 4. 形参和实参4.1 实参4.2 形参4.3 实参和形参的关系 5. return 语句6. 数组做…
阅读更多...
最新文章

Copyright @ 2022~2023