From 742923a5512707bdfd4c0e2e9adfcb86b453be28 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 13 八月 2023 17:33:18 +0800
Subject: [PATCH] 修复长度大于1的读取结果
---
main.go | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/main.go b/main.go
index f77fc7a..c479135 100644
--- a/main.go
+++ b/main.go
@@ -1,12 +1,15 @@
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"
)
@@ -24,13 +27,23 @@
if runtime.GOOS == "windows" {
logFilePath = "log/plc-recorder.log"
}
+
logger.InitLog(logFilePath, "debug", 15, false)
logger.Info("plc-recorde start!")
// 鍒濆鍖杗sq
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)
}
--
Gitblit v1.8.0