-
27. 聊聊本地消息表？
27. 聊聊本地消息表？ 聊聊可靠消息最终一致性方案？ 27. 聊聊本地消息表？ 本地消息表，其实是 国外的 Ebay 搞出来的这么一套思想 。 这个大概意思是这样的： A 系统在自己本地一个事务里操作同时，插入一条数据到消息表； 接着 A 系统将这个消息发送到 MQ 中去； B 系统接收到消息之后，在一个事务里，往自己本地消息表里插入... -
19. 消息队列的一般存储方式有哪些？
19. 消息队列的一般存储方式有哪些？ 19. 消息队列的一般存储方式有哪些？ 当前业界几款主流的MQ消息队列采用的存储方式主要有以下三种方式。 ? 1. 分布式KV存储 这类 MQ 一般会采用诸如 LevelDB 、RocksDB 和 Redis 来作为消息持久化的方式。由于分布式缓存的读写能力要优于 DB ，所以在对消息的读写能力要求都不是... -
1. 什么是消息队列？
1. 什么是消息队列？ 1. 什么是消息队列？ 消息队列，是分布式系统中重要的组件。 主要解决应用耦合，异步消息，流量削锋等问题。 可实现高性能，高可用，可伸缩和最终一致性架构，是大型分布式系统不可缺少的中间件。 目前主流的消息队列有 Kafka RabbitMQ RocketMQ ，老版本是 MetaQ 。 ActiveMQ ，目前用的人... -
8. 如何使用消息队列进行日志处理？
8. 如何使用消息队列进行日志处理？ 8. 如何使用消息队列进行日志处理？ 日志处理，是指将消息队列用在日志处理中，比如 Kafka 的应用，解决大量日志传输 的问题。 日志传输 日志采集客户端，负责日志数据采集，定时批量写入 Kafka 队列。 Kafka 消息队列，负责日志数据的接收，存储和转发。 日志处理应用：订阅并消费 Kafka... -
61.聊聊 Kafka 的设计要点？
61.聊聊 Kafka 的设计要点？ 1）吞吐量 2）负载均衡 3）拉取系统 4）可扩展性 61.聊聊 Kafka 的设计要点？ 参考解析 1）吞吐量 高吞吐是 Kafka 需要实现的核心目标之一，为此 kafka 做了以下一些设计： 1、数据磁盘持久化：消息不在内存中 Cache ，直接写入到磁盘，充分利用磁盘的顺序读写性能。 ... -
18. Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点？
18. Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点？ 18. Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点？ 这四者，对比如下表格如下： 特性 ActiveMQ RabbitMQ RocketMQ Kafka 单机吞吐量 万级，比 RocketMQ、Ka... -
71.Kafka 的数据存储模型是怎么样的?
71.Kafka 的数据存储模型是怎么样的? 71.Kafka 的数据存储模型是怎么样的? Kafka 每个 Topic 下面的所有消息都是以 Partition 的方式分布式的存储在多个节点上。同时在 Kafka 的机器上，每个 Partition 其实都会对应一个日志目录，在目录下面会对应多个日志分段（LogSegment）。 MacBook ... -
78.什么是 Kafka 事务？
78.什么是 Kafka 事务？ 1. 为什么要支持事务 2. 事务语义 2.1. 多分区原子写入 2.2. 粉碎“僵尸实例” 2.3. 读事务消息 3. 事务处理Java API 4. 事务工作原理 5. 事务协调器和事务日志 6. 数据流 7. 事务实践 7.1. 如何选择事务Id 7.2. 事务性能以及如何优... -
60.Kafka 的主要特点？
60.Kafka 的主要特点？ 60.Kafka 的主要特点？ 1、同时为发布和订阅提供高吞吐量。据了解，Kafka 每秒可以生产约 25 万消息（50MB），每秒处理 55 万消息（110MB）。 2、可进行持久化操作。将消息持久化到磁盘，因此可用于批量消费，例如 ETL ，以及实时应用程序。通过将数据持久化到硬盘，以及replication ... -
13. 如何保证生产者的发送消息的可靠性？
13. 如何保证生产者的发送消息的可靠性？ 13. 如何保证生产者的发送消息的可靠性？ 要保证生产者的发送消息的可靠性，可以从RabbitMQ、RocketMQ和Kafka三个消息队列的机制来讲： RabbitMQ ： 确认机制（ACK） ：通过开启confirm 功能，生产者在发送消息后会等待接收到确认回调，从而确保消息已经成功投递到队列中...