关闭消费者时先关闭连接，再停止消费者

zhangqian

2023-10-21 4c066543587bb0ec88a6723f4d66da60c36aec53

关闭消费者时先关闭连接，再停止消费者

 nsq/nsq.go

@@ -89,5 +89,5 @@

func Stop() {
    defaultConsumerManager.stop()
    StopProducer()
    //StopProducer()
}

 pkg/nsqclient/consumer.go

@@ -91,9 +91,6 @@
        select {
        case <-n.ctx.Done():
            logx.Infof("[%s] stop consumer...", n.topic)
            n.consumer.Stop()
            <-n.consumer.StopChan
            logx.Infof("[%s] stop consumer success", n.topic)
            for _, addr := range qAddr {
                err = n.consumer.DisconnectFromNSQD(addr)
                if err != nil {
@@ -102,6 +99,10 @@
                    logx.Infof("disconnect from nsq server success, addr: %v, topic: %v", addr, n.topic)
                }
            }
            n.consumer.Stop()
            <-n.consumer.StopChan
            logx.Infof("[%s] stop consumer success", n.topic)

            return nil
        }
    }