MQ产品常用的三种协议： 1:JMS rocketMQ，activeMQ 2.AMQP RabbitMq 3.MQTT activeMQ RabbitMQ是AMQP的一种实现。 AMQP是什么？ 基本概念 broker：消息代理 producer: 消息的生产者 consumer: 消息的消费者 e ...
分类：
其他好文 时间：
2020-01-16 22:25:32
阅读次数：
93
分布式事务 通过MQ解决分布式事务的思路 1) 业务和消息生成耦合在一起 2) 业务和消息解耦 RocketMQ 中的事务消息 1) 目前RMQ3.2.6中事务消息的实现原理及存在的问题 2) 问题解决思路 本文介绍RocketMQ提供的第三种类型的消息——Transaction Message(事 ...
分类：
其他好文 时间：
2020-01-16 14:54:42
阅读次数：
91
生产者端消费者端运行效果补充RocketMQ提供了3种模式的Producer：NormalProducer（普通）、OrderProducer（顺序）、TransactionProducer（事务），对应的分别是普通消息、顺序消息和事务消息。在前面的博客当中，涉及的都是NormalProducer， ...
分类：
其他好文 时间：
2020-01-16 12:44:51
阅读次数：
97
文章目录 一、 Producer端重试 二、 Consumer端重试 1. Exception 2. Timeout总结 对于MQ，可能存在各种异常情况，导致消息无法最终被Consumer消费掉，因此就有了消息失败重试机制。很显示，消息重试分为2种：Producer端重试和Consumer端重试。 ...
分类：
其他好文 时间：
2020-01-15 19:11:14
阅读次数：
95
一、前言 二、分析问题 三、持久化 四、confirm机制 五、消息提前持久化 + 定时任务 六、幂等含义 6.1、为什么要有幂等这种场景？ 6.2、乐观锁方案 6.3、唯一ID + 指纹码 6.4、Redis原子操作 6.1、为什么要有幂等这种场景？ 6.2、乐观锁方案 6.3、唯一ID + 指纹 ...
分类：
其他好文 时间：
2020-01-13 16:16:12
阅读次数：
86
1.简介 RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion level capacity and flexib ...
分类：
其他好文 时间：
2020-01-12 21:41:26
阅读次数：
105
RocketMQ路由发现是非实时的，当Topic路由出现变化时，NameServer不主动推动给客户端，而是客户端定时拉取主题最新的路由 ...
分类：
其他好文 时间：
2020-01-12 09:42:12
阅读次数：
50
分布式事务解决方案： 一.基于XA协议的两阶段提交； 二.消息事务+最终一致性 所谓的消息事务就是基于消息中间件的两阶段提交，本质上是对消息中间件的一种特殊利用，它是将本地事务和发消息放在了一个分布式事务里，保证要么本地操作成功成功并且对外发消息成功，要么两者都失败。 开源的RocketMQ就支持这 ...
分类：
其他好文 时间：
2020-01-12 09:37:29
阅读次数：
64
Kafka作为时下最流行的开源消息系统，被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统，Kafka在保障了大部分功能特性的同时，还提供了超一流的读写性能。 针对Kafka性能方面进行简单分析，相关数据请参考：https://segmentfau ...
分类：
其他好文 时间：
2020-01-09 20:48:30
阅读次数：
79
rocketmq 基本使用可以看官网和官网给的demo. https://github.com/apache/rocketmq/tree/master/example这里主要说明几个点:rocketmq 发送类型常用:1,普通消息.(可以获取发送结果,失败了重试)2,有序消息.(秒杀,等需要有序的消 ...
分类：
其他好文 时间：
2020-01-09 18:57:20
阅读次数：
80
