test

upload/mq.go

@@ -7,11 +7,14 @@ package upload
 import (
 	"encoding/json"
 	"fmt"
+	"sync"
 
 	beeLogger "github.com/beego/bee/logger"
 	"github.com/streadway/amqp"
 )
 
+var once sync.Once
+var RM *RabbitMQ
 type RabbitMQ struct {
 	connection   *amqp.Connection
 	channel      *amqp.Channel
@@ -60,7 +63,7 @@ func (r *RabbitMQ) mqClose() {
 }
 
 func (r *RabbitMQ) Send(req map[string]interface{}) error {
-	defer r.mqClose()
+	//defer r.mqClose()
 
 	bytes, err := json.Marshal(req)
 	if err != nil {
@@ -73,7 +76,13 @@ func (r *RabbitMQ) Send(req map[string]interface{}) error {
 
 }
 
-func Send(r map[string]interface{}) error {
-	s := &RabbitMQ{}
-	return s.Send(r)
+func init() {
+	once.Do(func() {
+		RM = NewRabbitmq()
+	})
+
 }
+func NewRabbitmq() *RabbitMQ{
+	return &RabbitMQ{}
+}
+

upload/ppt.go

@@ -68,7 +68,8 @@ func (p *PPT) Transform() (err error) {
 	_ = mime.AddExtensionType(".pptx", "application/vnd.openxmlformats-officedocument.presentationml.presentation")
 	maps["type"] = mime.TypeByExtension(ext)
 	maps["path"] = objectName
-	if err = Send(maps); err != nil {
+
+	if err = RM.Send(maps); err != nil {
 		beeLogger.Log.Errorf("Send Error: %s", err)
 		_ = UpdateFileError("6", maps["uuid"].(string), maps["roomNum"].(string), objectName)
 		return