From fef42313bbe5d67b9ae8929167472f95dcb0fa55 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 20 十月 2023 19:29:36 +0800
Subject: [PATCH] 只启动一次生产者

---
 nsq/nsq.go |   10 +++++++---
 1 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/nsq/nsq.go b/nsq/nsq.go
index 06e78e5..3561a25 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -23,14 +23,18 @@
 	defaultConsumerManager = new(consumerManager)
 }
 
+var producerStarted bool
+
 func (c *consumerManager) init() error {
 	if len(conf.Conf.NsqConf.NodeId) <= 0 {
 		return errors.New("no NodeId")
 	}
-	if err := initProducer(); err != nil {
-		return err
+	if !producerStarted {
+		if err := initProducer(); err != nil {
+			return err
+		}
+		producerStarted = true
 	}
-
 	var topics = []string{
 		constvar.NsqTopicScheduleTask,
 		constvar.NsqTopicSendPlcAddress,

--
Gitblit v1.8.0