只启动一次生产者

zhangqian

2023-10-20 fef42313bbe5d67b9ae8929167472f95dcb0fa55

 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,