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