-
83.Kafka 如何保证消息的顺序性？
83.Kafka 如何保证消息的顺序性？ 83.Kafka 如何保证消息的顺序性？ Kafka 本身，并不像 RocketMQ 一样，提供顺序性的消息。所以，提供的方案，都是相对有损的。如下： 这里的顺序消息，我们更多指的是，单个 Partition 的消息，被顺序消费。 方式一，Consumer ，对每个 Partition 内部单线程... -
71.Redis 有什么优点？
71.Redis 有什么优点？ 71.Redis 有什么优点？ ? 1. 速度快 因为数据存在内存中，类似于 HashMap ，HashMap 的优势就是查找和操作的时间复杂度都是O (1) 。 Redis 本质上是一个 Key-Value 类型的内存数据库，很像 Memcached ，整个数据库统统加载在内存当中进行操作，定期通过异步操作把... -
67.Kafka Consumer 是否可以消费指定的分区消息？
67.Kafka Consumer 是否可以消费指定的分区消息？ 67.Kafka Consumer 是否可以消费指定的分区消息？ Consumer 消费消息时，向 Broker 发出“fetch”请求去消费特定分区的消息，Consumer 指定消息在日志中的偏移量(offset)，就可以消费从这个位置开始的消息，Consumer 拥有了 offse... -
72.简单介绍一下如何读取数据？
72.简单介绍一下如何读取数据？ 72.简单介绍一下如何读取数据？ 如果我们要读取第 911 条数据。 首先第一步，找到它是属于哪一段的，根据二分法查找到他属于的文件，找到 0000900.index 和 00000900.log 之后。 然后，去 .index 中去查找 (911-900) =11 这个索引或者小于 11 最近的索引... -
83.Redis 有哪些数据结构？
83.Redis 有哪些数据结构？ 83.Redis 有哪些数据结构？ 如果你是 Redis 普通玩家，可能你的回答是如下五种数据结构： 字符串 String 字典Hash 列表List 集合Set 有序集合 SortedSet 如果你是 Redis 中级玩家，还需要加上下面几种数据结构： HyperLogLog Geo Bitmap 如... -
88.如何使用 Redis 实现消息队列？
89.如何使用 Redis 实现消息队列？ 89.如何使用 Redis 实现消息队列？ 一般使用 list 结构作为队列，rpush 生产消息，lpop 消费消息。当 lpop 没有消息的时候，要适当 sleep 一会再重试。 如果对方追问可不可以不用 sleep 呢？list 还有个指令叫 blpop ，在没有消息的时候，它会阻塞住直到消息到来... -
1.初识Kafka
初识Kafka 基本概念 初识Kafka Kafka 起初是 由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统，现已被捐献给 Apache 基金会。目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。目前越... -
88.为什么kafka这么快
为什么Kafka这么快？ 一、顺序IO 二、内存映射文件 三、零拷贝 四、应用层面的优化 写在后面 为什么Kafka这么快？ 很多人都知道Kafka吞吐量高，延迟低，那么为什么Kafka会这么快？如果在面试中被问到这个问题，你会回答吗？如果你一脸懵逼地看着面试官，面试官可能不会很生气，但是后果可能很严重。因为在面试官的眼里，你可能只是个会写... -
2. Kafka入门
安装与配置 1. JDK的安装与配置 2. ZooKeeper安装与配置 3. Kafka的安装与配置 生产与消费 服务端参数配置 1. zookeeper.connect 2. listeners 3. broker.id 4. log.dir和log.dirs 5. message.max.bytes 总结 安装与配置 本节... -
86.如何保证mysql和redis的实时性一致性
如何保证mysql和redis的实时性一致性 如何保证mysql和redis的实时性一致性 保证MySQL和Redis的实时一致性可以通过以下方法： 写入MySQL后更新Redis：在数据写入MySQL后，同步更新Redis。 使用MySQL的二进制日志（binlog）和消息队列：监控MySQL的binlog变更，然后通过消息队列将变更同步到Re...