kafka broker:运行kafka server的服务被称为broker,它主要用于接手topic消息,管理topic,持久化和存储topic数据,kafka审计,kafka权限管理等。 topic:消息主题,每个topic唯一,可存储和传输数据。(MQ中通常有Topic和Queue 2中消息 ...
分类:
其他好文 时间:
2020-02-22 18:31:35
阅读次数:
82
背景 Javashop电商系统的消息总线使用的事rabbitmq,在订单创建、静态页生成、索引生成等等业务中大量采用异步消息系统,这个对于mq高可用的要求有两个重要的考量: 1、集群化 2、可扩容 3、冗灾 冗灾就要实现rabbitmq的持久化,要考虑到rabbitmq宕机的情况,当rabbitmq ...
分类:
Web程序 时间:
2020-02-22 15:38:52
阅读次数:
226
用户购买一笔订单,需要在订单的有效截止时间前一定时间,提醒用户去使用。到达有效结束时间,将订单设置为失效。这时候可以用延时队列可以很好的解决,用户下单之后,在有效期前发送一条提醒用户去使用的消息,和一条订单已经失效的消息。 入口 生产者 将消息发送出去,延时delay毫秒,同时记录下消息发送的时间。 ...
分类:
编程语言 时间:
2020-02-21 18:13:39
阅读次数:
67
简介MQ全称为MessageQueue,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。概念介绍Rab
分类:
其他好文 时间:
2020-02-20 18:37:50
阅读次数:
87
write 解释 语法 示例 wall 解释 语法 示例 ping 解释 语法 示例 ifconfig 解释 语法 示例 mail 解释 语法 mail命令不存在 示例 last 解释 语法 示例 lastlog 解释 语法 示例 traceroute 解释 语法 traceroute命令不存在 示 ...
分类:
系统相关 时间:
2020-02-19 20:39:01
阅读次数:
77
一般来说,分布式事务的实现主要有以下 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
- 消息队列 RabbitMQ https://www.jianshu.com/p/79ca08116d57- 依赖注入和控制反转是什么东西???- 任务队列、延迟队列https://blog.csdn.net/liuxinghao/article/details/52205737- 熟悉的测试框架... ...
分类:
其他好文 时间:
2020-02-17 14:19:45
阅读次数:
57