rocketmq-client-cpp

(★ 393)

Apache RocketMQ cpp client

File Explorer

Download Latest Version (.zip)

- - issue_template.md
- check-git-clang-format.sh
- git-clang-format
- FindJsoncpp.cmake
- FindLibevent.cmake
- build.sh
- deploy.sh
- AsyncProducer.cpp
- AsyncPushConsumer.cpp
- BatchProducer.cpp
- CAsyncProducer.c
- CBatchProducer.c
- CMakeLists.txt
- common.h
- COrderlyAsyncProducer.c
- OrderlyPushConsumer.cpp
- OrderProducer.cpp
- Producer.c
- PullConsumeMessage.c
- PullConsumer.cpp
- PushConsumeMessage.c
- PushConsumer.cpp
- PushConsumerOrderly.c
- README.md
- SendDelayMsg.cpp
- SyncProducer.cpp
- TransactionProducer.cpp
- Arg_helper.h
- AsyncCallback.h
- CBatchMessage.h
- CCommon.h
- CErrorMessage.h
- CMessage.h
- CMessageExt.h
- CMessageQueue.h
- CMQException.h
- ConsumeType.h
- CProducer.h
- CPullConsumer.h
- CPullResult.h
- CPushConsumer.h
- CSendResult.h
- CTransactionStatus.h
- DefaultMQProducer.h
- DefaultMQPullConsumer.h
- DefaultMQPushConsumer.h
- MQClient.h
- MQClientException.h
- MQMessage.h
- MQMessageExt.h
- MQMessageListener.h
- MQMessageQueue.h
- MQSelector.h
- MQueueListener.h
- PullResult.h
- RocketMQClient.h
- SendResult.h
- SessionCredentials.h
- TransactionListener.h
- TransactionMQProducer.h
- TransactionSendResult.h
- - CMakeLists.txt
- CMakeLists.txt
- CMakeLists.txt
- build.sh
- - DefaultMQAdmin.cpp
  - DefaultMQAdmin.h
- - Arg_helper.cpp
  - AsyncArg.h
  - AsyncCallbackWrap.cpp
  - AsyncCallbackWrap.h
  - big_endian.cpp
  - big_endian.h
  - ByteOrder.h
  - ClientRPCHook.cpp
  - ClientRPCHook.h
  - CommunicationMode.h
  - dataBlock.cpp
  - dataBlock.h
  - DefaultMQClient.cpp
  - FilterAPI.h
  - InputStream.cpp
  - InputStream.h
  - MemoryInputStream.cpp
  - MemoryInputStream.h
  - MemoryOutputStream.cpp
  - MemoryOutputStream.h
  - MessageAccessor.cpp
  - MessageAccessor.h
  - MessageSysFlag.cpp
  - MessageSysFlag.h
  - MQClientErrorContainer.cpp
  - MQClientErrorContainer.h
  - MQVersion.cpp
  - MQVersion.h
  - NameSpaceUtil.cpp
  - NameSpaceUtil.h
  - NamesrvConfig.h
  - noncopyable.h
  - OutputStream.cpp
  - OutputStream.h
  - PermName.cpp
  - PermName.h
  - PullSysFlag.cpp
  - PullSysFlag.h
  - ServiceState.h
  - SubscriptionGroupConfig.h
  - sync_http_client.cpp
  - sync_http_client.h
  - TopAddressing.cpp
  - TopAddressing.h
  - TopicConfig.cpp
  - TopicConfig.h
  - TopicFilterType.h
  - url.cpp
  - url.h
  - UtilAll.cpp
  - UtilAll.h
  - Validators.cpp
  - Validators.h
  - VirtualEnvUtil.cpp
  - VirtualEnvUtil.h
- - AllocateMQStrategy.h
  - ConsumeMessageConcurrentlyService.cpp
  - ConsumeMessageHookImpl.cpp
  - ConsumeMessageHookImpl.h
  - ConsumeMessageOrderlyService.cpp
  - ConsumeMsgService.h
  - DefaultMQPullConsumer.cpp
  - DefaultMQPullConsumerImpl.cpp
  - DefaultMQPullConsumerImpl.h
  - DefaultMQPushConsumer.cpp
  - DefaultMQPushConsumerImpl.cpp
  - DefaultMQPushConsumerImpl.h
  - FindBrokerResult.h
  - OffsetStore.cpp
  - OffsetStore.h
  - PullAPIWrapper.cpp
  - PullAPIWrapper.h
  - PullRequest.cpp
  - PullRequest.h
  - PullResult.cpp
  - PullResultExt.h
  - Rebalance.cpp
  - Rebalance.h
  - SubscriptionData.cpp
  - SubscriptionData.h
