消息

notify/producer.go

@@ -41,12 +41,8 @@ func InitProducer(config *NsqConfig) *NsqProducer {
 
 //发布消息
 func (p *NsqProducer) Publish(topic string, message string) (err error) {
-	defer func() {
-		if err != nil {
 	//重试连接
-			InitProducer(nsqConfig)
-		}
-	}()
+	NsqProducers = InitProducer(nsqConfig)
 
 	if p.producer != nil {
 		if message == "" { //不能发布空串，否则会导致error
@@ -67,8 +63,7 @@ func (p *NsqProducer) Publish(topic string, message string) (err error) {
 //发布延迟消息
 func (p *NsqProducer) DeferredPublish(topic string, delay time.Duration, message string) error {
 
-	//logs.Infof(context.Background(),"topic",message)
-
+	NsqProducers = InitProducer(nsqConfig)
 	var err error
 	if p.producer != nil {
 		if message == "" { //不能发布空串，否则会导致error