1
0
mirror of https://shylinux.com/x/ContextOS synced 2025-04-25 16:58:06 +08:00

0 context简介

context: 终端工具链,各种实用的功能模块,通过简洁的接口,自由的组合在一起。

作为一个工具箱,内置各种实用工具,通过灵活的配置,打造个性化的工具链。

作为一个框架,通过模块式开发,可以快速开发各种应用软件。

  • 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-bin/raw/master/bench-linux-arm

https://github.com/shylinux/context-bin/raw/master/bench-linux-386

https://github.com/shylinux/context-bin/raw/master/bench-linux-amd64

https://github.com/shylinux/context-bin/raw/master/bench-windows-386.exe

https://github.com/shylinux/context-bin/raw/master/bench-windows-amd64.exe

https://github.com/shylinux/context-bin/raw/master/bench-darwin-amd64

1.1 context源码安装

1.1.0 golang安装

1.1.1 golang开发环境安装

1.1.2 context源码安装

2 context使用

2.0 应用示例--启动WEB服务器

$ bench
> ~web
> serve ./ ':9090'

在shell中运行命令bench启动应用进入到一个类似于shell的环境中。

执行"~web"切换到web模块执行"serve ./ ':9090'"在当前目录启动一个WEB服务器监听地址为"0.0.0.0:9090"。

打开浏览器输入"http://localhost:9090" 即可看一个静态WEB服务器已经启动。

2.0.1 添加脚本

bench支持脚本解析可以添加启动脚本这样就可以在启动的时候就运行一些命令启动一些功能。 在bench运行的当前目录创建一个目录etc并添加了个启动脚本文件etc/init.sh向脚本中添加如下命令。

~web serve ./ ':9090'

重新启动bench 打开浏览器输入"http://localhost:9090" 即可看一个静态WEB服务器已经启动。

2.0.2 查看日志

bench支持日志输出可以通过日志查看历史记录和运行状态。 在bench运行的当前目录创建一个目录var, 重新启动bench。 再打开一个终端进行bench的运行目录并查看日志文件。

$ 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对命令进行解释执行。

$ bench
> pwd
/Users/shaoying/context
> ls
etc
var
LICNESE
README.md
...

2.1 常用命令

2.1.1 缓存管理cache

web> cache
address(:9090): 服务地址
directory(./): 服务目录
protocol(http): 服务协议

输入"cache"命令,即可查看当前模块的缓存数据,通过这些缓存数据,就可以了解模块的当前各种运行状态。 如"address"代表web模块监听的网络地址为"0.0.0.0:9090"。

2.1.2 配置管理config

web> config
logheaders(yes): 日志输出报文头(yes/no)

输入"config"命令,即可查看当前模块的配置信息。通过修改这些配置信息,就可以控制模块的运行的环境,改变模块运行的状态。 如"logheaders"代表web模块处理网络请求时是否在日志中输出报文头此时值为yes即打印报文头。

web> config logheaders no
web> config
logheaders(no): 日志输出报文头(yes/no)

输入"config logheaders no"命令修改logheaders的值为no即不在日志中输出报文头。

2.1.3 命令管理command

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

web> context
web(ctx:cli:aaa::): start(:9090) 应用中心

输入"context"命令即可查看当前模块及子模块的基本信息。web模块没有子模块所以这里只显示了web模块的基本信息。

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

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。

tcp> message 9
message: 0
9(ctx->tcp): 23:36:48 []

输入"message 9"命令查看编号为9的消息的具体信息。

2.2 web模块的命令

web模块提供web服务。目前有两条命令主机管理serve路由管理route。

web> command
serve: serve [directory [address [protocol]]]
route: route directory|template|script route content
/demo: /demo

2.2.1 主机管理serve

web> command serve
serve [directory [address [protocol]]]
    开启应用服务

serve命令会监听网络端口并启动web服务器。

  • directory服务目录
  • address服务地址(ip:port)
  • protocol服务协议(http/https)

2.2.2 路由管理route

web> command route
route directory|template|script route content
    添加应用内容

route命令会向指定的URI添加响应内容。响应内容可以是文件内容可以是golang的模板可以是脚本执行结果。 参数route代表http请求的uri地址参数content代表响应回复的内容不同类型的服务有不同的意义。

  • directory静态服务
web> route directory /p pkg

命令"route diretory /p pkg"当web模块接收到请求uri为"/p/"时把目录"pkg"中的内容作为响应回复。 content代表路径即web服务请求此route路径时回复的内容为content指定的目录或文件。

  • template模板服务
web> route template /t LICENSE

命令"route template /t LICENSE"当web模块接收到请求uri为"/t"时把文件"LICENSE"中的内容作为响应回复。

  • script脚本服务
web> route script /s echo.shy

content代表脚本的文件名即web服务请求此route路径时回复的内容为content指定的脚本运行后输出的内容。

2.3 nfs模块的命令

nfs模块文件读写读写模块可以读写本地文件或远程文件。

$ bench
> ~nfs
> genqr qr.png hello

启动bench进入nfs模块调用genqr生成二维码图片。 可以看到在bench的当前运行目录生了一个png图片可以用手机扫描一下查看二维码内容。

nfs模块还支持文件的远程传输。

$ bench
> ~nfs
> listen ":9191"

启动bench进入nfs模块调用listen开启一个文件服务器监听的端口为"0.0.0.0:9191"。

在另外一个目录,一定注意是另外一个目录中。运行以下命令。

$ 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文件并输入以下代码。

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",引入新添加的模块 。

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进入新模块执行新添加的命令。

$ go install src/example/bench.go
$ bench
> ~demo
> echo
hello go world

3.0.0 代码解析

func init() {
	ctx.Index.Register(Index, nil)
}

在模块初始化时向ctx模块注册当前模块即当前模块为ctx的子模块。

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为命令项。 每个模块都需要初始化这五个属性,通过这些属性向外提供标准接口。

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为命令项执行函数。

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 缓存接口

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 配置接口

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 日志接口

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接口。

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()关闭模块服务,类似于进程结束,类似于面向对象的析构函数。

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()创建新的自定义结构体,并与静态模块绑定。

$ 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配置项则会调用父模块的配置项。 从而实现了模块间的继承与多态。

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消息的请求行参数。

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命令的执行结果。

$ 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 消息创建

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 消息发送

func (m *Message) Cmd(arg ...interface{}) *Message

消息发送给目标模块调用对应的Command接口。参数为命令行包括命令名与命令参数。

3.2.3 消息读写

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类型的相互转换。

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设置响应头。

$ go install src/example/bench.go
$ bench
demo> new one
one> context demo
demo> send one
hello world nice

3.3 message消息驱动的事件回调

每个模块都可以运行自己的协程有自己的消息队列从而实现并发。为了更简单的使用并发对Cmd()封装了一个异步接口Call()。

func (m *Message) Call(cb func() bool)
func (m *Message) Back()

Call()发送消息,命令执行完成后会调用参数的中的回调函数。 在回调函数中如果返回值为true则代表消息执行完成会删除回调函数。 如果返回值为false则代表消息还未处理完成。在其它事件中调用Back()可以再调用回调函数。

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命令直接就结束。当回调函数再次被调用时就看不到执行行结果了。

$ go install src/example/bench.go
$ bench
demo> new one
one> context demo
demo> send one
hello world nice

4 context核心模块详解

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: 数据中心
Description
Languages
JavaScript 40.6%
Shell 23%
HTML 20.7%
CSS 9.3%
Go 4.6%
Other 1.7%