Merge branch 'master' into master

Author: pczchen

.gitignore

@@ -22,7 +22,6 @@ _testmain.go
 *.bak
 *.[568vq]
 [568vq].out
-bin/*
 bin/apibox
 
 .vscode/tasks.json

.vscode/settings.json

@@ -1,4 +1,4 @@
 // 将设置放入此文件中以覆盖默认值和用户设置。
 {
-    "go.gopath": "/Users/shibingli/Develop/Go_Code/webconsole"
+    "go.gopath": "${workspaceRoot}"
 }

Dockerfile

@@ -1,4 +1,4 @@
-FROM golang:1.8.1-alpine
+FROM golang:1.8.3-alpine
 
 MAINTAINER Eric Shi <[email protected]>
 ADD . /go/

README.md

@@ -1,8 +1,6 @@
-##欢迎大家踊跃报名，利用业余时间来拓展此项目，增加更多的功能服务大家。
-==================
+# 欢迎大家踊跃报名，利用业余时间来拓展此项目，增加更多的功能服务大家。
 
-##常规部署
-------------------
+## 常规部署
 ```
 1、下载 go1.8.1.linux-amd64.tar.gz
 2、tar zxvf go1.8.1.linux-amd64.tar.gz -C /usr/local
@@ -11,49 +9,54 @@
 5、cd /opt && git clone --recurse-submodules https://github.com/shibingli/webconsole.git && cd webconsole && git submodule update --init --recursive
 6、cd /opt/webconsole/src/apibox.club/apibox
 7、GOPATH=/opt/webconsole go install
+8、设置开机自动启动
+  cp /opt/webconsole/bin/webconsole  /etc/init.d/   && chmod   755 /etc/init.d/webconsole 
+  chkconfig   --add  webconsole  &&  chkconfig webconsole   on  && service webconsole   start
+  
+
 ```
 
 [下载 Golang](https://storage.googleapis.com/golang/go1.8.1.linux-amd64.tar.gz)
 
 
-##容器部署
-------------------
+## 容器部署
 ```
 1、下载并安装 Docker
 2、cd /opt && git clone --recurse-submodules https://github.com/shibingli/webconsole.git && cd webconsole && git submodule update --init --recursive
-3、cd /opt/webconsole
-4、docker build -t webconsole:latest .
-5、docker run -d -p 8080:8080 --restart=always --name webconsole webconsole:latest
+3、cd /opt/webconsole/src/apibox.club/apibox
+4、GOPATH=/opt/webconsole go install
+5、cd /opt/webconsole
+6、docker build -t webconsole:latest .
+7、docker run -d -p 8080:8080 --restart=always --name webconsole webconsole:latest
 ```
 
 [安装 Docker](https://docs.docker.com/engine/installation/)
 
 
-##开源捐献日志（感谢各位网友的支持）
-==================
-
-2017.04.05                    
+## 更新日志
 
-    @木乃伊(qq:357573995)       捐献：100.00 元（人民币）
+2018.12.28
 
-2017.04.05                    
-
-    @朱小四(weichat:juechengke) 捐献：200.00 元（人民币）
+    更新：
 
-2017.02.25                    
+        1、更新核心js库
+        2、合并 pczchen 提交的分支，支持 Docker 容器访问
+        3、常规修复
 
-    @jerry2049                 捐献：100.00 元（人民币）
+2017.07.31
 
-2016.03.13
+    更新：
 
-    @非非不在家(qq:762810120)    捐献：8.88 元（人民币）
+        1、更新 xTerm.js
 
-2016.05.16
+2017.07.20
 
-    @玩蝴蝶的法师(qq:43588476)   捐献：50.00 元（人民币）
+    修证：
 
-##更新日志
-==================
+        1、修证UTF-8字符集展示BUG;
+        2、修证大文件展示BUG。
+       
+     本次BUG由 @AEGQ 修证和贡献代码
 
 2017.04.19
 
@@ -156,14 +159,12 @@
         1、增加后台运行模式(conf/conf.json.  daemon:true/false);
         2、增加程序运行时的PID文件(log/apibox.pid);
 
-##大概的数据流向：
-==================
+## 大概的数据流向：
 ```
     浏览器--》WebSocket--》SSH--》Linux OS
 ```
 
-###代码地址
-=================
+### 代码地址
 
 [Git@OSC](http://git.oschina.net/shibingli/webconsole)
 
@@ -174,8 +175,7 @@
 [演示地址](http://webconsole.realclouds.org)
 
 
-##程序包结构：
-================
+## 程序包结构：
 
 ```
 ├── bin
@@ -235,12 +235,11 @@
 
     2）、成功获取到加密的 en_addr 信息后，以 GET 或 POST 方式访问  "http(s)://ip:port/console/login/'en_addr'" 即可。注: "en_addr" 是通过第 1）步操作获取的数据。
 
-##JQuery Demo:
-======
+## JQuery Demo:
 
         
-###第一种方式（需要二次登陆，同一个域的情况，同样可以使用跨域的方式访问）：
-======
+### 第一种方式（需要二次登陆，同一个域的情况，同样可以使用跨域的方式访问）：
+
 
 ```javascript
 var protocol = (location.protocol === "https:") ? "https://" : "http://";
@@ -261,8 +260,7 @@ $.post(addr+"/console/chksshdaddr?rnd=" + Math.random(), {
 
 
 
-###第二种方式（直接输入远端的主机地址、用户名、密码，然后直接登陆。跨域的情况）：
-======
+### 第二种方式（直接输入远端的主机地址、用户名、密码，然后直接登陆。跨域的情况）：
 
 ```html
 <button class="btn btn-primary" onclick="testDemo();">Test</button>

bin/webconsole

@@ -0,0 +1,73 @@
+#! /bin/sh
+# chkconfig: 2345 85 15
+# Description: Startup script for webconsole webserver on Debian. Place in /etc/init.d and
+# run 'update-rc.d -f webconsole defaults', or use the appropriate command on your
+# distro. For CentOS/Redhat run: 'chkconfig --add webconsole'
+
+### BEGIN INIT INFO
+# Provides:         webconsole
+# Required-Start:    $all
+# Required-Stop:     $all
+# Default-Start:     2 3 4 5
+# Default-Stop:      0 1 6
+# Short-Description: starts the webconsole web server
+# Description:       starts webconsole using start-stop-daemon
+### END INIT INFO
+
+# Author:   licess
+# website:  https://webconsole.realclouds.org
+
+NAME=webconsole
+
+PIDFILE=/opt/webconsole/log/apibox.pid 
+. /etc/init.d/functions
+webconsole_start() {
+	nohup  /opt/webconsole/bin/apibox   start   >/dev/null   2>&1 &
+}
+
+webconsole_stop() {
+        /opt/webconsole/bin/apibox  stop   >/dev/null   2>&1 &
+        rm -f  $PIDFILE
+
+}
+
+case "$1" in
+    start)
+
+        if [ -f "$PIDFILE" ]; then
+            echo "$NAME (pid `pidof $NAME`) already running..."
+            exit 1
+        fi
+        webconsole_start
+        echo "$NAME (pid `pidof $NAME`) is running..."
+        ;;
+
+    stop)
+        echo -n "Stoping $NAME... "
+        webconsole_stop
+         echo "$NAME   is  stopped..."
+        exit 1
+        ;;
+
+    status)
+        if [ -f "$PIDFILE" ]; then
+            echo "$NAME (pid `pidof $NAME`) is running..."
+        else
+            echo "$NAME is stopped."
+            exit 0
+        fi
+           ;;
+    restart)
+        webconsole_stop
+             echo -n "Stoping $NAME... "
+             echo "$NAME   is  stopped..."
+        sleep 1
+        webconsole_start
+            echo "$NAME (pid `pidof $NAME`) is running..."
+        ;;
+    *)
+        echo "Usage: $0 {start|stop|restart|status}"
+        exit 1
+
+esac
+exit 0

src/apibox.club/website/console.go

@@ -1,12 +1,14 @@
 package website
 
 import (
+	"bufio"
 	"bytes"
-	"io"
 	"net"
 	"net/http"
 	"net/url"
 	"strings"
+	"time"
+	"unicode/utf8"
 
 	"apibox.club/utils"
 	"github.com/gorilla/websocket"
@@ -258,25 +260,49 @@ func SSHWebSocketHandler(w http.ResponseWriter, r *http.Request) {
 				defer func() {
 					done <- true
 				}()
-				rbuf := make([]byte, 1024)
-				for {
-					n, err := channel.Read(rbuf)
+				br := bufio.NewReader(channel)
+				buf := []byte{}
 
-					if io.EOF == err {
-						return
-					}
-					if err != nil {
-						apibox.Log_Err(err.Error())
-						return
-					}
-					if n > 0 {
-						err = ws.WriteMessage(websocket.TextMessage, rbuf[:n])
+				t := time.NewTimer(time.Millisecond * 100)
+				defer t.Stop()
+				r := make(chan rune)
+
+				go func() {
+					for {
+						x, size, err := br.ReadRune()
 						if err != nil {
-							apibox.Log_Err(err)
+							apibox.Log_Err(err.Error())
 							return
 						}
+						if size > 0 {
+							r <- x
+						}
+					}
+				}()
+
+				for {
+					select {
+					case <-t.C:
+						if len(buf) != 0 {
+							err = ws.WriteMessage(websocket.TextMessage, buf)
+							buf = []byte{}
+							if err != nil {
+								apibox.Log_Err(err.Error())
+								return
+							}
+						}
+						t.Reset(time.Millisecond * 100)
+					case d := <-r:
+						if d != utf8.RuneError {
+							p := make([]byte, utf8.RuneLen(d))
+							utf8.EncodeRune(p, d)
+							buf = append(buf, p...)
+						} else {
+							buf = append(buf, []byte("@")...)
+						}
 					}
 				}
+
 			}()
 			<-done
 		} else {
@@ -340,10 +366,11 @@ func (c *Console) ConsoleMainPage(w http.ResponseWriter, r *http.Request) {
 			user_name := strings.TrimSpace(de_vm_info_arr[0])
 			user_pwd := strings.TrimSpace(de_vm_info_arr[1])
 			vm_addr := strings.TrimSpace(de_vm_info_arr[2])
-                        vm_time := strings.TrimSpace(de_vm_info_arr[3])
+      vm_time := strings.TrimSpace(de_vm_info_arr[3])
 
 			now := time.Now()
 			start, _ := time.Parse(Time.RFC3339, vm_time)
+
 			url_timeout, err := time.ParseDuration(Conf.Web.UrlTimeout)
 			if nil != err {
 				url_timeout, _ = time.ParseDuration("60s")
@@ -375,10 +402,10 @@ func (c *Console) ConsoleLogin(w http.ResponseWriter, r *http.Request) {
 	user_name := ctx.GetFormValue("user_name")
 	user_pwd := ctx.GetFormValue("user_pwd")
 	vm_addr := ctx.GetFormValue("vm_addr")
-        vm_cid := ctx.GetFormValue("vm_cid")
+  vm_cid := ctx.GetFormValue("vm_cid")
 	vm_time := time.Now().Format(Time.RFC3339)
 
-        apibox.Log_Debug(user_name,user_pwd,vm_addr,vm_cid,vm_time)
+  apibox.Log_Debug(user_name,user_pwd,vm_addr,vm_cid,vm_time)
 
 	if vm_cid == "" {
 		vm_cid = "none"
@@ -415,7 +442,7 @@ func (c *Console) ConsoleLogin(w http.ResponseWriter, r *http.Request) {
 				ssh_info = append(ssh_info, user_name)
 				ssh_info = append(ssh_info, user_pwd)
 				ssh_info = append(ssh_info, vm_addr)
-                                ssh_info = append(ssh_info, vm_time)
+        ssh_info = append(ssh_info, vm_time)
 				ssh_info = append(ssh_info, vm_cid)
 				b64_ssh_info, err := apibox.AESEncode(strings.Join(ssh_info, "\n"), aesKey)
 				if nil != err {