mongoDB 4.0事務回滾的辛酸歷程探究
前言
主管前幾天發現mongoDB已經升級到4.0了,迫不及待得讓我實現他期待已久的事務回滾,發現還是有很多坑啊!
下面是我將已有的本地mongoDB升級到支援事務回滾的歷程,分享出來,有錯誤的地方歡迎指正!
以mac為例哈
部署mongodb事務回滾
1.準備工作
升級mongodb至4.0.0
$ brew upgrade mongodb
升級或安裝mongodb.js v3.1.0 以上
$ npm i mongodb --save-dev
坑
升級完上述後,db.js裡連線mongo時,
會警告,讓你在connect的option里加一個欄位
useNewUrlParser:true
這時如果有使用者驗證,還需要在connect的option裡再加一個欄位
authSource:使用者所在的db,一般為admin
否則會報驗證失敗,找不到使用者的錯誤,比如
const mongoClient = await MongoClient.connect(mongoClientUrl,{ auth: { user: config.dbUserName,password: config.dbUserPassword,},authSource:'admin',useNewUrlParser:true,});
2.將已有的資料庫改造成複製集
目前事務回滾只能在複製集上操作,單獨的mongodb server是不能操作事務的
關掉所有的mongod
在平時啟動mongod的命令後新增--replSet rs0,比如
$ mongod -dbpath ./db --port 27017 --replSet rs0
再開個shell,創一個不同埠的mongo例項,比如
$ mongod -dbpath ./db_repl --port 27018 --replSet rs0
連線27017的mongo例項,並設定
$ mongo $ rs.initiate() $ rs.add('localhost:27018');
完成
3.寫回滾程式碼
在db.js裡新增了一個方法
export const getSession = async function() { return await state.mongoClient.startSession(); };
每次在需要回滾的mongo程式碼前呼叫這個方法拿到session,開始回滾的標記
const session = await db.getSession(); session.startTransaction({ readConcern: {level: 'snapshot'},writeConcern: {w: 'majority'},});
在每次呼叫mongodb.js的方法操作資料庫時,都要帶上session,比如
db .collection(this.collecitonName) .insertOne(doc,{session});
在你處理錯誤並覺得需要回滾了,執行
await session.abortTransaction();
在你覺得沒問題,一起正常結束時,執行
await session.commitTransaction();
我的程式碼裡可能有一些封裝的程式碼沒有放上去,導致不一定能理解。我只是舉個栗子去實現,具體的程式碼實現可以看參考連結1
4.總結
useNewUrlParser這個屬性會在url裡識別驗證使用者所需的db,未升級前是不需要指定的,升級到一定要指定,不管是在url後面,還是用authSource
事務回滾只能在複製集上操作,我猜測實現的原理可能是這樣:先記錄主節點的session,然後回滾的話,通過這個session查詢副節點的資料快照,然後將這快照再應用到主節點上,實現回滾。當然,實際情況應該相當複雜,不然mongoDB也不會用3年時間來實現這個操作。
5.參考連結
- mongoDB官方關於事務的介紹
- mongoDB中文社群關於replSet的介紹
- 如果不想進行第二步,run-rs可以直接為你建立一個新的mongoDB複製集
總結
以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對我們的支援。