require ( github.com/apache/rocketmq-client-go v2.0.0-alpha1 )
Go Client define the Logger
interface for log output, user can specify implementation of private. in default, client use logrus
.
rlog.SetLogger(Logger)
Producer interface {
Start() error
Shutdown() error
SendSync(context.Context, *primitive.Message) (*internal.SendResult, error)
SendOneWay(context.Context, *primitive.Message) error
}
Producer
instanceopt := producer.ProducerOptions{
NameServerAddr: "127.0.0.1:9876",
RetryTimesWhenSendFailed: 2,
}
p := producer.NewProducer(opt)
err := p.Start()
result, err := p.SendSync(context.Background(), &primitive.Message{ Topic: "test", Body: []byte("Hello RocketMQ Go Client!"), }) // do something with result
err := p.SendOneWay(context.Background(), &primitive.Message{
Topic: "test",
Body: []byte("Hello RocketMQ Go Client!"),
})
Full examples: producer
alpha1 only support PushConsumer
PushConsumer interface {
Start() error
Shutdown()
Subscribe(topic string, selector MessageSelector,
f func(*ConsumeMessageContext, []*primitive.MessageExt) (ConsumeResult, error)) error
}
PushConsumer
instancec := consumer.NewPushConsumer("testGroup", consumer.ConsumerOption{
NameServerAddr: "127.0.0.1:9876",
ConsumerModel: consumer.Clustering,
FromWhere: consumer.ConsumeFromFirstOffset,
})
err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx *consumer.ConsumeMessageContext,
msgs []*primitive.MessageExt) (consumer.ConsumeResult, error) {
fmt.Println(msgs)
return consumer.ConsumeSuccess, nil
})
Full examples: consumer