pika線程模型

pika使用的是多線程模型，使用多個工作線程來進(jìn)行讀寫操作，由底層nemo引擎來保證線程安全，線程分為11種：

• PikaServer：主線程
• DispatchThread：監(jiān)聽端口1個端口，接收用戶連接請求
• ClientWorker：存在多個（用戶配置），每個線程里有若干個用戶客戶端的連接，負(fù)責(zé)接收處理用戶命令并返回結(jié)果，每個線程執(zhí)行寫命令后，追加到binlog中
• Trysync：嘗試與master建立首次連接，并在以后出現(xiàn)故障后發(fā)起重連
• ReplicaSender：存在多個（動態(tài)創(chuàng)建銷毀，本master節(jié)點(diǎn)掛多少個slave節(jié)點(diǎn)就有多少個），每個線程根據(jù)slave節(jié)點(diǎn)發(fā)來的同步偏移量，從binlog指定的偏移開始實(shí)時同步命令給slave節(jié)點(diǎn)
• ReplicaReceiver：存在1個（動態(tài)創(chuàng)建銷毀，一個slave節(jié)點(diǎn)同時只能有一個master），將用戶指定或當(dāng)前的偏移量發(fā)送給master節(jié)點(diǎn)并開始接收執(zhí)行master實(shí)時發(fā)來的同步命令，在本地使用和master完全一致的偏移量來追加binlog
• SlavePing：slave用來向master發(fā)送心跳進(jìn)行存活檢測
• bgsave：后臺dump線程
• HeartBeat：master用來接收所有slave發(fā)送來的心跳并回復(fù)進(jìn)行存活檢測
• scan：后臺掃描keyspace線程
• purge：后臺刪除binlog線程