这篇文章主要介绍“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的代码怎么写”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。