前言

MongoShake是阿里云以Golang語(yǔ)言編寫的通用平臺(tái)型服務(wù)工具，它通過(guò)讀取MongoDB的Oplog操作日志來(lái)復(fù)制MongoDB的數(shù)據(jù)以實(shí)現(xiàn)特定需求。

MongoShake還提供了日志數(shù)據(jù)的訂閱和消費(fèi)功能，可通過(guò)SDK、Kafka、MetaQ等方式的靈活對(duì)接，適用于日志訂閱、數(shù)據(jù)中心同步、Cache異步淘汰等場(chǎng)景。

官方地址：https://github.com/alibaba/MongoShake

使用場(chǎng)景

• MongoDB集群間數(shù)據(jù)的異步復(fù)制，免去業(yè)務(wù)雙寫開銷（數(shù)據(jù)災(zāi)備）；
• MongoDB集群間數(shù)據(jù)的鏡像備份（當(dāng)前1.0開源版本支持受限）；
• 日志離線分析；
• 日志訂閱；
• 數(shù)據(jù)路由，根據(jù)業(yè)務(wù)需求，結(jié)合日志訂閱和過(guò)濾機(jī)制，可以獲取關(guān)注的數(shù)據(jù)，達(dá)到數(shù)據(jù)路由的功能；
• Cache同步。日志分析的結(jié)果，知道哪些Cache可以被淘汰，哪些Cache可以進(jìn)行預(yù)加載，反向推動(dòng)Cache的更新；
• 基于日志的集群監(jiān)控

基于mongoshake可以衍生出很多的場(chǎng)景，從而提供給開發(fā)者在架構(gòu)設(shè)計(jì)中更多更靈活、更豐富的選擇

搭建步驟

mongoshake本身的使用不難，這個(gè)參考官方的配置即可，主要是根據(jù)自身的業(yè)務(wù)場(chǎng)景做好配置文件中各個(gè)參數(shù)的配置即可達(dá)到目的，下面以mongoshake一個(gè)較為常用的場(chǎng)景，即使用mongoshanke完成2個(gè)mongodb復(fù)制集群之間的數(shù)據(jù)同步

環(huán)境準(zhǔn)備

• 兩臺(tái)服務(wù)器（阿里云、騰訊云服務(wù)器或虛擬機(jī)）
• 提前規(guī)劃相關(guān)的端口，并開放相關(guān)端口
• 提前下載mongodb以及mongoshake安裝包，兩臺(tái)服務(wù)器均上傳，本次mongodb版本為：mongodb-linux-x86_64-4.0.10.tgz，mongo-shake-v2.4.6.tar.gz

一、搭建mongodb復(fù)制集

選擇其中一臺(tái)服務(wù)器搭建一個(gè)mongodb的單機(jī)版復(fù)制集群，這里使用端口號(hào)區(qū)分，啟動(dòng)的時(shí)候啟動(dòng)多個(gè)實(shí)例即可（有條件的可以采用3個(gè)不同的服務(wù)器操作），按照下面的步驟依次執(zhí)行即可：

1、創(chuàng)建3個(gè)目錄