这篇文章主要介绍“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的代码怎么写”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
