RocketMQ 消息队列中丢失消息的场景举例及解决办法
消息中间件

RocketMQ 消息队列中丢失消息的场景举例及解决办法

101 0

既然使用在项目中使用了MQ,那么就不可避免的需要考虑消息丢失问题。在一些涉及到了金钱交易的场景下,消息丢失还是很致命的。那么在RocketMQ中存在哪几种消息丢失的场景呢?先来一张最简单的消费流程图:上图中大致包含了这么几种场景:1)生产者产生消息发送给RocketMQ2)RocketMQ接收到了消...

阅读全文
消息队列应用场景及ActiveMQ、RabbitMQ、RocketMQ、Kafka对比
RabbitMQ

消息队列应用场景及ActiveMQ、RabbitMQ、RocketMQ、Kafka对比

90 0

在之前的业务中,使用了Kafka和RabbitMQ两种消息队列,这篇文章来做一个总结。消息队列中间件是分布式系统中重要的组件,主要实现异步消息,应用解耦,流量削峰及消息通讯等功能。下面举例说明在实际应用中消息队列是如何使用的。消息队列应用场景1、异步处理以用户注册,并且需要注册邮件和短信为例。用户注...

阅读全文
ActiveMQ消息队列从入门到实践(3)—通过ActiveMQ收发消息
ActiveMQ

ActiveMQ消息队列从入门到实践(3)—通过ActiveMQ收发消息

921 0

在MQ中,消息模型有两种,一种是队列(Queue),一种是主题(Topic)。队列是Point-To-Point的,队列中的消息,仅能被消费一次。主题是PubSub模型,主题中的消息,可以由多个订阅者消费;订阅者只能消费它订阅以后的消息。这是遵循的JMS规范。1.1 收发消息对象创建过程如上图所示,...

阅读全文
RabbitMQ

消息队列篇—常用消息队列MQ产品介绍及对比

7964 0

MQ作为中间件,消息队列是分布式应用间交换信息的重要组件。消息队列可存储在内存和磁盘上,队列可以存储消息直至它们被应用程序接收。通过消息队列在应用程序不知道彼此位置的情况下可以独立处理信息或在处理消息前不需要等待接收该消息。所有消息队列可以解决应用解耦、异步消息等问题,是实现高性能、高可用、可伸缩和...

阅读全文
消息队列篇—详谈ActiveMQ消息队列模式的分析及使用
Java

消息队列篇—详谈ActiveMQ消息队列模式的分析及使用

5264 0

消息队列(Message Queue)是分布式系统中重要的组件,通用使用场景可以简单地描述为当不需要立即获得结果,但是并发量需控制时就需要使用消息队列。消息列队有两种消息模式,一种是点对点的消息模式,另一种是订阅\发布的消息模式。点对点的消息模式点对点的模式主要建立在一个队列上,当连接一个列队时,发...

阅读全文