hub / github.com/apache/rocketmq-client-go

github.com/apache/rocketmq-client-go @v2.1.2

repository ↗ · DeepWiki ↗ · release v2.1.2 ↗ · + Follow

1,283 symbols 3,965 edges 124 files 259 documented · 20% 5 cross-repo links

What it actually does AI analysis from the code graph — generated when you open this

loading…

README

RocketMQ Client Go

A product ready RocketMQ Client in pure go, which supports almost the full features of Apache RocketMQ, such as pub and sub messages, ACL, tracing and so on.

Due Diligence

Here, we sincerely invite you to take a minute to feedback on your usage scenario.

Features

For 2.X version, it supports: * sending message in synchronous mode * sending message in asynchronous mode * sending message in oneway mode * sending message in batch mode * sending orderly messages * sending delay messages * sending transaction messages * consuming message using push model * consuming message using pull model * consuming message using broadcast model * message tracing for pub and sub messages * ACL for producers and consumers * request-reply model

How to use

Step-by-step instruction are provided in RocketMQ Go Client Introduction
Consult RocketMQ Quick Start to setup rocketmq broker and nameserver.

Apache RocketMQ Community

RocketMQ Community Projects

Contact us

Mailing Lists: https://rocketmq.apache.org/about/contact/
Home: https://rocketmq.apache.org
Docs: https://rocketmq.apache.org/docs/quick-start/
Issues: https://github.com/apache/rocketmq-client-go/issues
Ask: https://stackoverflow.com/questions/tagged/rocketmq
Slack: https://rocketmq-community.slack.com/

How to Contribute

Contributions are warmly welcome! Be it trivial cleanup, major new feature or other suggestion. Read this how to contribute guide for more details.

License

Apache License, Version 2.0 Copyright (C) Apache Software Foundation

Extension points exported contracts — how you extend this code

CustomHeader (Interface)

(no doc) [27 implementers]

internal/remote/codec.go

OffsetStore (Interface)

go:generate mockgen -source offset_store.go -destination mock_offset_store.go -self_package github.com/apache/rocketmq-c [4 …

consumer/offset_store.go

NsResolver (Interface)

resolver for nameserver, monitor change of nameserver and notify client consul or domain is common [3 implementers]

primitive/nsresolver.go

QueueSelector (Interface)

(no doc) [4 implementers]

producer/selector.go

Namesrvs (Interface)

go:generate mockgen -source namesrv.go -destination mock_namesrv.go -self_package github.com/apache/rocketmq-client-go/v [2 …

internal/namesrv.go

RMQClient (Interface)

go:generate mockgen -source client.go -destination mock_client.go -self_package github.com/apache/rocketmq-client-go/v2/ [2 …

internal/client.go

UniqueItem (Interface)

(no doc) [3 implementers]

internal/utils/set.go

Invoker (FuncType)

Invoker finish a message invoke on producer/consumer.

primitive/interceptor.go

Core symbols most depended-on inside this repo

NewPassthroughResolver

called by 43

primitive/nsresolver.go

internal/remote/codec.go

Shape

Method 707

Function 373

Struct 144

TypeAlias 25

Interface 22

FuncType 12

Languages

Go100%

Modules by API surface

internal/client.go79 symbols

internal/mock_client.go71 symbols

internal/request.go51 symbols

consumer/consumer.go50 symbols

consumer/statistics.go47 symbols

consumer/pull_consumer.go45 symbols

primitive/message.go44 symbols

consumer/push_consumer.go44 symbols

consumer/option.go37 symbols

api.go36 symbols

producer/producer.go35 symbols

consumer/offset_store.go33 symbols

Used by 5 indexed graphs manifest dependencies, hub-wide

github.com/bufanyun/hotgo

github.com/coze-dev/coze-studio

github.com/dapr/dapr

github.com/douyu/jupiter

github.com/hwholiday/learning_tools

For agents

$ claude mcp add rocketmq-client-go \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact