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 subscribeerr = c.Start()os.Exit(-1)c.Shutdown()

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