背景 Javashop电商系统的消息总线使用的事rabbitmq,在订单创建、静态页生成、索引生成等等业务中大量采用异步消息系统,这个对于mq高可用的要求有两个重要的考量: 1、集群化 2、可扩容 3、冗灾 冗灾就要实现rabbitmq的持久化,要考虑到rabbitmq宕机的情况,当rabbitmq ...
分类:
Web程序 时间:
2020-02-22 15:38:52
阅读次数:
226
简介MQ全称为MessageQueue,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。概念介绍Rab
分类:
其他好文 时间:
2020-02-20 18:37:50
阅读次数:
87
一般来说,分布式事务的实现主要有以下 5 种方案: XA 方案(两阶段提交 事务) TCC 方案 本地消息表(异步确保一致性) 可靠消息最终一致性方案(MQ事务消息RocketMQ) 最大努力通知方案 一致性从强到弱/性能开销从多到少:三阶段->二阶段->TCC->saga 使用场景: 1、资金账户 ...
分类:
其他好文 时间:
2020-02-19 00:47:32
阅读次数:
73
一.重试机制 1.由于MQ经常处于复杂的分布式系统中,考虑网络波动,服务宕机,程序异常因素,很有可能出现消息发送或者消费失败的问题。因此,消息的重试就是所有MQ中间件必须考虑到的一个关键点。如果没有消息重试,就可能产生消息丢失的问题,可能对系统产生很大的影响。所以,秉承宁可多发消息,也不可丢失消息的 ...
分类:
其他好文 时间:
2020-02-18 20:06:00
阅读次数:
70
MQ,Message Queue 消息队列。 ActiveMQ Apache开源的消息中间件,老牌消息中间件。 性能一般,一般场景够用了,但高并发时往往应付不了,在中小企业中使用广泛。 有2种集群模式: 一种是主从模式,另一种是分布式的主从模式。 slave 从属、奴隶 Kafka 最初由Linke ...
分类:
其他好文 时间:
2020-02-18 13:28:29
阅读次数:
92
RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列,类似于kafka中的partition producer 生产者,先去连接name server,查询到对应的broker信息,再去连接broker consumer 消费者,先去连接na ...
分类:
其他好文 时间:
2020-02-17 20:08:08
阅读次数:
85
计组 运算器 四个部件 | | ACC | MQ | ALU | X | | | | | | | | 加法运算 | 初态:被加数 | None | [ACC] + [X] ACC | [M] | | 减法运算 | 初态:被减数 | None | [ACC] [X] ACC | [M] | | 乘法运 ...
分类:
其他好文 时间:
2020-02-17 12:44:55
阅读次数:
148
ActiveMQ的消息事务 消息事务,是保证消息传递原子性的一个重要特性,和JDBC的事务特征类似。 一个事务性发送,其中一组消息要么能够全部保证到达服务器,要么都不到达服务器。生产者,消费者与消息服务器都支持事务性。ActiveMQ得事务主要偏向在生产者得应用。 ActiveMQ消息事务流程图: ...
分类:
其他好文 时间:
2020-02-16 12:38:59
阅读次数:
95
参考文档:https://www.rabbitmq.com/install-rpm.htm 1. 首先需要安装ErLang # dnf install -y wget epel-release # wget https://github.com/rabbitmq/erlang-rpm/release ...
分类:
其他好文 时间:
2020-02-15 23:37:47
阅读次数:
127
ActiveMQ简单简绍 MQ简介: MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信 ...
分类:
其他好文 时间:
2020-02-13 18:50:39
阅读次数:
79