Stack Overflow
Stack Overflow

Questions tagged [rocketmq]

RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.

RocketMQ

RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.

It offers a variety of features as follows:

  • Pub/Sub and P2P messaging model
  • Reliable FIFO and strict sequential messaging in the same queue
  • Long pull queue model,also support push consumption style
  • Million message accumulation ability in single queue
  • Over a variety of messaging protocols.such as JMS,MQTTCloud Charge etc.
  • Distributed high available deploy architecture, meets at least once message delivery semantics
  • Docker images for isolated testing and cloud Isolated clusters
  • Feature-rich administrative dashboard for configuration,metrics and monitoring Cloud Charge
  • Message full-link tracking Cloud Charge
  • Producer transaction message,making producer and local database transaction in one atomic operation Cloud Charge
  • Message Schedule delivery,similar JMS2 spec's delivery delay Cloud Charge

Learn it & Contact us

How can I develop with RocketMQ?

87 questions
10
votes
1 answer

Apache Pulsar vs. Apache RocketMQ

Apache Pulsar (by Yahoo) seems to be the next generation of Apache Kafka. Apache RocketMQ (by Alibaba) seems to be the next generation of Apache ActiveMQ. Both are open source distributed messaging and streaming data platforms. But how do they…
krn
  • 6,715
  • 14
  • 59
  • 82
4
votes
1 answer

Why Thread.sleep(0) can prevent gc in rocketmq?

Recently I read source code in RocketMQ , but I can`t understand this code. Why this code can prevent gc? https://github.com/apache/rocketmq/blob/master/store/src/main/java/org/apache/rocketmq/store/MappedFile.java for (int i = 0, j = 0; i <…
stuben
  • 43
  • 5
3
votes
2 answers

what's difference of readQueue and writeQueue

In RocketMQ the number of readQueue and number of writeQueue could be set separately, and it seems to me only the common part could work as expected. For example, if readQueueNum is set to 8 and writeQueueNum is set to 16, half of the messages is…
fankai
  • 128
  • 1
  • 8
3
votes
4 answers

Spring Boot application can handle tons of requests

I am using Spring-boot or Spring-Cloud Framework to develop a web application. The system will be mainly for processing HTTP Restful requests from client side, and then save them in to MySQL database. But I plan to make it more expandable. It…
Xmagic
  • 189
  • 1
  • 11
2
votes
1 answer

MongoDB insertMany or bulkwrite throws duplicate key error in Java-API

When I Try to use java api to insert many data into Mongodb4.0 (replica set) it throws duplicate key errors. The amount of data is not too large, only about 300000 . & insert in 3-5 seconds firstly I searched from the official document &…
HbnKing
  • 1,762
  • 1
  • 11
  • 25
2
votes
2 answers

apache rockerMQ broker doesn't start

i try to star rockerMQ broker,but i got the error message: There is insufficient memory for the Java Runtime Environment to continue. Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory. An error report…
liangyuanpeng
  • 21
  • 2
2
votes
2 answers

Rocketmq:MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]

when i send message to broker,this exception occasionally occurs. MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while This means broker is too busy(when tps>1,5000) to handle so many sending message…
allan
  • 21
  • 3
1
vote
1 answer

Newlife.RocketMQ message loss and duplicate

I am trying to do some test with RocketMQ, and I use C# with Newlife.RocketMQ. I started RocketMQ on my pc and I see the command window open and printing messages -- so that is ok. So I wrote a simple C# program to test this: This is the WPF…
AIMIN PAN
  • 1,563
  • 1
  • 9
  • 13
1
vote
2 answers

How to config multiple nameservers using spring-cloud-stream-rocketmq

Trying to develop a microservices project using the spring-cloud-stream-rocketmq. I have the default rocketmq server and my configuration is spring: cloud: stream: default-binder: rocketmq rocketmq: binder: …
neng zhang
  • 11
  • 1
1
vote
1 answer

One topic with 4 queues, only one be consumed

There are some RocketMQ topics, but only one topic with 4 queues, only one queue be consumed. RocketMQ 4.2.0 Java 1.8 The consumer group configuration: depthConsumerGroup.setNamesrvAddr(rocketMQConfig.getNameServers()); …
毕晓峰
  • 131
  • 1
  • 8
1
vote
1 answer

rocketmq-cpp fatal error LNK1112: module machine type 'x64' conflicts with target machine type 'X86'

I am generating rocketmq dll from rocketmq-cpp opensource github Project.I have used folling Prequisite boost 1.56.0,--> have build using this jam.exe msvc architecture=x86 address-model=64 link=static runtime-link=static stage(which is …
Vikas Singh
  • 181
  • 7
1
vote
0 answers

bytebuffer write cost too much time

I made a load test for rocketmq, then I found a lot of long call,the long call cost much more then 100ms.But I read the source code of the long call,the main cost is the writing of bytebuffer. The core code like this: public AppendMessageResult…
yuzhou.li
  • 31
  • 3
1
vote
1 answer

How can I connect RocketMQ broker with RocketMQ console to get the details?

I am a newbie to Apache RocketMQ. I have found that we can use RocketMQ console to get details of RocketMQ message transaction. see here How do I connect(sync) that console with my locally running RockerMQ broker? I am using this documentation to…
Kasthuriraajan
  • 145
  • 2
  • 15
1
vote
1 answer

Message queue for file transfers

My question is pretty simple. I'm looking for a MQ solution capable of reliable EDI file transfers along with some metadata attached to it. I've tried RocketMQ recently and I've come across hardcoded message size limits. I liked RocketMQ because of…
Newerth
  • 449
  • 2
  • 12
1
vote
0 answers

rocketmq-console taking minutes of time to showing created topics from rocketMQ client

I have installed rocketMQ-4.1 in ubuntu server ( 18GB ram and 6 Core ), and also rocketMQ-console for dashboard. https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console Then i have created dotNet client for creating topics for…
sanath meti
  • 5,179
  • 1
  • 21
  • 30
1
2 3 4 5 6