go~wasm插件的开发
Go和TinyGo是两种不同的Go语言编译器,它们之间有以下几点区别:
-
目标平台:
- Go:Go语言编译器主要面向通用计算机平台,如Windows、Linux、macOS等。
- TinyGo:TinyGo专注于支持嵌入式系统和物联网设备等资源受限的平台,如微控制器、嵌入式设备、WebAssembly等。
-
性能:
- Go:Go编译器生成的可执行文件通常较大,运行速度较快,适合在通用计算机上运行。
- TinyGo:TinyGo针对嵌入式系统做了优化,生成的可执行文件更小,运行速度可能会受到一定影响,但更适合在资源受限的环境下运行。
-
语言特性支持:
- Go:Go语言拥有完整的标准库和语言特性,适合构建各类应用程序。
- TinyGo:由于针对嵌入式系统,TinyGo对部分Go语言特性和标准库进行了裁剪,不支持所有Go标准库,但提供了适用于嵌入式系统的替代方案。
-
编译器实现:
- Go:Go编译器是使用Go语言本身实现的。
- TinyGo:TinyGo是一个基于LLVM的Go编译器前端,通过LLVM将Go代码编译为目标平台的机器码。
总的来说,Go适合构建通用计算机上的应用程序,而TinyGo则更适合用于嵌入式系统和物联网设备等资源受限的平台。选择使用哪种编译器取决于你的目标平台和需求。
github.com/alibaba/higress/plugins/wasm-go这个由阿里团队开发的包,目前2024-03-01已经集成了redis,目前只在阿里mse上使用,不支持本地化使用,目前本地化envoy环境还不支持这个东西。
可关注它的sdk,github.com/higress-group/proxy-wasm-go-sdk,目前最新版是202402026号的,再更新后,应该就支持了
没有封装的redis命令,可以这样使用
没有的命令可以先用 Command(cmds []interface{}, callback RedisResponseCallback),通过 []interface{}{"set", "id", 1} 这种方式执行redis命令
重写onHttpRequestBody之后需要设置请求体限制
- 当你需要接收请求体时,你需要将mse->参数配置->DownstreamConnectionBufferLimits,默认是32768 byte
- DownstreamConnectionBufferLimits:作用于网关连接,单条链接的buffer大小,配置后会影响吞吐和网关的内存使用
func onHttpRequestBody(ctx wrapper.HttpContext, config MyConfig, body []byte, log wrapper.Log) types.Action {
}
这句话的意思是:当配置单条链接的buffer大小时,这个配置会影响网关连接的吞吐量(即单位时间内处理的请求或数据量)和网关所使用的内存量。具体来说:
-
吞吐量影响:单条链接的buffer大小会直接影响数据在网关连接中的传输速度和效率。较大的buffer大小可能会提高数据传输的速度,从而增加吞吐量;而较小的buffer大小可能会导致数据传输速度变慢,降低吞吐量。
-
内存使用影响:配置单条链接的buffer大小后,会占用一定量的内存空间来存储这些buffer。如果buffer大小较大,将会消耗更多的内存资源;反之,如果buffer大小较小,则消耗的内存资源也相对较少。因此,合理配置buffer大小可以平衡吞吐量和内存使用之间的关系,以达到更好的性能表现。
对return types.ActionPause的理解
- return types.ActionPause请求被阻塞后,通过proxywasm.ResumeHttpRequest()恢复执行,这样其它插件(filter)可以继续执行
- 当前方法中,如果return types.ActionPause后面还有其它代码,这些代码不会被执行,因为方法已经退出了
如下代码,当eptid不为空时,执行了return types.ActionPause,及时它proxywasm.ResumeHttpRequest()了,那下面的代码username这块,也不会被执行
if eid != "" {
err := blackProcess(ctx, config, log, != "" {, BLACKLIST_EPTID)
if err != nil {
log.Errorf("blackProcess error while calling redis")
return types.ActionContinue
}
return types.ActionPause
}
if username != "" {
err := blackProcess(ctx, config, log, username, BLACKLIST_KCUSERNAME)
if err != nil {
log.Errorf("blackProcess error while calling redis")
return types.ActionContinue
}
return types.ActionPause
}
以下这两个方法定义有什么区别
- func (config RedisConfig) BlackProcess(ctx wrapper.HttpContext, log wrapper.Log, val string, blackType string)
- func (config *RedisConfig) BlackProcess(ctx wrapper.HttpContext, log wrapper.Log, val string, blackType string)
这两个方法定义的区别在于它们的接收者(Receiver)不同:
-
func (config RedisConfig) BlackProcess(ctx wrapper.HttpContext, log wrapper.Log, val string, blackType string)
:这是一个针对RedisConfig
类型值的方法,即使用值接收者。在调用该方法时,会对传入的RedisConfig
对象进行值拷贝,方法内部对对象的修改不会影响原始对象。 -
func (config *RedisConfig) BlackProcess(ctx wrapper.HttpContext, log wrapper.Log, val string, blackType string)
:这是一个针对RedisConfig
类型指针的方法,即使用指针接收者。在调用该方法时,会直接操作指向RedisConfig
对象的指针,方法内部对对象的修改会影响原始对象。
通常情况下,如果需要在方法内部修改接收者对象的状态或属性,应该使用指针接收者;如果不需要修改对象状态,只是对对象进行操作,可以使用值接收者。根据具体需求选择合适的接收者类型来定义方法。