Mongodb的入門（8）mongodb事物分析

老生常談：<在前面博客中也介紹過>

　　mongodb官網：https://docs.mongodb.com/manual/introduction/

　　mongodb：官網上是這樣定義的MongoDB is an open-source document database that provides high performance, high availability, and automatic scaling.翻譯成中文：是一個開源文檔數據庫，提供高性能，高可用性和自動擴展。

      mongodb4：

　　　　　1  >　MongoDB CTO Eliot Horowitz 剛剛於2月16日凌晨在MongoDB西雅圖大會上宣佈，MongoDB將在4.0版本中正式推出多文檔ACID事務支持 。

                2 >  「MongoDB 4.0 將支持多文檔事務，屆時MongoDB將成爲惟一可以同時支持速度，靈活性，JSON文檔模型優點和ACID數據完整性保證的數據庫。經過快照隔離，（MongoDB）的事務可以提供一個全局一致的數據視圖，

　　　　　　　　　　並能夠實現all-or-nothing的事務提交及回滾機制，保證數據的完整性。」

  　　　 　3 >   這個功能的支持，徹底不亞於2014年MongoDB引入WiredTiger存儲引擎的影響力。由於這個功能的引入，原計劃是3.8版本的MongoDB將直接進入4.0時代。

　　　　   4 >　ACID 多文檔事務，能夠理解爲關係型數據庫的多行事務。在關係型的事務支持中，你們幾乎無一例外支持同一事務內操做的原子性，即要麼所有提交，要麼所有回滾。這個同一事務內能夠有多個操做，針對於多個表，或者是同一個表內的多行數據。

　　注意：我在以前就介紹過mongodb之前也是有事務的，不過事物是在單文檔操做上存在事務。如今介紹的是mongodb的多文檔的原子事務

---

 

介紹：

　　mongodb 的事務是依靠 mongodb 鏈接的客戶端 session 實現，事務執行的流程大體是 創建 session，經過 session startTransaction 啓動事務，若是一系列事務都完成，那麼 commitTransaction 完成事務操做，並結束當前事務 session；若是一系列事務中有任意事件失敗， 那麼 　abortTransaction 停止事務，內部將已完成的任務回退到修改以前，並結束當前事務 session。

　　

 

　　事務和副本集(Replica Sets)

　　　　副本集是 MongoDB 的一種主副節點架構，它使數據獲得最大的可用性，避免單點故障引發的整個服務不能訪問的狀況的發生。目前 MongoDB 的多表事務操做僅支持在副本集上運行，想要在本地環境安裝運行副本集能夠藉助一個工具包——run-rs，

　　　　如下的文章中有詳細的使用說明：https://thecodebarbarian.com/

　　事務和會話(Sessions)

　　　　事務和會話(Sessions)關聯，一個會話同一時刻只能開啓一個事務操做，當一個會話斷開，這個會話中的事務也會結束。

　　事務中的函數

• Session.startTransaction()

　　　　在當前會話中開始一次事務，事務開啓後就能夠開始進行數據操做。在事務中執行的數據操做是對外隔離的，也就是說事務中的操做是原子性的。

• Session.commitTransaction()

　　　　提交事務，將事務中對數據的修改進行保存，而後結束當前事務，一次事務在提交以前的數據操做對外都是不可見的。

• Session.abortTransaction()

　　　　停止當前的事務，並將事務中執行過的數據修改回滾。

　　重試

　　　　當事務運行中報錯，catch 到的錯誤對象中會包含一個屬性名爲 errorLabels 的數組，當這個數組中包含如下2個元素的時候，表明咱們能夠從新發起相應的事務操做。

• TransientTransactionError：出如今事務開啓以及隨後的數據操做階段
• UnknownTransactionCommitResult：出如今提交事務階段

 

---

 

mongo模擬事務實現:

　　mongodb的多文檔事務是基於副本集或者分片實現的，那我如今來簡單再搭建一個mongo4 的副本集集羣（你們還記得副本集和主從複製的區別嗎？不知道的能夠參考 Mongodb的入門（6）副本集 ）

