一、RocketMQ4.X 消费者核心配置 consumeFromWhere 配置(某些情况失效:参考https://blog.csdn.net/a417930422/article/details/83585397)这个配置基本不用改,采用默认配置即可。 CONSUME_FROM_FIRST_OF ...
分类:
其他好文 时间:
2020-02-26 01:32:25
阅读次数:
138
Spring实现异步的方式 引入MQ后的架构演进 MQ的使用场景 异步处理 流量削峰填谷 解耦微服务 MQ的选择 mq对比详情 "mq对比详情" 搭建MQ "搭建教程" 搭建RocketMq控制台 "RocketMQ控制台安装教程" RocketMq的术语与概念 RocketMQ进阶 ==看官方Ro ...
分类:
编程语言 时间:
2020-02-25 20:01:39
阅读次数:
274
综上所述,各种对比之后,我个人倾向于是: 一般的业务系统要引入MQ,最早大家都用ActiveMQ,但是现在确实大家用的不多了,没经过大规模吞吐量场景的验证,社区也不是很活跃,所以大家还是算了吧,我个人不推荐用这个了; 后来大家开始用RabbitMQ,但是确实erlang语言阻止了大量的java工程师 ...
分类:
其他好文 时间:
2020-02-23 20:01:10
阅读次数:
69
消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ。消息中间件到底该如何使用,何时使用这是一个问题,胡乱地使用消息中间件增加了系统的复杂度,如果用不好消息中间件还不如不用。
分类:
其他好文 时间:
2020-02-19 10:20:29
阅读次数:
116
一般来说,分布式事务的实现主要有以下 5 种方案: XA 方案(两阶段提交 事务) TCC 方案 本地消息表(异步确保一致性) 可靠消息最终一致性方案(MQ事务消息RocketMQ) 最大努力通知方案 一致性从强到弱/性能开销从多到少:三阶段->二阶段->TCC->saga 使用场景: 1、资金账户 ...
分类:
其他好文 时间:
2020-02-19 00:47:32
阅读次数:
73
RocketMQ生产者和消费者 注:生产者在生产数据时,指定数据的key,然后消费者进行数据消费时,获取到key,与redis中保存的key做判断 如果不相同代表之前没有人进行消费,处理消费,保存到redis当中 当有第二个消费者时,如果拿到的消息与redis中相同代表之前已已经有人消费 就进行数据 ...
分类:
其他好文 时间:
2020-02-18 20:11:14
阅读次数:
60
一.重试机制 1.由于MQ经常处于复杂的分布式系统中,考虑网络波动,服务宕机,程序异常因素,很有可能出现消息发送或者消费失败的问题。因此,消息的重试就是所有MQ中间件必须考虑到的一个关键点。如果没有消息重试,就可能产生消息丢失的问题,可能对系统产生很大的影响。所以,秉承宁可多发消息,也不可丢失消息的 ...
分类:
其他好文 时间:
2020-02-18 20:06:00
阅读次数:
70
第一步:导入依赖 <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>3.0.10</version> </dependency> <depend ...
分类:
编程语言 时间:
2020-02-18 15:04:07
阅读次数:
79
RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列,类似于kafka中的partition producer 生产者,先去连接name server,查询到对应的broker信息,再去连接broker consumer 消费者,先去连接na ...
分类:
其他好文 时间:
2020-02-17 20:08:08
阅读次数:
85
今天,「架构师成长系列直播」正式上线啦! 疫情爆发,为了避免大家在线下聚集,我们决定延期举办众多 "线下 Meetup" 。我们迅速召集了包括 Apache Dubbo PMC、Apache RocketMQ 中国社区发起人& PMC、Spring Cloud Alibaba PMC 等 30+ 位 ...
分类:
其他好文 时间:
2020-02-17 19:55:30
阅读次数:
71