# cloudmq-go-client **Repository Path**: anhj_iot_platform/cloudmq-go-client ## Basic Information - **Project Name**: cloudmq-go-client - **Description**: Golang版本的rocketMQ客户端 - **Primary Language**: Unknown - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 4 - **Created**: 2019-11-30 - **Last Updated**: 2020-12-19 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # go_rocket_mq go rocketmq client #import import rocketmq "github.com/didapinchegit/go_rocket_mq" #example conf := &rocketmq.Config{ Nameserver: "192.168.1.234:9876", ClientIp: "192.168.1.23", InstanceName: "DEFAULT", } consumer, err := rocketmq.NewDefaultConsumer("C_TEST", conf) if err != nil { log.Panic(err) } consumer.Subscribe("test2", "*") consumer.Subscribe("test3", "*") consumer.RegisterMessageListener(func(msgs []*rocketmq.MessageExt) error { for i, msg := range msgs { log.Print(i, string(msg.Body)) } return nil }) consumer.Start()