package main
|
|
import (
|
"flag"
|
_ "net/http/pprof"
|
"vamicro/config"
|
"vamicro/iotData-service/device"
|
"vamicro/iotData-service/model"
|
"vamicro/iotData-service/mqtt"
|
"vamicro/iotData-service/webserver"
|
|
"basic.com/valib/logger.git"
|
)
|
|
var (
|
env = flag.String("e", "pro", "")
|
webPort = flag.String("p", "9000", "listen port")
|
)
|
|
func init() {
|
flag.Parse()
|
|
config.Init(*env)
|
var logFile = config.LogConf.Path + "vamicro-" + "iotData-service" + ".log"
|
logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
|
|
logger.Info("log init success !")
|
}
|
|
func main() {
|
//go func() {
|
// logger.Info(http.ListenAndServe("0.0.0.0:6080", nil))
|
//}()
|
|
model.Init()
|
|
mqtt.LoadConfig()
|
|
mqtt.Client.Init(mqtt.Options.Broker, mqtt.Options.ClientId, mqtt.Options.Username, mqtt.Options.Password)
|
|
go device.Collector()
|
|
webserver.Serve(*webPort)
|
}
|
