一、KafKa分区副本ISR选举机制 kafka 中每一个主题又进一步划分成若干个分区。副本的概念实际上是在分区层级下定义的，每个分区配置有多若干个副本。 所谓的副本，本质上就是一个只能追加写消息的提交日志，根据kafk…

在处理Web客户端发送的命令请求时，某些操作的执行时间可能会比我们预期的更长一些。通过将待执行任务的相关信息放入队列里面，并在之后对队列进行处理，用户可以推迟那些需要一段时间才能完成的操作，这种工作交给任务处理器来执行的…

声明 文章不是完全的原创，部分例子是收集网络资料 首先 我先引入一个大家熟知的观点：Reids可以作为消息队列来使用redis提供了两种方式来做消息队列，一种是生产者消费者模式，一种是发布订阅模式。 本篇文章将从 异步，…

看完lookupd和nsqd之后我们再来看下nsq client端的代码。 我是想把nsq系统完完整整的看一遍，从而对他形成一个更整体的认识。对message queue来说他的client端就是生产者和消费者，生产者负…

看完了nsqlookupd我们继续往下看, nsqd才是他的核心. 里面大量的使用到了go channel, 相信看完之后对你学习go有很大的帮助.相较于lookupd部分无论在代码逻辑和实现上都要复杂很多. 不过基本的…

在处理Web客户端发送的命令请求时，某些操作的执行时间可能会比我们预期的更长一些。通过将待执行任务的相关信息放入队列里面，并在之后对队列进行处理，用户可以推迟那些需要一段时间才能完成的操作，这种工作交给任务处理器来执行的…