只启动一次生产者

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,