golang操作rocketmq的代码怎么写

这篇文章主要介绍"golang操作rocketmq的代码怎么写"，在日常操作中，相信很多人在golang操作rocketmq的代码怎么写问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"golang操作rocketmq的代码怎么写"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

代码

func main() {        // 1. 创建主题        //CreateTopic("test-04", 10909)        // 2. 生产者向主题中发送消息        //SendSyncMessage("hello world0002")        // 3. 消费者订阅主题并消费        SubscribeMessage()}func CreateTopic(topicName string, port int) {        // 创建主题        testAdmin, err := admin.NewAdmin(admin.WithResolver(primitive.NewPassthroughResolver([]string{"ip:server_port"})))        if err != nil {                fmt.Println(err)        }        err = testAdmin.CreateTopic(                context.Background(),                admin.WithTopicCreate(topicName),                admin.WithBrokerAddrCreate(fmt.Sprintf("ip:%d", port)),        )        fmt.Println(err)func SendSyncMessage(message string) {        endPoint := []string{"ip:server_port"}        p, err := rocketmq.NewProducer(                producer.WithNameServer(endPoint),                //producer.WithNsResolver(primitive.NewPassthroughResolver(endPoint)),                producer.WithRetry(2),        err = p.Start()        result, err := p.SendSync(context.Background(), &primitive.Message{                Topic: "test",                Body:  []byte(message),        })        fmt.Println(result.Status, result)func SubscribeMessage() {        // 订阅主题、并消费        c, err := rocketmq.NewPushConsumer(                consumer.WithNameServer(endPoint),                consumer.WithConsumerModel(consumer.Clustering),                consumer.WithGroupName("GID_TEST01"),                //fmt.Println(err)        err = c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context,                msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {                for i := range msgs {                        fmt.Printf("subscribe callback: %v \n", msgs[i])                }                return consumer.ConsumeSuccess, nil                //fmt.Println(err.Error())        // Note: start after subscribe        err = c.Start()                os.Exit(-1)        c.Shutdown()

到此，关于"golang操作rocketmq的代码怎么写"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！