diff --git a/conn.go b/conn.go index 093612b..fb5becb 100644 --- a/conn.go +++ b/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) + +}