增加SendMsg方法

conn.go

@@ -3,10 +3,11 @@ package rocketmq
 import (
 	"context"
 	"errors"
+	"log"
+
 	"github.com/apache/rocketmq-client-go/v2"
 	"github.com/apache/rocketmq-client-go/v2/primitive"
 	"github.com/apache/rocketmq-client-go/v2/producer"
-	"log"
 )
 
 var MqPool rocketmq.Producer
@@ -28,6 +29,7 @@ func MqConnect(group string, resolver []string) {
 	}
 	MqPool = p
 }
+
 func SendSync(ctx context.Context, mq *primitive.Message) (*primitive.SendResult, error) {
 	var res primitive.SendResult
 	if MqPool == nil {
@@ -35,3 +37,25 @@ func SendSync(ctx context.Context, mq *primitive.Message) (*primitive.SendResult
 	}
 	return MqPool.SendSync(ctx, mq)
 }
+
+func Conn(group string, resolver []string) {
+	MqConnect(group, resolver)
+}
+
+/**
+ * 发送mq消息
+ * topic
+ * tag
+ * message json格式化
+ * 2023/02/17
+ */
+func SendMsg(ctx context.Context, topic, tag string, message []byte) (*primitive.SendResult, error) {
+
+	if MqPool == nil {
+		return &res, errors.New("Mq未链接")
+	}
+	msg := primitive.NewMessage(topic, message)
+	msg.WithTag(tag)
+	return MqPool.SendSync(ctx, msg)
+
+}