消息

notify/producer.go

@@ -4,7 +4,6 @@ import (
 	"fmt"
 	"github.com/gogf/gf/frame/g"
 	"github.com/nsqio/go-nsq"
-	"gitlab.jxhh.com/stbz/library.git/logs"
 	"time"
 )
 
@@ -19,22 +18,27 @@ var (
 
 func New(config *NsqConfig) {
 	nsqConfig = config
+	NsqProducers = new(NsqProducer)
 }
 
 func InitProducer(config *NsqConfig) {
-	producer, err := nsq.NewProducer(config.Addr, nsq.NewConfig())
-	if logs.CheckErr(err, "InitProducer") {
-		producer.Stop()
+	var err error
+	if NsqProducers.producer != nil {
+		err = NsqProducers.producer.Ping()
+		if err == nil {
+			return
+		}
 	}
-
-	err = producer.Ping()
-	if logs.CheckErr(err, "InitProducer") {
-		producer.Stop()
+	NsqProducers.producer, err = nsq.NewProducer(config.Addr, nsq.NewConfig())
+	if err != nil {
+		return
 	}
-
-	NsqProducers = &NsqProducer{
-		producer: producer,
+	err = NsqProducers.producer.Ping()
+	if err != nil {
+		NsqProducers.producer.Stop()
+		return
 	}
+
 }
 
 //Publish 发布消息