Clarifying requirements I am now addressing the problem of out-of-order message handling for MQ during consumption. A quick introduction to the image above. A message...
Disruptor is a high-performance asynchronous processing framework. It is a lightweight Java messaging service, JMS, that enables concurrent operations on queues without locking.
LinkedIn has opened source Brooklin, a distributed, scalable streaming data service in near real time. Brooklin has been running LinkedIn since 2016, processing thousands of...
Preface In computer, middleware can be simply understood as "middleware is software that is located in the middle of two pieces of software, broadly speaking,...
MQ (full name: Message Queue- Message Queue) is an application-to-application communication process in which one end publishes messages to the Queue and the other end...
Distributed message queue xxL-MQ message consumption, timeout, retry process source level interpretation 1 How does the consuming end consume messages, what is the data flow...
In our last blog, we discussed some of the problems BIGO encountered in the performance tuning process of Pulsar Broker and suggested solutions. In this...
When interviewing a candidate for a job and discovering the use of MQ technology (such as Kafka, RabbitMQ, RocketMQ) in a project, one question will...
In the process of enterprise digital transformation, it is natural to encounter scenarios such as message routing, remote multi-activity, protocol adaptation and message backup. This...
Application scenarios of message-oriented middleware 3 Common message-oriented middleware 4 Design idea of message-oriented middleware 5. What is protocol protocol is a set of conventions...
Hello, everyone. I am a little boy picking up snails. What is message queue message queue application scenarios message queue how to solve the problem...
RabbitMQ is essentially a producer and consumer model, responsible for receiving, storing, and forwarding messages. In computer terms, the RabbitMQ model is more like a...
Build Lakehouse architecture based on RocketMQ and Hudi zero code, and RocketMQ Connector & RocketMQ Stream to assist ETL data analysis, providing you with the...
Half messages are the first phase of a RocketMQ transaction and can consist of two parts: producer -> Broker sends half messages. The Broker processes...
With the continuous expansion of project business, message queue has become a very important role in the project under the comprehensive microservitization environment. If you're...
SpringCloud Stream is a highly extensible event-driven microservice component for building connections to shared messaging systems. It provides a flexible programming model to build independent...
This article focuses on best practices for online production environments with RocketMQ's observability tools. RocketMQ leads the industry in its visibility capabilities, with features such...
Abstract: this article belongs to the original, welcome to reprint, reproduced please keep reference: https://github.com/jasonGeng88/blog, one day, the product run to say: "we need to...
Delayed messaging applies to a wide range of business scenarios. In distributed systems, the functionality of delayed messaging typically sinks into the middleware layer, usually...
In the RocketMQ configuration, there is a configuration item 'maxMessageSize' that changes the size limits for sending and receiving messages, and here is a way...
RabbitMQ optimizes channel producers, consumers and RabbitMQ to establish connections. To avoid establishing too many TCP connections, reduce resource consumption. The AMQP protocol introduces channels,...