Sun Mar 8 03:09:59 CST 2020

Author: yckj0834

README.md

@@ -129,224 +129,6 @@ this.ws.onclose = () => {
 * [Xterm.js v3](https://github.com/lflxp/gin-xterm/blob/master/src/views/pty/xterm3.vue)
 * [Xterm.js v4](https://github.com/lflxp/gin-xterm/blob/master/src/views/pty/index.vue)
 
-## Golang Websocket
-
-1. 不需要解析Quit操作，那怎么判断程序结束去杀掉线程呢
-
-解答：根据`exec.Command`的`cmd.Wait()`去判断，退出自动触发`quitChan <- true`去结束线程
-
-2. 后端websocket使用的什么项目
-
-解答： `github.com/gorilla/websocket`
-
-3. 如何实现golang命令行exec.Command的结果实时联动操作的？
-
-解答：通过pty/tty在linux启动一个pid线程实现的，具体资料如下：
-
-* [Linux中tty、pty、pts的概念区别](https://blog.csdn.net/fuhanghang/article/details/83691158)
-* [golang pty pkg](github.com/creack/pty)
-
-4. gin或者go http如何做到websocket连接的切换？
-
-解答：`http`升级为[websocket](github.com/gorilla/websocket)
-
-```golang
-...
-
-import "github.com/gorilla/websocket"
-
-var upGrader = websocket.Upgrader{
-	ReadBufferSize:  1024 * 1024,
-	WriteBufferSize: 1024 * 1024 * 10,
-	CheckOrigin: func(r *http.Request) bool {
-		return true
-	},
-}
-
-func ping(c *gin.Context) {
-	//升级get请求为webSocket协议
-	ws, err := upGrader.Upgrade(c.Writer, c.Request, nil)
-	if err != nil {
-		return
-	}
-    defer ws.Close()
-    
-    // todo
-    ...
-}
-```
-
-5. 如何处理每个websocket的多个goroutine正常退出
-
-解答：通过quit Channel + for select
-
-```golang
-// 发送命令的执行结果
-// 不执行具体任务
-func (this *ClientContext) Send(quitChan chan bool) {
-	defer setQuit(quitChan)
-
-	buf := make([]byte, 1024)
-
-	for {
-		select {
-		case <-quitChan:
-			log.Info("Close Send Channel")
-			return
-		default:
-			// 读取命令执行结果并通过ws反馈给用户
-			size, err := this.Pty.Read(buf)
-			if err != nil {
-				log.Errorf("%s命令执行错误退出: %s", this.Request.RemoteAddr, err.Error())
-				return
-			}
-			log.Infof("Send Size: %d buf: %s buf[:size]: %s\n", size, string(buf), string(buf[:size]))
-			if err = this.write(buf[:size]); err != nil {
-				log.Error(err.Error())
-				return
-			}
-		}
-	}
-}
-```
-
-6. 如何判断各种操作类型以及怎么执行
-
-解答：
-
-* 预先设计数据格式
-* for select + switch
-
-```golang
-// 判断命令
-// @Params msg:message
-switch message[0] {
-case Input:
-    // TODO: 用户是否能写入
-    if !this.Xtermjs.Options.PermitWrite {
-        break
-    }
-
-    // base64解码
-    decode, err := utils.DecodeBase64Bytes(string(message[1:]))
-    if err != nil {
-        log.Error(err.Error())
-        break
-    }
-
-    // 向pty中传入执行命令
-    _, err = this.Pty.Write(decode)
-    if err != nil {
-        log.Error(err.Error())
-        return
-    }
-case Ping:
-    this.write([]byte("pong"))
-case ResizeTerminal:
-    // @数据格式 type+rows:cols
-    // base64解码
-    decode, err := utils.DecodeBase64(string(message[1:]))
-    if err != nil {
-        log.Error(err.Error())
-        break
-    }
-
-    tmp := strings.Split(decode, ":")
-    rows, err := strconv.Atoi(tmp[0])
-    if err != nil {
-        log.Error(err.Error())
-        this.write([]byte(err.Error()))
-        break
-    }
-    cols, err := strconv.Atoi(tmp[1])
-    if err != nil {
-        log.Error(err.Error())
-        this.write([]byte(err.Error()))
-        break
-    }
-    window := struct {
-        row uint16
-        col uint16
-        x   uint16
-        y   uint16
-    }{
-        uint16(rows),
-        uint16(cols),
-        0,
-        0,
-    }
-    syscall.Syscall(
-        syscall.SYS_IOCTL,
-        this.Pty.Fd(),
-        syscall.TIOCSWINSZ,
-        uintptr(unsafe.Pointer(&window)),
-    )
-default:
-    this.write([]byte(fmt.Sprintf("Unknow Message Type %s", string(message[0]))))
-    log.Error("Unknow Message Type %v", message[0])
-}
-```
-
-7. 如何设置exec.Command在pty终端的窗口大小
-
-解答：
-
-```golang
-window := struct {
-    row uint16
-    col uint16
-    x   uint16
-    y   uint16
-}{
-    uint16(rows),
-    uint16(cols),
-    0,
-    0,
-}
-syscall.Syscall(
-    syscall.SYS_IOCTL,
-    this.Pty.Fd(),
-    syscall.TIOCSWINSZ,
-    uintptr(unsafe.Pointer(&window)),
-)
-```
-
-8. 还需要注意什么
-
-* 明确命令下发渠道和作用
-
-> this.Pty.Write([]byte(***))
-
-* 明确websocket下发渠道和作用
-
-> this.WsConn.Write([]byte(***))
-
-* 如何操作正在执行中的cmd程序
-
-> this.Cmd.Process.Signal(syscall.Signal(this.Xtermjs.Options.CloseSignal))
-
-* 明确一个exec.Command和一个webscoket.Conn如何对一个http请求保持长连接请求的
-
-一个http.Request请求由cmd.Wait() + go Send() + go Receive() + Channel 将一个完整链路进行串联起来
-
-* 如何下手？设计一个符合场景的struct
-
-```golang
-// 服务端内部处理对象
-type ClientContext struct {
-	Xtermjs    *XtermJs        // 前端配置
-	Request    *http.Request   // http客户端请求
-	WsConn     *websocket.Conn // websocket连接
-	Cmd        *exec.Cmd       // exec.Command实例
-	Pty        *os.File        // 命令行pty代理
-	Cache      *bytes.Buffer   // 命令缓存
-	CacheMutex *sync.Mutex     // 缓存并发锁
-	WriteMutex *sync.Mutex     // 并发安全 通过ws发送给客户
-}
-```
-
 ## 参考
 
-* https://github.com/yudai/gotty @release-1.0
-* https://github.com/creack/pty
 * https://mojotv.cn/2019/05/27/xtermjs-go