From 0cefdaa03209a11da364b6205f2de9755f085735 Mon Sep 17 00:00:00 2001 From: shaoying Date: Fri, 30 Aug 2019 20:49:02 +0800 Subject: [PATCH] opt context --- Makefile | 7 +- bin/boot.sh | 2 +- etc/dotsfile/shy.vim | 4 +- src/contexts/cli/cli.go | 199 ++++---- src/contexts/cli/version.go | 2 +- src/contexts/ctx/core.go | 3 + src/contexts/ctx/ctx.go | 3 + src/contexts/ctx/type.go | 2 +- src/contexts/nfs/nfs.go | 19 +- src/contexts/ssh/ssh.go | 2 - src/contexts/web/web.go | 38 +- src/contexts/yac/yac.go | 43 +- src/examples/code/code.go | 52 +- src/plugin/context/index.shy | 62 +-- usr/README.md | 901 ----------------------------------- 15 files changed, 215 insertions(+), 1124 deletions(-) delete mode 100644 usr/README.md diff --git a/Makefile b/Makefile index ca99f35c..e7bf42e2 100644 --- a/Makefile +++ b/Makefile @@ -4,16 +4,13 @@ upgrade=usr/upgrade/ install: @go get github.com/nsf/termbox-go - @go get github.com/skip2/go-qrcode @go get github.com/go-sql-driver/mysql - @go get github.com/gomarkdown/markdown @go get github.com/gomodule/redigo/redis - # @go get github.com/PuerkitoBio/goquery - @go get github.com/go-cas/cas + @go get github.com/gomarkdown/markdown + @go get github.com/skip2/go-qrcode @go get gopkg.in/gomail.v2 GOPATH=$(PWD):$(GOPATH) go install $(BENCH) @date - # bench web.code.counter nmake 1 install_all: install touch etc/init.shy diff --git a/bin/boot.sh b/bin/boot.sh index 10c878a0..ae8237b8 100755 --- a/bin/boot.sh +++ b/bin/boot.sh @@ -55,7 +55,7 @@ main() { trap HUP hup log "\nstarting..." while true; do - date && ${ctx_bin} "$@" 2>var/log/boot.log && break + date && ${ctx_bin} "$@" && break log "\n\nrestarting..." && sleep 1 done } diff --git a/etc/dotsfile/shy.vim b/etc/dotsfile/shy.vim index dc0a0c63..921ceef1 100644 --- a/etc/dotsfile/shy.vim +++ b/etc/dotsfile/shy.vim @@ -37,10 +37,12 @@ syn match shyCommand "\(^\|\t\| \|$(\)[a-zA-Z0-9_\.]\+\>" syn match shyOperator "option" +call Keys("Statment", ["fun", "kit"]) +call Keys("SubCommand", ["private", "protected", "public"]) + call Keys("Statment", ["config", "cache"]) call Keys("Statment", ["return", "source"]) call Keys("Statment", ["var", "let"]) -call Keys("Statment", ["fun", "kit"]) call Keys("Statment", ["if", "else", "else if", "for", "end"]) call Keys("Statment", ["label", "goto"]) " context nfs diff --git a/src/contexts/cli/cli.go b/src/contexts/cli/cli.go index dfecabd1..4c95185a 100644 --- a/src/contexts/cli/cli.go +++ b/src/contexts/cli/cli.go @@ -93,32 +93,31 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", "project": &ctx.Config{Name: "project", Value: map[string]interface{}{ "github": "https://github.com/shylinux/context", - "goproxy": "https://goproxy.cn", "import": []interface{}{ - "github.com/nsf/termbox-go", - "github.com/gomodule/redigo/redis", - "github.com/go-sql-driver/mysql", - "github.com/gomarkdown/markdown", - "gopkg.in/gomail.v2", - "github.com/skip2/go-qrcode", - "github.com/PuerkitoBio/goquery", - "github.com/go-cas/cas", - }, "plugin": map[string]interface{}{ + "goproxy": "https://goproxy.cn", + "plugin": map[string]interface{}{ "path": "src/plugin", "list": Template, }, "script": map[string]interface{}{ "path": "usr/script", + }, "trash": map[string]interface{}{ + "path": "usr/trash", }, }, Help: "项目管理"}, "compile": &ctx.Config{Name: "compile", Value: map[string]interface{}{ - "bench": "src/extend/bench.go", "list": []interface{}{ + "name": "bench", "bench": "src/extend/bench.go", "list": []interface{}{ map[string]interface{}{"os": "linux", "cpu": "arm"}, map[string]interface{}{"os": "linux", "cpu": "386"}, map[string]interface{}{"os": "linux", "cpu": "amd64"}, map[string]interface{}{"os": "windows", "cpu": "386"}, map[string]interface{}{"os": "windows", "cpu": "amd64"}, map[string]interface{}{"os": "darwin", "cpu": "amd64"}, + }, "tmp": "var/tmp/go", "dep": []interface{}{ + "github.com/nfs/termbox-go", + "github.com/go-sql-driver/mysql", + "github.com/redigo/redis", + "github.com/gomarkdown/markdown", + "github.com/skip2/go-qrcode", + "gopkg.in//gomail.v2", }, - "env": []interface{}{"GOBIN", "GOPATH", "PATH"}, - "tmp": "var/tmp/go", }, Help: "源码编译"}, "publish": &ctx.Config{Name: "publish", Value: map[string]interface{}{ "path": "usr/publish", "list": map[string]interface{}{ @@ -126,6 +125,7 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", "zone_sh": "bin/zone.sh", "user_sh": "bin/user.sh", "node_sh": "bin/node.sh", + "init_shy": "etc/init.shy", "common_shy": "etc/common.shy", "exit_shy": "etc/exit.shy", @@ -149,6 +149,7 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", "zone_sh": "bin/zone.sh", "user_sh": "bin/user.sh", "node_sh": "bin/node.sh", + "init_shy": "etc/init.shy", "common_shy": "etc/common.shy", "exit_shy": "etc/exit.shy", @@ -158,7 +159,7 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", }, }, Help: "服务升级"}, "missyou": &ctx.Config{Name: "missyou", Value: map[string]interface{}{ - "path": "usr/local/work", "local": "usr/local", + "path": "usr/local/work", }, Help: "任务管理"}, }, Commands: map[string]*ctx.Command{ @@ -166,7 +167,6 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", m.Conf("runtime", "host.GOARCH", runtime.GOARCH) m.Conf("runtime", "host.GOOS", runtime.GOOS) m.Conf("runtime", "host.pid", os.Getpid()) - runtime.GOMAXPROCS(1) m.Confm("runtime", "init", func(index int, key string) { if value := os.Getenv(key); value != "" { @@ -747,136 +747,139 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", return }}, - "project": &ctx.Command{Name: "project init|stat|import|plugin", Help: "项目管理, ", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { + "project": &ctx.Command{Name: "project init|stat|trend|submit|review|plugin [args...]", Help: "项目管理", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { switch arg[0] { case "init": if _, e := os.Stat(".git"); e == nil { + // 更新代码 m.Cmdp(0, []string{"git update"}, []string{"cli.system", "git"}, [][]string{ - []string{"git", "stash"}, []string{"git", "pull"}, []string{"git", "stash", "pop"}, + []string{"stash"}, []string{"pull"}, []string{"stash", "pop"}, }) - m.Cmdy("nfs.git", "status") + + // 更新依赖 + list := [][]string{} + m.Confm("compile", "dep", func(index int, value string) { + list = append(list, []string{value}) + }) + m.Cmdp(0, []string{"go build"}, []string{"cli.system", "go", "get"}, list) + + // 代码状态 + m.Cmdy("cli.system", "git", "status", "-sb", "cmd_parse", "cut") return e } + + // 创建项目 m.Cmdp(0, []string{"git init"}, []string{"cli.system", "git"}, [][]string{ []string{"init"}, []string{"remote", "add", kit.Select("origin", arg, 1), kit.Select(m.Conf("project", "github"), arg, 2)}, []string{"stash"}, []string{"pull"}, []string{"checkout", "-f", "master"}, []string{"stash", "pop"}, }) case "stat": + // 代码统计 m.Cmdy("nfs.dir", "src", "dir_deep", "dir_type", "file", "dir_sort", "line", "int_r") case "trend": + // 提交记录 m.Cmdy("nfs.git", "sum", "-n", kit.Select("20", arg, 1)) - case "review": - m.Cmdy("nfs.git", "diff") - case "submit": + // 提交代码 if len(arg) > 1 { m.Cmdp(0, []string{"git submit"}, []string{"cli.system", "git"}, [][]string{ []string{"commit", "-am", arg[1]}, []string{"push"}, }) } + // 提交记录 m.Cmdy("nfs.git", "logs", "table.limit", "3") - case "import": - list := [][]string{} - m.Confm("project", "import", func(index int, value string) { - list = append(list, []string{value}) - m.Add("append", "time", m.Time()) - m.Add("append", "package", value) - }) - m.Table() - - m.Cmdp(time.Second, []string{"go init"}, []string{"cli.system", "go", "get", - "cmd_env", "GOPROXY", m.Conf("project", "goproxy"), - "cmd_env", "GOPATH", m.Conf("runtime", "boot.ctx_path")}, list) + case "review": + // 代码修改 + m.Cmdy("cli.system", "git", "diff") case "plugin": + // 查看插件 if arg = arg[1:]; len(arg) == 0 { m.Cmdy("nfs.dir", m.Conf("project", "plugin.path"), "time", "line", "name") break } fallthrough default: + // 创建插件 p := path.Join(m.Conf("project", "plugin.path"), arg[0]) if _, e := os.Stat(p); os.IsNotExist(e) && m.Assert(os.MkdirAll(p, 0777)) { m.Confm("project", "plugin.list", func(index int, value map[string]interface{}) { ioutil.WriteFile(path.Join(p, kit.Format(value["name"])), []byte(kit.Format(value["text"])), 0666) }) } + // 插件列表 m.Cmdy("nfs.dir", p, "time", "line", "hashs", "path") } return }}, - "compile": &ctx.Command{Name: "compile all|self|[[[plugin] name] [OS [ARCH]]]", Help: "源码编译", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { - wd, _ := os.Getwd() + "compile": &ctx.Command{Name: "compile all|self|linux|windows|darwin|restart|plugin", Help: "项目编译", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { switch arg[0] { case "all": + // 所有版本 list := [][]string{} m.Confm("compile", "list", func(index int, value map[string]interface{}) { list = append(list, []string{kit.Format(value["os"]), kit.Format(value["cpu"])}) }) m.Cmdp(0, []string{"go build"}, []string{"cli.compile"}, list) - m.Cmdy("nfs.dir", m.Conf("publish", "path"), "dir_reg", "bench") case "self": - env := []string{ - "cmd_env", "GOTMPDIR", path.Join(wd, m.Conf("compile", "tmp")), - "cmd_env", "GOCACHE", path.Join(wd, m.Conf("compile", "tmp")), - } - m.Confm("compile", "env", func(index int, key string) { - env = append(env, "cmd_env", key, kit.Select(os.Getenv(key), m.Option(key))) - }) - + // 编译版本 m.Cmd("cli.version", "create") - os.MkdirAll(m.Conf("compile", "tmp"), 0777) - p, q := path.Join(m.Conf("runtime", "boot.ctx_home"), m.Conf("compile", "bench")), path.Join(kit.Select(os.Getenv("GOBIN"), ""), "bench") - if m.Cmdy("cli.system", env, "go", "build", "-o", q, p); m.Result(0) == "" { - m.Cmdy("cli.quit", 1) - m.Append("time", m.Time()) - m.Append("cost", m.Format("cost")) - m.Append("hash", kit.Hashs(q)[:8]) - m.Append("bin", q) - m.Table() + // 编译项目 + if m.Cmdy("cli.compile", ""); m.Has("bin") { + target := path.Join(kit.Select(os.Getenv("GOBIN"), ""), m.Conf("compile", "name")) + os.Remove(target) + m.Append("bin", m.Cmdx("nfs.copy", target, m.Append("bin"))) + os.Chmod(target, 0777) + m.Cmd("cli.quit", 1) } case "restart": + // 重启项目 m.Cmdy("cli.quit", "1") case "plugin": - arg = arg[1:] - if len(arg) == 0 { + // 插件列表 + if arg = arg[1:]; len(arg) == 0 { m.Cmdy("nfs.dir", m.Conf("publish", "path"), "dir_deep", "dir_reg", ".*\\.so", "time", "size", "hashs", "path") break } fallthrough default: + // 编译插件 p, q, o := path.Join(m.Conf("project", "plugin.path"), arg[0], "index.go"), "", []string{} if _, e := os.Stat(p); e == nil { q = path.Join(m.Conf("publish", "path"), arg[0], "index.so") - o = []string{"-buildmode=plugin"} + o = append(o, "-buildmode=plugin") arg = arg[1:] } + // 目标系统 goos := kit.Select(m.Conf("runtime", "host.GOOS"), arg, 0) arch := kit.Select(m.Conf("runtime", "host.GOARCH"), arg, 1) + // 编译环境 + tmp := path.Join(kit.Pwd(), m.Conf("compile", "tmp")) os.MkdirAll(m.Conf("compile", "tmp"), 0777) - env := []string{"cmd_env", "GOOS", goos, "cmd_env", "GOARCH", arch, - "cmd_env", "GOTMPDIR", path.Join(wd, m.Conf("compile", "tmp")), - "cmd_env", "GOCACHE", path.Join(wd, m.Conf("compile", "tmp")), + env := []string{ + "cmd_env", "GOOS", goos, "cmd_env", "GOARCH", arch, + "cmd_env", "GOTMPDIR", tmp, "cmd_env", "GOCACHE", tmp, + "cmd_env", "GOPATH", m.Conf("runtime", "boot.ctx_home")+":"+os.Getenv("GOPATH"), + "cmd_env", "PATH", os.Getenv("PATH"), } - m.Confm("compile", "env", func(index int, key string) { - env = append(env, "cmd_env", key, kit.Select(os.Getenv(key), m.Option(key))) - }) + // 编译目标 if q == "" { - q = path.Join(m.Conf("publish", "path"), strings.Join([]string{"bench", goos, arch}, ".")) + q = path.Join(m.Conf("publish", "path"), strings.Join([]string{m.Conf("compile", "name"), goos, arch}, ".")) p = m.Cmdx("nfs.path", m.Conf("compile", "bench")) } + // 编译项目 if m.Cmdy("cli.system", env, "go", "build", o, "-o", q, p); m.Result(0) == "" { m.Append("time", m.Time()) m.Append("cost", m.Format("cost")) @@ -887,17 +890,16 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", } return }}, - "publish": &ctx.Command{Name: "publish [item...]", Help: "版本发布", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { - // 发布系统 + "publish": &ctx.Command{Name: "publish [args...]", Help: "项目发布", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { if len(arg) == 0 { m.Confm("publish", "list", func(key string, value string) { arg = append(arg, strings.Replace(key, "_", ".", -1)) }) } + + // 发布插件 p := path.Join(m.Conf("project", "plugin.path"), arg[0]) q := path.Join(m.Conf("publish", "path"), arg[0]) - - // 发布模块 if _, e := os.Stat(p); e == nil && m.Assert(os.MkdirAll(q, 0777)) { m.Confm("project", "plugin.list", func(index int, value map[string]interface{}) { m.Cmd("nfs.copy", path.Join(q, kit.Format(value["name"])), path.Join(p, kit.Format(value["name"]))) @@ -929,35 +931,41 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", m.Table() return }}, - "upgrade": &ctx.Command{Name: "upgrade project|bench|system|portal|plugin|script", Help: "服务升级", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { + "upgrade": &ctx.Command{Name: "upgrade project|bench|system|portal|plugin|restart|script", Help: "服务升级", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { if len(arg) == 0 { m.Cmdy("ctx.config", "upgrade") return } - switch arg[0] { - case "restart": - m.Cmd("cli.quit", "1") + switch arg[0] { case "project": m.Cmd("cli.project", "init") m.Cmd("cli.compile", "all") m.Cmd("cli.publish") case "script": + // 脚本列表 if len(arg) == 1 { m.Cmdy("nfs.dir", m.Conf("project", "script.path"), "time", "line", "hashs", "path") break } + + // 局部脚本 miss := "" if len(arg) > 2 { miss, arg = arg[1], arg[1:] } + // 下载脚本 for _, v := range arg[1:] { - m.Cmdy("web.get", "dev", fmt.Sprintf("publish/%s", v), - "upgrade", "script", "missyou", miss, "save", path.Join("usr/script", v)) + m.Cmdy("web.get", "dev", fmt.Sprintf("publish/%s", v), "upgrade", "script", + "missyou", miss, "save", path.Join(m.Conf("project", "script.path"), v)) } + case "restart": + m.Cmdy("cli.quit", "1") + case "plugin": + // 模块列表 if arg = arg[1:]; len(arg) == 0 { m.Cmdy("cli.context") break @@ -1009,11 +1017,13 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", for _, link := range kit.View([]string{arg[0]}, m.Confm("upgrade")) { file := kit.Select(link, m.Conf("upgrade", []string{"list", strings.Replace(link, ".", "_", -1)})) + // 下载文件 m.Cmd("web.get", "dev", fmt.Sprintf("publish/%s", link), "GOARCH", m.Conf("runtime", "host.GOARCH"), "GOOS", m.Conf("runtime", "host.GOOS"), "upgrade", arg[0], "save", file) + // 执行文件 if strings.HasPrefix(file, "bin/") { if m.Cmd("cli.system", "chmod", "a+x", file); link == "bench" { m.Cmd("cli.system", "mv", "bin/bench", fmt.Sprintf("bin/bench_%s", m.Time("20060102_150405"))) @@ -1023,49 +1033,51 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", restart = true } + // 输出信息 m.Push("time", m.Time()) m.Push("cost", m.Format("cost")) m.Push("hash", kit.Hashs(file)[:8]) m.Push("file", file) + // 压缩文件 if strings.HasSuffix(link, ".tar.gz") { m.Cmd("cli.system", "tar", "-xvf", file, "-C", path.Dir(file)) + os.Remove(file) } } + // 重启服务 if m.Table(); restart { m.Cmd("cli.quit", 1) } } - return }}, - "missyou": &ctx.Command{Name: "missyou [name [stop]]", Help: "任务管理", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { + "missyou": &ctx.Command{Name: "missyou [topic] [name [action]]", Help: "任务管理", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { + // 任务主题 topic := "hello" if len(arg) > 0 && (arg[0] == "" || m.Cmds("nfs.path", path.Join(m.Conf("cli.project", "plugin.path"), arg[0]))) { topic, arg = arg[0], arg[1:] } + // 任务列表 if len(arg) == 0 { - m.Option("dir_root", "") m.Cmd("nfs.dir", m.Conf("missyou", "path"), "time", "name").Table(func(value map[string]string) { name := strings.TrimSuffix(value["name"], "/") - m.Add("append", "create_time", value["time"]) - m.Add("append", "you", name) - if m.Confs("nfs.node", name) { - m.Add("append", "status", "start") - } else { - m.Add("append", "status", "stop") - } + m.Push("create_time", value["time"]) + m.Push("you", name) + m.Push("status", kit.Select("stop", "start", m.Confs("nfs.node", name))) }) m.Sort("you", "str_r").Sort("status").Table() return } + // 任务命名 if !strings.Contains(arg[0], "-") { arg[0] = m.Time("20060102-") + arg[0] } + // 任务管理 if m.Confs("ssh.node", arg[0]) { switch kit.Select("", arg, 1) { case "stop": @@ -1076,27 +1088,24 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心", return } + // 启动目录 p := path.Join(m.Conf("missyou", "path"), arg[0]) - if _, e := os.Stat(p); e != nil { - m.Confm("missyou", "local", func(index string, local string) { - m.Cmd("nfs.git", "clone", local, path.Join(p, m.Conf("missyou", "local"), index)) - }) - } + m.Assert(os.MkdirAll(p, 0777)) + // 启动参数 args := []string{ - "daemon", "cmd_dir", p, + "daemon", + "cmd_dir", p, + "cmd_daemon", "true", "cmd_env", "PATH", os.Getenv("PATH"), "cmd_env", "ctx_type", kit.Select(topic, arg, 1), "cmd_env", "ctx_home", m.Conf("runtime", "boot.ctx_home"), "cmd_env", "ctx_ups", fmt.Sprintf("127.0.0.1%s", m.Conf("runtime", "boot.ssh_port")), "cmd_env", "ctx_box", fmt.Sprintf("http://127.0.0.1%s", m.Conf("runtime", "boot.web_port")), - "cmd_daemon", "true", - } - if m.Assert(os.MkdirAll(p, 0777)); m.Conf("runtime", "host.GOOS") == "windows" { - m.Cmdy("cli.system", path.Join(m.Conf("runtime", "boot.ctx_home"), "bin/node.sh"), "start", args) - } else { - m.Cmdy("cli.system", m.Conf("runtime", "boot.ctx_bin"), args) } + + // 启动服务 + m.Cmdy("cli.system", path.Join(m.Conf("runtime", "boot.ctx_home"), "bin/node.sh"), "start", args) return }}, "version": &ctx.Command{Name: "version", Help: "", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { diff --git a/src/contexts/cli/version.go b/src/contexts/cli/version.go index 8111cea8..4bdb6b27 100644 --- a/src/contexts/cli/version.go +++ b/src/contexts/cli/version.go @@ -4,5 +4,5 @@ var version = struct { host string self int }{ - "2019-08-27 21:20:24", "centos", 428, + "2019-08-30 20:40:26", "centos", 480, } diff --git a/src/contexts/ctx/core.go b/src/contexts/ctx/core.go index 6593f3ec..09e48ade 100644 --- a/src/contexts/ctx/core.go +++ b/src/contexts/ctx/core.go @@ -1,6 +1,7 @@ package ctx import ( + "runtime" "errors" "fmt" "io" @@ -33,6 +34,8 @@ func (c *Context) Register(s *Context, x Server, args ...interface{}) *Context { return s } func (c *Context) Plugin(s *Context, args []string) string { + runtime.GOMAXPROCS(8) + c.Register(s, nil) m := Pulse.Spawn(s) // m := &Message{code: 0, time: time.Now(), source: s, target: s, Meta: map[string][]string{}} diff --git a/src/contexts/ctx/ctx.go b/src/contexts/ctx/ctx.go index 90a468ae..d04b5f30 100644 --- a/src/contexts/ctx/ctx.go +++ b/src/contexts/ctx/ctx.go @@ -1,6 +1,7 @@ package ctx import ( + "runtime" "toolkit" "encoding/json" @@ -1346,6 +1347,8 @@ var Index = &Context{Name: "ctx", Help: "模块中心", Server: &CTX{}, } func Start(args ...string) bool { + runtime.GOMAXPROCS(1) + if len(args) == 0 { args = append(args, os.Args[1:]...) } diff --git a/src/contexts/ctx/type.go b/src/contexts/ctx/type.go index d9c4f442..ffb404a4 100644 --- a/src/contexts/ctx/type.go +++ b/src/contexts/ctx/type.go @@ -453,7 +453,7 @@ func (m *Message) Echo(str string, arg ...interface{}) *Message { func (m *Message) Cmdp(t time.Duration, head []string, prefix []string, suffix [][]string) *Message { if head != nil && len(head) > 0 { - m.Show(strings.Join(head, " "), "...\n") + m.Show(fmt.Sprintf("[%s]...\n", strings.Join(head, " "))) } for i, v := range suffix { diff --git a/src/contexts/nfs/nfs.go b/src/contexts/nfs/nfs.go index 1c08138d..2deb2726 100644 --- a/src/contexts/nfs/nfs.go +++ b/src/contexts/nfs/nfs.go @@ -535,7 +535,7 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心", "list": []interface{}{}, }, Help: "文件搜索"}, "git": &ctx.Config{Name: "git", Value: map[string]interface{}{ - "args": []interface{}{"-C", "@git_dir"}, + "args": []interface{}{}, "info": map[string]interface{}{"cmds": []interface{}{"log", "status", "branch"}}, "update": map[string]interface{}{"cmds": []interface{}{"stash", "pull", "pop"}}, "pop": map[string]interface{}{"args": []interface{}{"stash", "pop"}}, @@ -627,7 +627,6 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心", skip, find := false, false m.Confm("pwd", func(index int, value string) bool { - // p := path.Join(value, m.Option("dir_root"), arg[0]) p := path.Join(value, arg[0]) if s, e := os.Stat(p); e == nil { if s.IsDir() { @@ -702,15 +701,14 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心", if p := m.Cmdx("nfs.path", arg[0]); p != "" && !m.Confs("git", arg[0]) { m.Option("git_dir", p) arg = arg[1:] - } else { - wd, e := os.Getwd() - m.Assert(e) - m.Option("git_dir", wd) } if len(arg) > 0 && arg[0] == "sum" { - args := []string{"-C", m.Option("git_dir"), "log", "--shortstat", "--pretty=commit: %ad", "--date=format:%Y-%m-%d %H:%M"} - if len(arg) > 1 { + args := []string{} + if m.Options("git_dir") { + args = append(args, "-C", m.Option("git_dir")) + } + if args = append(args, "log", "--shortstat", "--pretty=commit: %ad", "--date=iso"); len(arg) > 1 { args = append(args, arg[1:]...) } else { args = append(args, "--reverse") @@ -734,12 +732,14 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心", m.Add("append", "adds", "0") m.Add("append", "dels", adds[0]) } + m.Add("append", "hour", strings.Split(hs[1], ":")[0]) m.Add("append", "time", hs[1]) } else if len(l[0]) > 0 { hs := strings.Split(l[0], " ") m.Add("append", "date", hs[0]) m.Add("append", "adds", 0) m.Add("append", "dels", 0) + m.Add("append", "hour", strings.Split(hs[1], ":")[0]) m.Add("append", "time", hs[1]) } } @@ -759,6 +759,9 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心", for _, cmd := range cmds { args := append([]string{}, kit.Trans(m.Confv("git", "args"))...) + if m.Options("git_dir") { + args = append(args, "-C", m.Option("git_dir")) + } if v := m.Confv("git", []string{cmd, "args"}); v != nil { args = append(args, kit.Trans(v)...) } else { diff --git a/src/contexts/ssh/ssh.go b/src/contexts/ssh/ssh.go index f109b045..e8e8fee6 100644 --- a/src/contexts/ssh/ssh.go +++ b/src/contexts/ssh/ssh.go @@ -380,8 +380,6 @@ var Index = &ctx.Context{Name: "ssh", Help: "集群中心", if strings.HasPrefix(v, "__") { if len(arg) > 0 { args, arg = append(args, arg...), nil - } else { - args = append(args, "") } } else if strings.HasPrefix(v, "_") { if len(arg) > 0 { diff --git a/src/contexts/web/web.go b/src/contexts/web/web.go index e8b3ab46..4a143e65 100644 --- a/src/contexts/web/web.go +++ b/src/contexts/web/web.go @@ -1,7 +1,6 @@ package web import ( - "github.com/go-cas/cas" "github.com/skip2/go-qrcode" "contexts/ctx" @@ -100,29 +99,7 @@ func (web *WEB) Login(msg *ctx.Message, w http.ResponseWriter, r *http.Request) // defer func() { // msg.Log("info", "access: %s", msg.Option("access", msg.Cmdx("aaa.sess", "access"))) // }() - if msg.Confs("login", "cas") { - if !cas.IsAuthenticated(r) { - r.URL, _ = r.URL.Parse(r.Header.Get("index_url")) - msg.Log("info", "cas_login %v %v", r.URL, msg.Conf("spide", "cas.client.url")) - cas.RedirectToLogin(w, r) - return false - } - - for k, v := range cas.Attributes(r) { - for _, val := range v { - msg.Add("option", k, val) - } - } - - msg.Log("info", "cas_login %v", msg.Option("ticket")) - if msg.Options("ticket") { - msg.Option("username", cas.Username(r)) - msg.Log("info", "login: %s", msg.Option("username")) - http.SetCookie(w, &http.Cookie{Name: "sessid", Value: msg.Option("sessid", msg.Cmdx("aaa.user", "session", "select")), Path: "/"}) - http.Redirect(w, r, merge(msg, r.Header.Get("index_url"), "ticket", ""), http.StatusTemporaryRedirect) - return false - } - } else if msg.Options("username") && msg.Options("password") { +if msg.Options("username") && msg.Options("password") { if msg.Cmds("aaa.auth", "username", msg.Option("username"), "password", msg.Option("password")) { msg.Log("info", "login: %s", msg.Option("username")) http.SetCookie(w, &http.Cookie{Name: "sessid", Value: msg.Cmdx("aaa.user", "session", "select"), Path: "/"}) @@ -360,20 +337,9 @@ func (web *WEB) Start(m *ctx.Message, arg ...string) bool { return false }) - // SSO认证 - var handler http.Handler - if cas_url, e := url.Parse(m.Cmdx("web.spide", "cas", "client", "url")); e == nil && cas_url.Host != "" { - m.Log("info", "cas url: %s", cas_url) - m.Conf("login", "cas", "true") - client := cas.NewClient(&cas.Options{URL: cas_url}) - handler = client.Handle(web) - } else { - handler = web - } - // 启动服务 m.Log("info", "web: %s", m.Cap("address")) - web.Server = &http.Server{Addr: m.Cap("address"), Handler: handler} + web.Server = &http.Server{Addr: m.Cap("address"), Handler: web} if m.Caps("master", true); m.Cap("protocol") == "https" { web.Server.ListenAndServeTLS(m.Conf("runtime", "node.cert"), m.Conf("runtime", "node.key")) } else { diff --git a/src/contexts/yac/yac.go b/src/contexts/yac/yac.go index f02f581d..69ab5945 100644 --- a/src/contexts/yac/yac.go +++ b/src/contexts/yac/yac.go @@ -314,7 +314,6 @@ var Index = &ctx.Context{Name: "yac", Help: "语法中心", map[string]interface{}{"page": "key", "hash": "key", "word": []interface{}{"[A-Za-z_][A-Za-z_0-9]*"}}, map[string]interface{}{"page": "str", "hash": "str", "word": []interface{}{"mul{", "\"[^\"]*\"", "'[^']*'", "}"}}, map[string]interface{}{"page": "exe", "hash": "exe", "word": []interface{}{"mul{", "$", "@", "}", "opt{", "key", "}"}}, - map[string]interface{}{"page": "exe", "hash": "exe", "word": []interface{}{"mul{", "$", "@", "}", "opt{", "num", "}"}}, // 表达式语句 map[string]interface{}{"page": "op1", "hash": "op1", "word": []interface{}{"mul{", "-", "+", "}"}}, @@ -371,11 +370,11 @@ var Index = &ctx.Context{Name: "yac", Help: "语法中心", }, Help: "语法集合的最大数量"}, "input": &ctx.Config{Name: "input", Value: map[string]interface{}{ "text": true, - "button": true, "select": true, + "button": true, "textarea": true, - "feature": true, "exports": true, + "feature": true, }, Help: "控件类型"}, "exec": &ctx.Config{Name: "info", Value: map[string]interface{}{ "disable": map[string]interface{}{ @@ -1093,18 +1092,38 @@ var Index = &ctx.Context{Name: "yac", Help: "语法中心", p.Data = self return }}, - "kit": &ctx.Command{Name: "kit type name help view init cmd arg... [input type name value [key val]...]...", Help: "kit", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { + "kit": &ctx.Command{Name: "kit name help [view [init]] [public|protected|private] cmd arg... [input value [key val]...]...", Help: "小功能", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { m.Log("info", "_index: %v", arg) + args := []interface{}{} inputs := []interface{}{} - feature := map[string]interface{}{} exports := []interface{}{} - for i := 7; i < len(arg); i++ { + feature := map[string]interface{}{} + + view, init, show, cmd := "", "", "", "" + begin := 3 + + switch arg[3] { + case "private", "protected", "public": + begin, show, cmd = 5, arg[3], arg[4] + default: + switch arg[4] { + case "private", "protected", "public": + begin, view, show, cmd = 6, arg[3], arg[4], arg[5] + default: + begin, view, init, show, cmd = 7, arg[3], arg[4], arg[5], arg[6] + } + } + + if m.Confs("input", cmd) { + cmd, begin = arg[1], begin - 1 + } + + for i := begin; i < len(arg); i++ { if !m.Confs("input", arg[i]) { args = append(args, arg[i]) continue } - for j := i; j < len(arg); j++ { if j < len(arg)-1 && !m.Confs("input", arg[j+1]) { continue @@ -1147,18 +1166,18 @@ var Index = &ctx.Context{Name: "yac", Help: "语法中心", } m.Confv("_index", []interface{}{-2}, map[string]interface{}{ - "componet_type": kit.Select("public", arg, 5), "componet_name": kit.Select("", arg, 1), "componet_help": kit.Select("", arg, 2), - "componet_view": kit.Select("componet", arg, 3), - "componet_init": kit.Select("", arg, 4), + "componet_view": view, + "componet_init": init, + "componet_type": show, "componet_ctx": m.Cap("module"), - "componet_cmd": kit.Select("", arg, 6), + "componet_cmd": cmd, "componet_args": args, "inputs": inputs, - "feature": feature, "exports": exports, + "feature": feature, }) return }}, diff --git a/src/examples/code/code.go b/src/examples/code/code.go index 86496d94..2933657f 100644 --- a/src/examples/code/code.go +++ b/src/examples/code/code.go @@ -376,7 +376,8 @@ var Index = &ctx.Context{Name: "code", Help: "代码中心", return }}, "mux": &ctx.Command{Name: "mux [session [window [pane]]] args...", Help: "终端管理", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) (e error) { - if len(arg) == 0 { // 会话列表 + // 会话列表 + if len(arg) == 0 { view := kit.View([]string{"session"}, m.Confm("mux", "view")) for _, row := range strings.Split(strings.TrimSpace(m.Cmdx("cli.system", "tmux", "list-sessions", "-F", fmt.Sprintf("#{%s}", strings.Join(view, "},#{")))), "\n") { for j, col := range strings.Split(row, ",") { @@ -391,7 +392,8 @@ var Index = &ctx.Context{Name: "code", Help: "代码中心", return } - if len(arg) == 1 { //窗口列表 + //窗口列表 + if len(arg) == 1 { view := kit.View([]string{"window"}, m.Confm("mux", "view")) for _, row := range strings.Split(strings.TrimSpace(m.Cmdx("cli.system", "tmux", "list-windows", "-t", arg[0], "-F", fmt.Sprintf("#{%s}", strings.Join(view, "},#{")))), "\n") { for j, col := range strings.Split(row, ",") { @@ -403,13 +405,16 @@ var Index = &ctx.Context{Name: "code", Help: "代码中心", } switch arg[1] { - case "create": // 创建会话 + // 创建会话 + case "create": m.Cmdy("cli.system", "tmux", "new-session", "-s", arg[0], arg[2:], "-d", "cmd_env", "TMUX", "") return - case "exist": // 创建会话 + // 检查会话 + case "exist": m.Cmdy("cli.system", "tmux", "has-session", "-t", arg[0]) return - default: // 会话操作 + // 会话操作 + default: if v := m.Confv("mux", []string{"bind", "1", arg[1]}); v != nil { m.Cmdy("cli.system", "tmux", v, "-t", arg[0], arg[2:]) return @@ -417,7 +422,8 @@ var Index = &ctx.Context{Name: "code", Help: "代码中心", } target := fmt.Sprintf("%s:%s", arg[0], arg[1]) - if len(arg) == 2 { // 面板列表 + // 面板列表 + if len(arg) == 2 { view := kit.View([]string{"pane"}, m.Confm("mux", "view")) for _, row := range strings.Split(strings.TrimSpace(m.Cmdx("cli.system", "tmux", "list-panes", "-t", target, "-F", fmt.Sprintf("#{%s}", strings.Join(view, "},#{")))), "\n") { for j, col := range strings.Split(row, ",") { @@ -429,22 +435,48 @@ var Index = &ctx.Context{Name: "code", Help: "代码中心", } switch arg[2] { - case "create": // 创建窗口 + // 创建窗口 + case "create": m.Cmdy("cli.system", "tmux", "new-window", "-t", arg[0], "-n", arg[1], arg[3:]) return - default: // 窗口操作 + // 窗口操作 + default: if v := m.Confv("mux", []string{"bind", "2", arg[2]}); v != nil { m.Cmdy("cli.system", "tmux", v, arg[3:], "-t", target) return } } - target = fmt.Sprintf("%s:%s.%s", arg[0], arg[1], arg[2]) - if len(arg) == 3 { + // 面板内容 + if target = fmt.Sprintf("%s:%s.%s", arg[0], arg[1], arg[2]); len(arg) == 3 { m.Cmdy("cli.system", "tmux", "capture-pane", "-t", target, "-p") return } + switch arg[3] { + case "run": + m.Cmd("cli.system", "tmux", "send-keys", "-t", target, "clear", "Enter") + time.Sleep(kit.Duration(m.Conf("mux", "cmd_timeout"))) + prompt := strings.TrimSpace(m.Cmdx("cli.system", "tmux", "capture-pane", "-t", target, "-p")) + m.Log("info", "wait for prompt %v", prompt) + + m.Cmd("cli.system", "tmux", "send-keys", "-t", target, strings.Join(arg[4:], " "), "Enter") + for i := 0; i < 1000; i++ { + time.Sleep(kit.Duration(m.Conf("mux", "cmd_timeout"))) + list := strings.Split(m.Cmdx("cli.system", "tmux", "capture-pane", "-t", target, "-p"), "\n") + m.Log("info", "current %v", list) + for j := len(list)-1; j >= 0; j-- { + if list[j] != "" { + if list[j] == prompt { + i = 1000 + } + break + } + } + } + return + } + if v := m.Confv("mux", []string{"bind", "3", arg[3]}); v != nil { switch arg[3] { case "r": diff --git a/src/plugin/context/index.shy b/src/plugin/context/index.shy index fda576b6..5336981e 100644 --- a/src/plugin/context/index.shy +++ b/src/plugin/context/index.shy @@ -1,98 +1,58 @@ -fun project "项目" "" "" \ - private \ - select "" values plugin values submit values review values trend values stat values init action auto \ +kit project "项目" private \ + select "" values plugin values review values submit values trend values stat values init action auto \ text "" name see imports plugin_see action auto \ button "执行" \ exports see name see - copy cli.project __ -end - -fun compile "编译" "" "" \ - private \ +kit compile "编译" private \ select "" values plugin values restart values windows values darwin values linux values self values all action auto \ text "" name see imports plugin_see \ button "编译" - copy cli.compile __ -end - -fun publish "发布" "" "" \ - private \ +kit publish "发布" private \ text "" name see imports plugin_see \ button "发布" - copy cli.publish __ -end - -fun upgrade "升级" "" "" \ - private \ +kit upgrade "升级" private "ssh._route" _ "cli.upgrade" \ text "" name pod imports plugin_pod \ select "" values script values restart values plugin values bench values portal values system action auto \ text "" name see imports plugin_see \ button "升级" - copy ssh._route _ cli.upgrade __ -end - -fun missyou "任务" "" "" \ - private \ +kit missyou "任务" private \ text "" name see imports plugin_see \ text "" name you view long \ button "行动" action auto \ exports you "" you - copy cli.missyou __ -end - -fun pod "设备" "" "" \ - private \ +kit pod "设备" private "ssh._route" _ "ssh.remote" __ \ text "" name pod view long \ button "行动" action auto \ exports pod pod - copy ssh._route _ ssh.remote __ -end - -fun ctx "模块" "" "" \ - private \ +kit ctx "模块" private "ssh._route" _ context _ list __ \ text "" name pod imports plugin_pod action auto view long \ text "nfs" name ctx imports plugin_ctx action auto \ button "行动" \ exports ctx names - copy ssh._route _ context _ list __ -end - -fun cmd "命令" "" "" \ - private \ +kit cmd "命令" private "ssh._route" _ context _ command __ \ text "" name pod imports plugin_pod \ text "nfs" name ctx imports plugin_ctx \ text "pwd" name cmd \ button "执行" - copy ssh._route _ context _ command __ -end - -fun dir "目录" "" "" \ - private \ +kit dir "目录" private "ssh._route" _ "nfs.dir" _ time size line path \ text "" name pod imports plugin_pod action auto \ text "usr/script" name dir imports plugin_dir action auto view long \ button "浏览" action auto \ feature display "editor" \ exports dir "" dir - copy ssh._route _ nfs.dir _ time size line path -end - -fun git "版本" "" "" \ - private \ +kit git "版本" private "ssh._route" _ "nfs.git" __ \ text "" name pod imports plugin_pod action auto \ select "" values status values diff commit values values log values init action auto \ text "" name txt action auto \ button "查看" action auto - copy ssh._route _ nfs.git __ -end - diff --git a/usr/README.md b/usr/README.md deleted file mode 100644 index b4a1f990..00000000 --- a/usr/README.md +++ /dev/null @@ -1,901 +0,0 @@ -## 0 context简介 -context: 为代码提供自由的运行环境，干掉各种库依赖、包依赖、接口依赖、服务依赖、配置依赖、逻辑依赖。 - -// TODO: 代码已重构多次，文档比较落后，近期会整理文档。 - -终端工具链，各种实用的功能模块，通过简洁的接口，自由的组合在一起。 - -作为一个工具箱，内置各种实用工具，通过灵活的配置，打造个性化的工具链。 - -作为一个框架，通过模块式开发，可以快速开发各种应用软件。 - -* 1 context安装 -* 1.0 context程序下载 -* 1.1 context源码安装 -* 2 context使用 -* 2.0 应用示例--启动WEB服务器 -* 2.1 常用命令 -* 2.2 web模块的命令 -* 2.3 nfs模块的命令 -* 3 context开发 -* 3.0 context模块开发入门 -* 3.1 context模块的生命周期与继承多态 -* 3.2 message消息驱动的开发模型 -* 3.3 message消息驱动的事件回调 -* 4 context核心模块详解 - -## 1 context安装 -### 1.0 context程序下载 - -下载并解压: https://github.com/shylinux/context-tar/raw/master/tar.tgz - -#### 1.0.1 Linux - -./bootstrap.sh - -#### 1.0.2 MacOSX - -./bootstrap.sh - -#### 1.0.3 Windows - -cp bin/bench.win64.exe . -双击运行 - -### 1.1 context源码安装 -#### 1.1.0 golang安装 -* mac安装 https://github.com/shylinux/context-bin/raw/master/go1.6.2.darwin-amd64.pkg -* windows安装(推荐使用git的shell) https://github.com/shylinux/context-bin/raw/master/Git-2.12.2-32-bit.exe -* windows安装 https://github.com/shylinux/context-bin/raw/master/go1.6.2.windows-386.msi -* Linux安装 集成在了开发环境的安装包中，先安装好git即可 - -#### 1.1.1 golang开发环境安装 - -#### 1.1.2 context源码安装 -* 下载：git clone https://github.com/shylinux/context -* 编译：cd context && make && make run - -## 2 context使用 -```sh -$ ./bootstrap.sh -0[00:13:47]ctx.cli.shy> -``` -context启动后就像其它shell一样，解析并执行各种命令行。 - -context默认的启动脚本中，会开启WEB服务，可以用浏览器操作http://localhost:9094/code/。用户名root，密码root。 - -#### 2.0.1 添加脚本 -bench支持脚本解析，可以添加启动脚本，这样就可以在启动的时候就运行一些命令，启动一些功能。 -在bench运行的当前目录创建一个目录etc，并添加了个启动脚本文件etc/init.sh，向脚本中添加如下命令。 -```sh -~web serve ./ ':9090' -``` -重新启动bench， 打开浏览器输入"http://localhost:9090" ，即可看一个静态WEB服务器已经启动。 - -#### 2.0.2 查看日志 -bench支持日志输出，可以通过日志查看历史记录和运行状态。 -在bench运行的当前目录创建一个目录var, 重新启动bench。 -再打开一个终端，进行bench的运行目录，并查看日志文件。 -```sh -$ tail -f var/bench.log -... -2018/03/24 16:33:38 22 start(ctx->cli) 2 server [etc/init.shy] [stdio] -2018/03/24 16:33:38 22 find(ctx->cli) find yac -2018/03/24 16:33:38 27 start(cli->yac) 3 server [] [] -2018/03/24 16:33:38 30 find(cli->yac) find lex -2018/03/24 16:33:38 34 start(yac->lex) 4 server [] [] -2018/03/24 16:33:38 22 find(ctx->cli) find nfs -2018/03/24 16:33:38 3932 cmd(ctx->cli) 1 source [etc/init.shy] [] -... -``` -日志的格式中有日期与时间，随后是消息编号，与日志类型，消息的发起模块与接收模块，之后就是消息的请求行与请求头参数。 -如第一行日志，消息编号为22，消息类型是start启动模块，是ctx发送给cli模块的消息。 -从日志中可以看出bench在启动时，启动了词法解析模块lex与语法解析模块yac，并加载了启动脚本etc/init.shy。 - -#### 2.0.3 运行本机命令 -当输入的命令在bench中没有实现时，bench会调用本地shell对命令进行解释执行。 -```sh -$ bench -> pwd -/Users/shaoying/context -> ls -etc -var -LICNESE -README.md -... -``` - -### 2.1 常用命令 -#### 2.1.1 缓存管理cache -```sh -web> cache -address(:9090): 服务地址 -directory(./): 服务目录 -protocol(http): 服务协议 -``` -输入"cache"命令，即可查看当前模块的缓存数据，通过这些缓存数据，就可以了解模块的当前各种运行状态。 -如"address"，代表web模块监听的网络地址为"0.0.0.0:9090"。 - -#### 2.1.2 配置管理config -```sh -web> config -logheaders(yes): 日志输出报文头(yes/no) -``` -输入"config"命令，即可查看当前模块的配置信息。通过修改这些配置信息，就可以控制模块的运行的环境，改变模块运行的状态。 -如"logheaders"，代表web模块处理网络请求时，是否在日志中输出报文头，此时值为yes即打印报文头。 -```sh -web> config logheaders no -web> config -logheaders(no): 日志输出报文头(yes/no) -``` -输入"config logheaders no"命令，修改logheaders的值为no，即不在日志中输出报文头。 - -#### 2.1.3 命令管理command -```sh -web> command -serve: serve [directory [address [protocol]]] -route: route directory|template|script route content -/demo: /demo -``` -输入"command"命令，即可查看当前模块的命令集合。通过调用这些命令使用模块提供的各种功能。 -如"serve"，启动一个web服务器，参数都是可选的。 -参数"directory"代表web服务器的响应路径，存放网页的各种文件。 -参数"address"，代表服务器监听的网络地址。 -参数"protocol"，代表服务器使用的网络协议。 - -#### 2.1.4 模块管理context -```sh -web> context -web(ctx:cli:aaa::): start(:9090) 应用中心 -``` -输入"context"命令，即可查看当前模块及子模块的基本信息。web模块没有子模块，所以这里只显示了web模块的基本信息。 -```sh -web> context ctx -ctx> context -ctx(:cli:aaa:root:root): begin() 模块中心 -lex(ctx::aaa:root:root): start(52,19,0) 词法中心 -yac(ctx::aaa:root:root): start(26,13,21) 语法中心 -cli(ctx:cli:aaa:root:root): start(stdio) 管理中心 -ssh(ctx:cli:aaa:root:root): begin() 集群中心 -mdb(ctx:cli:aaa:root:root): begin() 数据中心 -tcp(ctx::aaa:root:root): begin() 网络中心 -web(ctx:cli:aaa:root:root): begin() 应用中心 -aaa(ctx::aaa:root:root): start(root) 认证中心 -nfs(ctx::aaa:root:root): begin() 存储中心 -log(ctx::aaa:root:root): begin() 日志中心 -file1(nfs::aaa:root:root): start(var/bench.log) 打开文件 -stdio(nfs::aaa:root:root): start(stdio) 扫描文件 -file2(nfs::aaa:root:root): start(etc/init.shy) 扫描文件 -``` -输入"context ctx"命令，切换ctx模块为当前模块。输入"context"命令，即可查看当前模块及子模块的基本信息。 -ctx为根模块，所以可以查看到所有模块的基本信息。 - -#### 2.1.5 消息管理message -```sh -tcp> message -requests: -0 9(ctx->tcp): 23:30:19 [] -sessions: -historys: -0 9(ctx->tcp): 23:30:19 [] -1 4358(cli->tcp): 23:30:22 [context tcp] - 0 4359(cli->log): 23:30:22 [log cmd 2 context [tcp] []] - 1 4361(tcp->log): 23:30:22 [log search 1 match [tcp]] - 2 4363(cli->tcp): 23:30:22 [] -``` -输入"message"命令，查看当前模块收发的所有消息。 -其中"requests"是收到的长消息，如有一条ctx模块发送给tcp模块的编号为9消息。 -其中"sessions"，是发送出的长消息，这里为空，所以tcp模块没有发送长消息。 -其中"historys"是模块收到的所有消息，包括长消息和短消息。显示中除了显示当前消息，还会显示消息的子消息。如这里，编号为4358的消息就有三条子消息4359、4361、4363。 -```sh -tcp> message 9 -message: 0 -9(ctx->tcp): 23:36:48 [] -``` -输入"message 9"命令，查看编号为9的消息的具体信息。 - -### 2.2 web模块的命令 -web模块，提供web服务。目前有两条命令：主机管理serve，路由管理route。 -```sh -web> command -serve: serve [directory [address [protocol]]] -route: route directory|template|script route content -/demo: /demo -``` - -#### 2.2.1 主机管理serve -```sh -web> command serve -serve [directory [address [protocol]]] - 开启应用服务 -``` -serve命令会监听网络端口，并启动web服务器。 -* directory服务目录 -* address服务地址(ip:port) -* protocol服务协议(http/https) - -#### 2.2.2 路由管理route -```sh -web> command route -route directory|template|script route content - 添加应用内容 -``` -route命令会向指定的URI添加响应内容。响应内容可以是文件内容，可以是golang的模板，可以是脚本执行结果。 -参数route代表http请求的uri地址，参数content代表响应回复的内容，不同类型的服务有不同的意义。 - -* directory静态服务 -```sh -web> route directory /p pkg -``` -命令"route diretory /p pkg"，当web模块接收到请求uri为"/p/"时把目录"pkg"中的内容作为响应回复。 -content代表路径，即web服务请求此route路径时，回复的内容为content指定的目录或文件。 - -* template模板服务 -```sh -web> route template /t LICENSE -``` -命令"route template /t LICENSE"，当web模块接收到请求uri为"/t"时把文件"LICENSE"中的内容作为响应回复。 - -* script脚本服务 -```sh -web> route script /s echo.shy -``` -content代表脚本的文件名，即web服务请求此route路径时，回复的内容为content指定的脚本运行后输出的内容。 - -### 2.3 nfs模块的命令 -nfs模块，文件读写读写模块，可以读写本地文件或远程文件。 -```sh -$ bench -> ~nfs -> genqr qr.png hello -``` -启动bench，进入nfs模块，调用genqr生成二维码图片。 -可以看到在bench的当前运行目录生了一个png图片，可以用手机扫描一下，查看二维码内容。 - -nfs模块，还支持文件的远程传输。 -```sh -$ bench -> ~nfs -> listen ":9191" -``` -启动bench，进入nfs模块，调用listen开启一个文件服务器，监听的端口为"0.0.0.0:9191"。 - -在另外一个目录，一定注意是另外一个目录中。运行以下命令。 -```sh -$ bench -> ~nfs -> dial ":9191" -> context -nfs(ctx::aaa::): begin() 存储中心 -file2(nfs::aaa::): start(etc/init.shy) 扫描文件 -file3(nfs::aaa::): start(127.0.0.1:63458->127.0.0.1:9191) 打开文件 -file1(nfs::aaa::): start(var/bench.log) 打开文件 -stdio(nfs::aaa::): start(stdio) 扫描文件 -> send pwd -/Users/shaoying/context -> pwd -/Users/shaoying/context/tmp -> recv file qr.png -> ls -qr.png -``` -启动bench，进入nfs模块，调用dial连接文件服务器。 -输入context命令，可以查看所有子模块，这里可以看到多了一个file3的模块，从备注信息中可以看出，这是一个网络连接。 -输入send可以执行远程命令，如send pwd就可以查看远程bench运行的当前目录。 -输入pwd查看当前bench的运行目录。 -输入recv命令就可以把远程文件复制到本地。 - -## 3 context开发 -### 3.0 context模块开发入门 -在context目录下，创建目录src/example/demo，然后打开src/example/demo/demo.go文件，并输入以下代码。 -```go -package demo - -import ( - "context" -) - -var Index = &ctx.Context{Name: "demo", Help: "example demo", - Caches: map[string]*ctx.Cache{ - "format": &ctx.Cache{Name: "format", Value: "hello %s world", Help: "output string"}, - }, - Configs: map[string]*ctx.Config{ - "default": &ctx.Config{Name: "default", Value: "go", Help: "output string"}, - }, - Commands: map[string]*ctx.Command{ - "echo": &ctx.Command{ - Name: "echo word", - Help: "echo something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Echo(m.Cap("format"), m.Conf("default")) - }, - }, - }, -} - -func init() { - ctx.Index.Register(Index, nil) -} -``` - -在context目录下，打开src/example/bench.go文件，添加一行 _ "example/demo"，引入新添加的模块 。 -```go -package main - -import ( - "context" - _ "context/aaa" - _ "context/cli" - _ "context/ssh" - - _ "context/mdb" - _ "context/nfs" - _ "context/tcp" - _ "context/web" - - _ "context/lex" - _ "context/log" - _ "context/yac" - - _ "example/demo" - - "os" -) - -func main() { - ctx.Start(os.Args[1:]...) -} -``` - -在context目录下，编译安装bench.go，启动bench进入新模块，执行新添加的命令。 -```sh -$ go install src/example/bench.go -$ bench -> ~demo -> echo -hello go world -``` - -#### 3.0.0 代码解析 -```go -func init() { - ctx.Index.Register(Index, nil) -} -``` -在模块初始化时，向ctx模块注册当前模块，即当前模块为ctx的子模块。 - -```go -var Index = &ctx.Context{Name: "demo", Help :example demo", - Caches: map[string]*ctx.Cache{}, - Configs: map[string]*ctx.Config{}, - Commands: map[string]*ctx.Commands{}, -} -``` -Index即为模块的数据结构，Name为模块的名字，Help为模块的简介，Caches为模块的缓存项， -Configs为模块的配置项，Commands为命令项。 -每个模块都需要初始化这五个属性，通过这些属性向外提供标准接口。 - -```go -type Cache struct { - Name string - Value string - Help string - Hand func(m *Message, x *Cache, arg ...string) string -} - -type Config struct { - Name string - Value string - Help string - Hand func(m *Message, x *Config, arg ...string) string -} - -type Command struct { - Name string - Help string - - Formats map[string]int - Options map[string]string - Appends map[string]string - Hand func(m *Message, c *Context, key string, arg ...string) -} -``` -三种标准接口的定义如上，Cache为缓存项，模块的内部数据可以定义成Cache，外部通过查看这些Cache就可以了解模块当前运行的各种状态。 -Config为配置项，模块内的一些常量或是可配置的数据，就可以定义成Config，外部通过对这些配置的设置，就可以改变模块的运行环境，控制模块的功能。 -Command的命令项，模块向外提供的各种API接口或是CLI接口都统一定义为command，即可以被其它模块在代码中直接调用，也可以在命令行实时调用。 -通过这种方式直接解除了模块的依赖关系，每个模块都可以独立编译，独立运行。 -通过脚本或是配置把各种模块组合在一起，完成复杂的功能。这样大大降低了代码的重复性，提高了代码的通用性。 - -Cache为缓存项的定义，Name为缓存项的名字，Value为缓存项的值，Help为缓存项的帮助信息，Hand为缓存项读写函数，可选。 - -Config为配置项的定义，Name为配置项的名字，Value为配置项的值，Help为配置项的帮助信息，Hand为配置项读写函数，可选。 - -Command为命令项的定义，Name为命令项的名字，Help为命令项的帮助信息，Hand为命令项执行函数。 - -```go -Commands: map[string]*ctx.Command{ - "echo": &ctx.Command{Name: "echo word", Help: "echo something", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Echo(m.Cap("format"), m.Conf("default")) - }}, -}, -``` -echo命令，按照缓存项format的格式输出配置项default的内容。 -这样可以从命令行查看缓存项format的值，就可以知道echo命令输出的格式。 -这样可以从命令行设置配置项default的值，就可以改变echo命令输出的内容。 -命令Hand函数，是消息驱动的。所以各种通过消息m就可以调用到各种函数。 - -m.Cap()读写当前模块的某个缓存项。 -m.Conf()读写当前模块的某个配置项。 -m.Echo()输出命令执行结果。 - -#### 3.0.1 缓存接口 -```go -func (m *Message) Caps(key string, arg ...bool) bool -func (m *Message) Capi(key string, arg ...int) int -func (m *Message) Cap(key string, arg ...string) string -``` -只有一个参数时，代表读取缓存项的值。有两个参数是会向缓存项中写入新值。 - -Cap()把缓存项，当成字符串来进行直接读写。 -Capi()只有一个参数时，读取缓存项并转换成整型数值返回。有两个参数时，会把第二个整型参数转换成字符串写缓存项中。 -Caps()只有一个参数时，读取缓存项并转换成布尔值返回。有两个参数时，会把第二个布尔参数转换成字符串写缓存项中。 - -#### 3.0.2 配置接口 -```go -func (m *Message) Confs(key string, arg ...bool) bool -func (m *Message) Confi(key string, arg ...int) int -func (m *Message) Conf(key string, arg ...string) string -``` -只有一个参数时，代表读取配置项的值。有两个参数是会向配置项中写入新值。 - -Cap()把缓存项，当成字符串来进行直接读写。 -Capi()只有一个参数时，读取配置项并转换成整型数值返回。有两个参数时，会把第二个整型参数转换成字符串写配置项中。 -Caps()只有一个参数时，读取配置项并转换成布尔值返回。有两个参数时，会把第二个布尔参数转换成字符串写配置项中。 - -#### 3.0.3 日志接口 -```go -func (m *Message) Log(action string, ctx *Context, str string, arg ...interface{}) -``` -参数action为日志类型，可取error, info, debug...类型及相关处理由log模块自定义。 -参数ctx指定模块, 可取nil。 -参数str与arg与Printf参数相同。 - -### 3.1 context模块的生命周期与继承多态 -context结构体封封装了三种标准接口，cache、config、command。 -但这些接口只能保存与处理简单的数据。如果需要处理复杂的数据，可以自己定义类型。 -自定义的类型必须实现Server接口。 -```go -type Server interface { - Spawn(m *Message, c *Context, arg ...string) Server - Begin(m *Message, arg ...string) Server - Start(m *Message, arg ...string) bool - Close(m *Message, arg ...string) bool -} -``` -模块有自己的完整的生命周期函数，像对象，像进程。 - -Spawn()创建新模块，类似于面向对象的new。参数m为创建模块时的消息，c为新模块，arg为创建时的参数。返回值为自定义的结构体。 - -Begin()初始化新模块，类似于面向对象的构造函数。 - -Start()启动模块服务，类似于进程启动。 - -Close()关闭模块服务，类似于进程结束，类似于面向对象的析构函数。 -```go -package demo - -import ( - "context" -) - -type Demo struct { - *ctx.Context -} - -func (demo *Demo) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server { - c.Caches = map[string]*ctx.Cache{ - "format": &ctx.Cache{Name: "format", Value: c.Name + ": hello %s world", Help: "output string"}, - } - c.Configs = map[string]*ctx.Config{} - - d := new(Demo) - d.Context = c - return d -} -func (demo *Demo) Begin(m *ctx.Message, arg ...string) ctx.Server { - return demo -} - -func (demo *Demo) Start(m *ctx.Message, arg ...string) bool { - return false -} - -func (demo *Demo) Close(m *ctx.Message, arg ...string) bool { - return true -} - -var Index = &ctx.Context{Name: "demo", Help: "example demo", - Caches: map[string]*ctx.Cache{ - "format": &ctx.Cache{Name: "format", Value: "hello %s world", Help: "output string"}, - }, - Configs: map[string]*ctx.Config{ - "default": &ctx.Config{Name: "default", Value: "go", Help: "output string"}, - }, - Commands: map[string]*ctx.Command{ - "echo": &ctx.Command{ - Name: "echo word", - Help: "echo something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Echo(m.Cap("format"), m.Conf("default")) - }, - }, - "new": &ctx.Command{ - Name: "new name", - Help: "create new module", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - sub := c.Spawn(m, arg[0], "new module") - sub.Begin(m) - sub.Start(m) - }, - }, - "del": &ctx.Command{ - Name: "del", - Help: "delete module", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - c.Close(m) - }, - }, - }, -} - -func init() { - demo := &Demo{} - demo.Context = Index - ctx.Index.Register(Index, demo) -} -``` -模块通过Context结构向外提供各种功能调用的接口，通过Server接口向ctx模块提供生命周期的控制函数。 -所以模块可以被复制，被删除，就有了生命周期。 -并且每个模块都会有父模块与子模块，所以就会形成一个动态的树状态结构，不断的有新加的模块，也会有消失的模块。 - -每个模块在被加载与注册时生成一个静态模块，Index即是静态模块的Context，在init()函数中会给创建模块的Server，并将Context与Server绑定到一起，同时向父模块注册当前模块。 - -当需要创新新模块时，会调用Spawn()从当前模块复制出来一个新的模块，作为当前模块的子模块。并调用Begin()对新模块进行初始化操作。 -当需要模块启动一个服务时，会调用Start()， 当需要模块关闭一个服务时，会调用Close()。服务的实现方式可以是一次性操作的，也可以是一直运行的。 - -新定义了一个结构体Demo，可以向其添加各种自定义的数据。ctx.Context指向绑定的模块。 -并实现了四个生命周期函数。Spawn()在创建新模块时会添加一个新缓存项。创建新的自定义结构体，并与新模块绑定。 -init()创建新的自定义结构体，并与静态模块绑定。 - -```sh -$ go install src/example/bench.go -$ bench -cli> ~demo -demo> new one -one> context demo -demo> context -demo(ctx:cli:aaa:root:root): begin() example demo -one(demo:cli:aaa:root:root): start() new module -demo> new two -two> context demo -demo> context -demo(ctx:cli:aaa:root:root): begin() example demo -one(demo:cli:aaa:root:root): start() new module -two(demo:cli:aaa:root:root): start() new module -one> context one -one> echo -one: hello go world -``` -重新编译并运行bench，进入demo模块，创新名为one的新模块，自动进入新模块。调用context demo切回原模块，调用context查看新建的模块。 -调用context one切换到新建的模块调用echo。 -新模块中没有echo命令，则会直接调用父模块的echo。 -新模块中有format缓存项，则不会调用父模块的format。 -新模块中没有default配置项，则会调用父模块的配置项。 -从而实现了模块间的继承与多态。 - -```sh -one> del -one> context demo -demo> context -demo(ctx:cli:aaa:root:root): begin() example demo -two(demo:cli:aaa:root:root): start() new module -``` -在one模块下调用del，则会删除当前模块。调用context demo切换到父模块，则看到one模块已经被删除。 - -### 3.2 message消息驱动的开发模型 -无论是Context中的三种标准接口，还是Server中的四个生命周期接口，都是基于消息调用的。 -即模块的所有操作都是消息驱动的。 所以大多函数中都会有参数m代表当前的消息，arg消息的请求行参数。 - -```go -Commands: map[string]*ctx.Command{ - "send": &ctx.Command{ - Name: "send module", - Help: "send something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - msg := m.Find(arg[0], false) - msg.Cmd("echo") - m.Echo(msg.Result(0)) - }, - }, - ... -``` -如上，消息的使用示例。 再给demo模块添加一条send命令。 -消息是有发起模块与接收模块，所以首先要指定接收模块创建一个新的消息。 -然后设置请求行与请求头的数据，并发送消息。 -最后从响应行与响应头中取出执行的结果。 - -这里从参数arg中取出接收模块的名字，调用Find()查找此模块，并创建新消息。 -然后调用Cmd()发送消息，通过参数设置了请求行。消息会发送给对应模块并调用模块的echo命令。 -最后调用Result()取了响应行的数据，并调用Echo()设置了send命令的执行结果。 - -```sh -$ go install src/example/bench.go -$ bench -demo> new one -one> context demo -demo> send one -one: hello go world -``` -重新编译并运行bench，在demo模块下，创建一个新的模块one，并切换回demo模块向one模块发送一条消息。 - -#### 3.2.1 消息创建 -```go -func (m *Message) Search(key string, root ...bool) []*Message -func (m *Message) Find(name string, root ...bool) *Message -func (m *Message) Sess(key string, arg ...string) *Message -``` -Search()遍历功能树，找出模块名称或模块帮助信息匹配正则表达式key的模块，并创建由当前模块发送给这些模块的消息。 - -Find()遍历功能树，找出模块名匹配完整路径名的模块，并创建由当前模块发送给此模块的消息。name值为点分路径名，如"ctx.cli"代表ctx模块下的cli模块。 - -第二个参数root代表搜索的起点，默认为从根模块开始搜索。值为false时，从当前模块开始搜索。 - -Sess()是对Search()与Find()进行了封装，会把搜索的结果保存下来，以便之后的多次使用。 -参数key为保存名，第二个参数为模块名，第三个参数为搜索方法search或find，第四个参数为搜索起点是否为根模块。 -后面三个参数都有默认值，使用方法类似于C++的变参。如果只有一个参数则会直接取出之前的查找结果并创建一个新的消息。 - -#### 3.2.2 消息发送 -```go -func (m *Message) Cmd(arg ...interface{}) *Message -``` -消息发送给目标模块，调用对应的Command接口。参数为命令行，包括命令名，与命令参数。 - -#### 3.2.3 消息读写 -```go -func (m *Message) Detail(index int, arg ...interface{}) string -func (m *Message) Detaili(index int, arg ...int) int -func (m *Message) Details(index int, arg ...bool) bool - -func (m *Message) Result(index int, arg ...interface{}) string -func (m *Message) Resulti(index int, arg ...int) int -func (m *Message) Results(index int, arg ...bool) bool - -func (m *Message) Option(key string, arg ...interface{}) string -func (m *Message) Optioni(key string, arg ...int) int -func (m *Message) Options(key string, arg ...bool) bool - -func (m *Message) Append(key string, arg ...interface{}) string -func (m *Message) Appendi(key string, arg ...int) int -func (m *Message) Appends(key string, arg ...bool) bool -``` -消息所带的数据类似于http报文。Detail()读写请求行（命令行）数据，Result()读写响应行。Option()读写请求头。Append()读写响应头。 - -请求行与响应行是由空格隔开的多个字符串，类似于字符串数组。Detail()与Result()第一个参数指定读写位置，第二个参数为要写入的数据，各种类型会转换为字符串插入到相应的位置。如果没有第二个参数，则代表读取对应位置上的数据。 - -请求头与响应头存储结构为map[string][]string，类似于字符串的数组结构体。Option()与Append()第一个参数为键值，指定要读写的数组，剩下的参数为要写入数组的多个数据，返回值为数组的第一个参数。如果没有第二个参数，则返回数组的第一个数据。 - -s结尾的函数代表读写的数据为bool值，函数内部会进行bool与string类型的相互转换。 - -i结尾的函数代表读写的数据为int值，函数内部会进行int与string类型的相互转换。 - -```go -Commands: map[string]*ctx.Command{ - "send": &ctx.Command{ - Name: "send module", - Help: "send something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Sess("sub", arg[0], "find", "false") - - msg := m.Sess("sub") - msg.Detail(0, "echo") - msg.Option("key", "hello") - - msg.Cmd() - - m.Echo(msg.Result(0)) - m.Echo(" ") - m.Echo(msg.Result(1)) - m.Echo(" ") - m.Echo(msg.Append("hi")) - }, - }, - "echo": &ctx.Command{ - Name: "echo", - Help: "echo something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Result(0, m.Option("key"), "world") - m.Append("hi", "nice") - }, - }, - ... -``` -在send命令中， Sess()在一开始就搜索并保存了所需的模块，这些操作可以放在专门的初始化。不必每次都查找模块。 -之后再调用Sess()创建新的消息，并调用Detail()设置请求行（命令行），调用Option()设置请求头。 -然后调用Cmd()执行命令。命令执行完成后调用Result()取出响应行，调用Append()取出响应头。 - -在echo命令中，调用Option取出请求头，调用Result设置响应行，调用Append设置响应头。 - -```sh -$ go install src/example/bench.go -$ bench -demo> new one -one> context demo -demo> send one -hello world nice -``` - -### 3.3 message消息驱动的事件回调 -每个模块都可以运行自己的协程，有自己的消息队列，从而实现并发。为了更简单的使用并发，对Cmd()封装了一个异步接口Call()。 - -```go -func (m *Message) Call(cb func() bool) -func (m *Message) Back() -``` -Call()发送消息，命令执行完成后会调用参数的中的回调函数。 -在回调函数中，如果返回值为true则代表消息执行完成，会删除回调函数。 -如果返回值为false则代表，消息还未处理完成。在其它事件中调用Back()可以再调用回调函数。 - -```go -Commands: map[string]*ctx.Command{ -"send": &ctx.Command{ - Name: "send module", - Help: "send something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Sess("sub", arg[0], "find", "false") - - msg := m.Sess("sub") - msg.Detail(0, "echo") - msg.Option("key", "hello") - - msg.Call(func() bool { - if msg.Append("get") == "" { - return false - } - - m.Echo(msg.Result(0)) - m.Echo(" ") - m.Echo(msg.Result(1)) - m.Echo(" ") - m.Echo(msg.Append("hi")) - return true - }) - - time.Sleep(2 * time.Second) - }, -}, -"echo": &ctx.Command{ - Name: "echo word", - Help: "echo something", - Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { - m.Result(0, m.Option("key"), "world") - m.Append("hi", "nice") - go func() { - time.Sleep(time.Second) - m.Append("get", "good") - m.Back() - }() - }, -}, -``` -把send与echo修改为异步方式，在send命令中，调用Call()发送消息，当echo命令执行完成后，会调用回调函数，但msg.Append("get")参数还不存在，所以返回false保留消息。 -1s后，echo命令中的协程会向消息中添加了响应头get，调用Back()，回调函数会被再次调用，此时条件满足，则会向后执行。 -为了看到执行结果，在send命令最后加了两秒的睡眼。 -如果去掉send命令中的睡眠，send命令直接就结束。当回调函数再次被调用时，就看不到执行行结果了。 - -```sh -$ go install src/example/bench.go -$ bench -demo> new one -one> context demo -demo> send one -hello world nice -``` -## 4 context核心模块详解 -应用层|ctx|cli|aaa|web --|-|-|-|- -控制层|lex|yac|log|gdb -数据层|tcp|nfs|ssh|mdb - -核心模块有十二个， 前两列为自下而上的控制流，后两列为自下而上的数据流。 - -最上层为应用层，定义各种应用。 -中间层为控制层，对数据的解析与记录。 -最下层为数据层，各种数据源的读写操作。 - - -ctx为模块中心，是根模块，ctx的三种标准接口会被所有模块继承。 - -cli为命令中心，所有的命令都会被cli模块接收执行分发，支持各种脚本语法。 - -lex为词法中心，可以自定义各种词法规则，对字符串进行词法解析。 - -yac为语法中心，可以自定义各种语法规则，对字符串进行语法解析。 - -tcp为网络中心，可以监听或建立网络连接，收发网络数据。 - -nfs为存储中心，可以对本地文件或是网络连接进行数据的各种读写操作。 - -aaa为认证中心，通过各种加密与认证算法，管理各种的权限，实现多用户并发。 - -web为应用中心，通过RESTful API向外提供各种应用服务。 - -log为日志中心，记录程序在运行的中的各种日志信息。 - -gdb为调试中心，提供调试工具，对程序运行的过程进行追踪与定位。 - -ssh为集群中心，自动的建立设备与设备的连接，实现域名与证书的自动分配。 - -mdb为数据中心，数据库的读写与维护，对各种数据库提供统一管理。 - -### 4.0 ctx模块中心 -### 4.1 cli命令中心 -### 4.2 lex词法中心 -### 4.3 yac语法中心 -### 4.4 tcp网络中心 -### 4.5 nfs存储中心 -### 4.6 aaa认证中心 -### 4.7 web应用中心 -### 4.8 log日志中心 -### 4.9 gdb调试中心 -### 4.a ssh集群中心 -### 4.b mdb数据中心 - -## 5 设计理念 - -## 数据结构 -* ARM: 寻址与指令 -* Linux: 文件与进程 -* HTTP: 表示与会话 - - -## 开发流程 -* 设计: 协议与流程 -* 编程: 接口与框架 -* 测试: 语句与表达式 - -## 接口设计 -* 功能树: Caches Configs Commands -* 消息树: Request History Session - -### Context功能树 -* Cap() Conf() Cmd() -* Spawn() Begin() Start() Close() - -### Message消息树 -* Detail() Option() Result() Append() -* Req() His() Sess() - -## 模块设计 -* 应用层 ctx cli aaa web -* 控制层 lex yac log gdb -* 数据层 tcp nfs ssh mdb - -### 应用层 -* ctx: 模块中心 -* cli: 管理中心 -* aaa: 认证中心 -* web: 应用中心 - -### 控制层 -* lex: 词法中心 -* yac: 语法中心 -* log: 日志中心 -* gdb: 调试中心 - -### 数据层 -* tcp: 网络中心 -* nfs: 存储中心 -* ssh: 集群中心 -* mdb: 数据中心 -