Redis Pipeline
Redis pipeline 功能简介在命令行中是没有Redis pipeline功能的，但redis是支持pipeline的，而且在各个语言版的client中都有相应的实现。
简单概括redis pipeline的功能就是将单次请求变为批量请求。
由于网络开销延迟，就算redis server端有
...
NSQD 消息处理流程
NSQD 消息处理整体流程
memoryMsgChan 和 backendMsgChanmemoryMsgChan：为内存缓冲区，Topic和Channel内存缓冲区的大小可以通过同一变量mem-queue-size来进行配置。
backendMsgChan：为磁盘优先级队列。通过diskqueue
...
分布式系统route map
分布式系统这里主要对分布式系统的定义、应用甚至意义来做一些阐述。有一个统揽全局的概念。
应用：分布式操作系统，分布式文件系统，分布式存储系统(分布式数据库、缓存、消息队列等)。
这里主要是针对分布式存储系统来展开。
分布式系统的理论基础基本概念基本概念：状态特征：无状态、系统重发、幂等性、 并行、并
...
基于Redis集群的分布式锁
分布式锁 Redlock由于前面介绍的基于单Redis节点的分布式锁在failover的时候会产生解决不了的安全性问题，因此antirez提出了新的分布式锁的算法Redlock，它基于N个完全独立的Redis节点（通常情况下N可以设置成5）。
运行Redlock算法的客户端依次执行下面各个步骤，来完
...
基于单Redis节点的分布式锁
具体实现获取锁：
1SET resource_name my_random_value NX PX 30000
上面的命令如果执行成功，则客户端成功获取到了锁，接下来就可以访问共享资源了；而如果上面的命令执行失败，则说明获取锁失败。
注意，在上面的SET命令中：
my_random_value是由
...
redis master, slave, sentinel通信
在这里主要说明redis sentinel是怎样在得知整个系统的拓扑结构的。
首先，sentinel会根据配置，和需要监控的master节点建立TCP连接，同时订阅master节点的 “__sentinel__:hello”频道。
在建立TCP连接后， sentinel会每10s向master
...
Redis 客户端与服务器连接流程实例
如下图所示，为redis 客户端连接服务器完整的流程。
1.首先在redis sever 启动的时候，会把AE_READABLE事件和acceptTcpHandler方法绑定，向eventLoop注册。
12if (server.ipfd > 0 && aeCreateFil
...
NSQ消息Inflight机制
简介在NSQ中，使用inflight机制来保证NSQ中消息”at least once”(至少被消费一次)。
在消息发送给Client之后，会将消息以及消息的timeout时间存储到优先级队列中pqueue。
如果客户端收到该消息，可以使用如下三个命令对此进行回复：
FIN: Finish a
...
NSQ中的优先级队列
在NSQ中，有两个最小堆实现的优先级队列，分别为: PriorityQueue，inFlightPqueue。分别用作延迟消息和消息的at least once机制。
堆排序(以大顶堆为例)堆排序的基本操作:
MAX-HEAPIFY ： 运行时间为O(logn)，是保持最大堆性质的关键。
BUIL
...
disk queue 源码分析
disk queue 简介disk queue是基于文件存储的FIFO(first-in-first-out)队列。在对数据进行持久化的同时，保证数据写入和读出的相对顺序。
在NSQ中，disk queue的应用场景为：
生产者在生产消息时，当消息内存缓冲区已经满了的时候，则利用disk queu
...
golang 反射中的Type Value 和 Kind
reflect.Type & reflect.Valuereflect.TypeTypeOf returns the reflection Type that represents the dynamic type of i. If i is a nil interface value,
...