| | |
|---|
| | | package main |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "os" |
|---|
| | | "runtime" |
|---|
| | | |
|---|
| | | "plc-recorder/collector" |
|---|
| | | "plc-recorder/config" |
|---|
| | | "plc-recorder/logger" |
|---|
| | | "plc-recorder/msg" |
|---|
| | | "plc-recorder/nsqclient" |
|---|
| | | "plc-recorder/webserver" |
|---|
| | | |
|---|
| | | "github.com/rs/zerolog" |
|---|
| | | ) |
|---|
| | |
|---|
| | | if runtime.GOOS == "windows" { |
|---|
| | | logFilePath = "log/plc-recorder.log" |
|---|
| | | } |
|---|
| | | |
|---|
| | | logger.InitLog(logFilePath, "debug", 15, false) |
|---|
| | | logger.Info("plc-recorde start!") |
|---|
| | | |
|---|
| | | // 初始化nsq |
|---|
| | | nsqclient.InitNsqProducer() |
|---|
| | | |
|---|
| | | // 订阅设备变更 |
|---|
| | | go nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "plc-recorder", collector.HandleDeviceUpdate) |
|---|
| | | |
|---|
| | | // 启动采集任务 |
|---|
| | | collector.InitTask() |
|---|
| | | |
|---|
| | | select {} |
|---|
| | | // 测试数据 |
|---|
| | | if len(os.Args) > 1 && os.Args[1] == "-d" { |
|---|
| | | go msg.TestSendDeviceLiveData() |
|---|
| | | } |
|---|
| | | |
|---|
| | | webserver.Serve(config.Options.ServePort) |
|---|
| | | } |
|---|