- - CBatchMessage.cpp
  - CErrorMessage.cpp
  - CMessage.cpp
  - CMessageExt.cpp
  - CProducer.cpp
  - CPullConsumer.cpp
  - CPushConsumer.cpp
  - CSendResult.cpp
- - BatchMessage.h
  - DefaultMQClient.h
  - MQAdmin.h
  - MQConsumer.h
  - MQProducer.h
  - QueryResult.h
- - Logging.cpp
  - Logging.h
- - BatchMessage.cpp
  - MQDecoder.cpp
  - MQDecoder.h
  - MQMessage.cpp
  - MQMessageExt.cpp
  - MQMessageId.h
  - MQMessageQueue.cpp
- - DefaultMQProducer.cpp
  - DefaultMQProducerImpl.cpp
  - DefaultMQProducerImpl.h
  - SendMessageHookImpl.cpp
  - SendMessageHookImpl.h
  - SendResult.cpp
  - StringIdMaker.cpp
  - StringIdMaker.h
  - TopicPublishInfo.h
  - TransactionMQProducer.cpp
  - TransactionMQProducerImpl.cpp
  - TransactionMQProducerImpl.h
- - CommandHeader.cpp
  - CommandHeader.h
  - ConsumerRunningInfo.cpp
  - ConsumerRunningInfo.h
  - HeartbeatData.h
  - KVTable.h
  - LockBatchBody.cpp
  - LockBatchBody.h
  - MessageQueue.cpp
  - MessageQueue.h
  - MQProtos.h
  - ProcessQueueInfo.h
  - RemotingCommand.cpp
  - RemotingCommand.h
  - RemotingSerializable.h
  - TopicList.h
  - TopicRouteData.h
- - ConsumeStats.cpp
  - ConsumeStats.h
  - StatsItem.h
  - StatsServer.cpp
  - StatsServer.h
  - StatsServerManager.cpp
  - StatsServerManager.h
- - disruptorLFQ.h
  - task_queue.cpp
  - task_queue.h
- - ConsumeMessageContext.cpp
  - ConsumeMessageContext.h
  - ConsumeMessageHook.h
  - SendMessageContext.cpp
  - SendMessageContext.h
  - SendMessageHook.h
  - TraceBean.cpp
  - TraceBean.h
  - TraceConstant.cpp
  - TraceConstant.h
  - TraceContext.cpp
  - TraceContext.h
  - TraceTransferBean.cpp
  - TraceTransferBean.h
  - TraceUtil.cpp
  - TraceUtil.h
- - ClientRemotingProcessor.cpp
  - ClientRemotingProcessor.h
  - EventLoop.cpp
  - EventLoop.h
  - ResponseFuture.cpp
  - ResponseFuture.h
  - SocketUtil.cpp
  - SocketUtil.h
  - TcpRemotingClient.cpp
  - TcpRemotingClient.h
  - TcpTransport.cpp
  - TcpTransport.h
- dllmain.cpp
- MQClientAPIImpl.cpp
- MQClientAPIImpl.h
- MQClientFactory.cpp
- MQClientFactory.h
- MQClientManager.cpp
- MQClientManager.h
- - MQClientAPIImpTest.cpp
  - MQClientFactoryTest.cpp
  - MQClientManagerTest.cpp
- CMakeLists.txt
- rocketmq-client-cpp.sln
- rocketmq-client-cpp.vcxproj
- rocketmq-client-cpp.vcxproj.filters
.asf.yaml
.clang-format
.gitignore
.travis.yml
build.sh
CMakeLists.txt
CONTRIBUTING.md
format.sh
LICENSE
NOTICE
package_rocketmq.mri
PULL_REQUEST_TEMPLATE.md
README.md
win32_build.bat

# Installation Guide

1. Get the code

git clone https://github.com/apache/rocketmq-client-cpp

Downloads the entire project code from GitHub to your computer.

cd rocketmq-client-cpp

Moves into the project folder you just downloaded.

2. CMake

Medium Recommended

Prerequisites

Git Needed to download the project code from GitHub.
CMake The tool used to generate build configuration.
C/C++ 컴파일러 Windows needs Visual Studio (Community edition, free), macOS needs Xcode Command Line Tools, Linux needs the gcc/g++ package.

- cmake 2.8.0: build jsoncpp require it

Type this command into your terminal and run it.

✅ Check that an executable was created inside the build folder, then run it directly (e.g. ./build/app_name).

Pulled directly from this repo's README.

3. .NET

Medium

Prerequisites

Git Needed to download the project code from GitHub.
.NET SDK The SDK required for the dotnet command.

cd Win32

This project's files live in a subfolder, so move into it first.

dotnet restore

Downloads the packages the project depends on.

dotnet run

Builds the project and runs it immediately.

✅ After dotnet run, check the message or address shown in the terminal.