　　下面我再搭建一下副本集，後期不會再搭建，請你們注意搭建步驟：

　　第一步：建立一個mongodb副本集的文件夾：E:\mongdb4

　　　　在裏面建立三個文件夾：分別是1688,1689,1690  這樣我會把響應的端口號也設置成1688,1689,1690。

　　　　

 

　　第二步：　在每一個文件夾下放入響應的mongodb服務。若是已經安裝直接拷貝過來便可：

　　　　

　　　　注意。這步要作一下處理，由於你不是最新安裝的，裏面可能會有數據或日誌。

　　　　　

　　　第三步：假設你已經處理好三個文件夾的文件，日誌等數據都已經刪除。環境已經乾淨。　

　　　　下面我來作副本集：

　　　　　　1》 建立是哪一個文件夾來保存數據

　　　　　　　　

　　　　　　2> 分別進入各個bin下執行以下命令：

　　　　　　　　 mongod.exe --replSet shard1 --dbpath=E:\mongdb4\data\1688 --port=1688

　　　　　　　　mongod.exe --replSet shard1 --dbpath=E:\mongdb4\data\1689 --port=1689

　　　　　　　　mongod.exe --replSet shard1 --dbpath=E:\mongdb4\data\1690 --port=1690

　　　　　　執行以後會有：

　　　　　　　　

 

　　　第四步：配置副本集

　　　　任意進入一個bin下，鏈接到mongo上測試   mongo.exe  --port=1688　

　　　　　　

　　　　　

　　　　　　rsconf = {_id: "shard1", members: [ { _id: 0, host: "127.0.0.1:1688" } ] }
　　　　　　rs.initiate( rsconf )
　　　　　　rs.add("127.0.0.1:1689")
　　　　　　rs.add("127.0.0.1:1690")

　　　　　到這副本集就配置完成了。再介紹幾個命令用於維護副本集

　　　　　　rs.isMaster();  查看是否是主節點

　　　　　　rs.status();  查看副本集的狀態。以下：

　　　　　　

　　　　　　

　

---

springboot操做副本集：

　　　環境搭建，不介紹了，假設環境已經搭建好了。如：

　　　　　

　　第一步:配置mongo鏈接信息：

　　　　　

　　第二步測試：

　　　　　　　　

　　　

/**
     * @author huhy
     * @ClassName:SpringbootMongodb4ApplicationTests
     * @date 2018/11/23 11:26 
     * @Description: 測試事務
     */
    @Test
    public void testTro(){
        int a = 1000;
        //獲取ClientSession
        ClientSession clientSession = mongoClient.startSession();
        Money yang = mongoTemplate.findById("12", Money.class);
        Money hui = mongoTemplate.findById("13", Money.class);
        int pay = yang.getPay()- a;
        hui.setPay(pay);
        yang.setPay(pay);
        try {
            //開啓事務
            clientSession.startTransaction();
            //爲mongoTemplate注入的事務特性
            MongoTemplate mongoTemplate = this.mongoTemplate.withSession(clientSession);
            mongoTemplate.save(hui);
            mongoTemplate.save(yang);
            if (pay < 0 ){
                System.out.println("abortTransaction");
                //撤銷事務
                clientSession.abortTransaction();
            }
        } catch (Exception e) {
            //提交事務
            clientSession.commitTransaction();
            e.printStackTrace();
        }
    }

note：注意：springboot 操做mongo時候，要注意：有兩種事務的特性：
　　　　

1》MongoTemplate mongoTemplate = this.mongoTemplate.withSession(clientSession);
2》 在文檔級別注入：
　　

  我在這提醒一下你們。基於文檔纔是原生的，mongTemplate是爲了方便咱們使用才用的。

 

 3》有一部分基於mongo的註解在實體上，我就不貼出來了，有興趣的能夠本身搞一下。