## 简介
闲来无事，试着用Golang来搞Linux嵌入式应用级开发。发现效果还挺好的，总结出来了个框架，分享一下：https://github.com/i4de/rulex 。
## 入门
```go
package main
import (
"os"
"os/signal"
"syscall"
"github.com/i4de/rulex/core"
"github.com/i4de/rulex/engine"
"github.com/i4de/rulex/glogger"
httpserver "github.com/i4de/rulex/plugin/http_server"
"github.com/i4de/rulex/typex"
)
/*
*
* Test 485 sensor gateway
*
*/
func main() {
mainConfig := core.InitGlobalConfig("rulex.ini")
glogger.StartGLogger(true, core.GlobalConfig.LogPath)
glogger.StartLuaLogger(core.GlobalConfig.LuaLogPath)
core.StartStore(core.GlobalConfig.MaxQueueSize)
core.SetLogLevel()
core.SetPerformance()
c := make(chan os.Signal, 1)
signal.Notify(c, syscall.SIGINT, syscall.SIGABRT, syscall.SIGTERM)
engine := engine.NewRuleEngine(mainConfig)
engine.Start()
hh := httpserver.NewHttpApiServer()
// HttpApiServer loaded default
if err := engine.LoadPlugin("plugin.http_server", hh); err != nil {
glogger.GLogger.Fatal("Rule load failed:", err)
}
// RTU485_THER Inend
RTU485Device := typex.NewDevice("RTU485_THER",
"温湿度采集器", "温湿度采集器", "", map[string]interface{}{
"slaverIds": []uint8{1, 2},
"timeout": 5,
"frequency": 5,
"config": map[string]interface{}{
"uart": "/dev/ttyUSB0",
"dataBits": 8,
"parity": "N",
"stopBits": 1,
"baudRate": 4800,
},
"registers": []map[string]interface{}{
{
"tag": "node1",
"function": 3,
"slaverId": 1,
"address": 0,
"quantity": 2,
},
{
"tag": "node2",
"function": 3,
"slaverId": 2,
"address": 0,
"quantity": 2,
},
},
})
RTU485Device.UUID = "RTU485Device1"
if err := engine.LoadDevice(RTU485Device); err != nil {
glogger.GLogger.Error("RTU485Device load failed:", err)
}
mqttOutEnd := typex.NewOutEnd(
"MQTT",
"MQTT桥接",
"MQTT桥接", map[string]interface{}{
"Host": "127.0.0.1",
"Port": 1883,
"ClientId": "test-485-thgw1",
"Username": "test-485-thgw1",
"Password": "test-485-thgw1",
"PubTopic": "MQTT/upstream/test-485-thgw1",
"SubTopic": "MQTT/downstream/test-485-thgw1",
},
)
mqttOutEnd.UUID = "mqttOutEnd-MQTT"
if err := engine.LoadOutEnd(mqttOutEnd); err != nil {
glogger.GLogger.Fatal("mqttOutEnd load failed:", err)
}
rule := typex.NewRule(engine,
"uuid",
"数据推送至MQTT",
"数据推送至MQTT",
[]string{},
[]string{RTU485Device.UUID}, // 数据来自网关设备,所以这里需要配置设备ID
`function Success() print("[LUA Success Callback]=> OK") end`,
`
Actions = {function(data)
for tag, v in pairs(rulexlib:J2T(data)) do
local ts = rulexlib:TsUnixNano()
local value = rulexlib:J2T(v['value'])
value['tag']= tag;
local jsont = {
method = 'report',
requestId = ts,
timestamp = ts,
params = value
}
print('mqttOutEnd-MQTT', rulexlib:T2J(jsont))
rulexlib:DataToMqtt('mqttOutEnd-MQTT', rulexlib:T2J(jsont))
end
return true, data
end}
`,
`function Failed(error) print("[LUA Failed Callback]", error) end`)
if err := engine.LoadRule(rule); err != nil {
glogger.GLogger.Fatal(err)
}
s := <-c
glogger.GLogger.Warn("Received stop signal:", s)
engine.Stop()
os.Exit(0)
}
```
