redis源碼分析之事務Transaction（下）

来源:http://www.cnblogs.com/lfls/archive/2017/11/14/7835335.html
-Advertisement-
Play Games

接著上一篇，這篇文章分析一下redis事務操作中multi，exec，discard三個核心命令。 原文地址：http://www.jianshu.com/p/e22615586595 看本篇文章前需要先對上面文章有所瞭解： "redis源碼分析之事務Transaction（上）" 一、redis事 ...


接著上一篇，這篇文章分析一下redis事務操作中multi，exec，discard三個核心命令。

原文地址：http://www.jianshu.com/p/e22615586595

看本篇文章前需要先對上面文章有所瞭解：
redis源碼分析之事務Transaction（上）

一、redis事務核心命令簡介

redis事務操作核心命令：

    //用於開啟事務
    {"multi",multiCommand,1,"sF",0,NULL,0,0,0,0,0},
    //用來執行事務中的命令
    {"exec",execCommand,1,"sM",0,NULL,0,0,0,0,0},
    //用來取消事務
    {"discard",discardCommand,1,"sF",0,NULL,0,0,0,0,0},

在redis中，事務並不具有ACID的概念，換句話說，redis中的事務僅僅是保證一系列的命令按順序一個一個執行，如果中間失敗了，並不會進行回滾操作。

使用redis事務舉例如下：

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a
QUEUED
127.0.0.1:6379> set b b
QUEUED
127.0.0.1:6379> set c c
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) OK
127.0.0.1:6379>

二、redis事務核心命令源碼分析

關於事務的幾個命令所對應的函數都放在multi.c文件中。

首先來看一下multi命令，該命令用於標記客戶端開啟事務狀態，因此它做的就是修改客戶端狀態，代碼很簡單，如下：

void multiCommand(client *c) {
    //如果客戶端已經是事務模式，則返回錯誤提示信息
    if (c->flags & CLIENT_MULTI) {
        addReplyError(c,"MULTI calls can not be nested");
        return;
    }
    //設置客戶端為事務模式
    c->flags |= CLIENT_MULTI;
    //返回結果
    addReply(c,shared.ok);
}

接下來看下redis處理命令邏輯中的一段源碼：
這段代碼在server.c文件中的processCommand方法中：

    //如果客戶端處於事務狀態且當前執行的命令不是exec，discard，multi跟watch命令中的一個
    //則把當前命令加入一個隊列
    if (c->flags & CLIENT_MULTI &&
        c->cmd->proc != execCommand && c->cmd->proc != discardCommand &&
        c->cmd->proc != multiCommand && c->cmd->proc != watchCommand)
    {
        //加入隊列
        queueMultiCommand(c);
        //返回結果
        addReply(c,shared.queued);
    } else {
        //執行當前命令
        call(c,CMD_CALL_FULL);
        c->woff = server.master_repl_offset;
        if (listLength(server.ready_keys))
            handleClientsBlockedOnLists();
    }

看入隊操作源碼前，先來熟悉幾個數據結構，redis會把每個連接的客戶端封裝成一個client對象，該對象中含有大量欄位用來保存需要的信息，發佈訂閱功能也使用對應的欄位進行存儲，事務當然也不例外，如下：

//每個客戶端對象中有一個mstate欄位用來保存事務上下文
typedef struct client {
    multiState mstate; 
}

//事務包裝類型
typedef struct multiState {
    //當前事務中需要執行的命令數組
    multiCmd *commands; 
    //需要執行的命令數量
    int count;          
    //需要同步複製的最小數量
    int minreplicas;       
    //同步複製超時時間
    time_t minreplicas_timeout; 
} multiState;

//事務中執行命令的封裝類型
typedef struct multiCmd {
    //參數
    robj **argv;
    //參數數量
    int argc;
    //命令本身
    struct redisCommand *cmd;
} multiCmd;

瞭解了基本的數據結構以後，再來看下入隊操作：

void queueMultiCommand(client *c) {
    //類型前面有說明
    multiCmd *mc;
    int j;
    //擴容，每次擴容一個命令的大小
    c->mstate.commands = zrealloc(c->mstate.commands,
            sizeof(multiCmd)*(c->mstate.count+1));
    //c++中給數組最後一個元素賦值語法實在是有點難懂...
    mc = c->mstate.commands+c->mstate.count;
    //初始化mc各個欄位
    mc->cmd = c->cmd;
    mc->argc = c->argc;
    mc->argv = zmalloc(sizeof(robj*)*c->argc);
    //把參數一個一個拷貝過來
    memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc);
    for (j = 0; j < c->argc; j++)
        incrRefCount(mc->argv[j]);
    c->mstate.count++;
}

上面是把命令加入事務命令數組的中的邏輯，由於在執行事務過程中也會執行刪除事務的操作，因此在看執行事務邏輯之前我們先看下刪除事務的實現原理。

當事務執行完成，執行錯誤或者客戶端想取消當前事務，都會跟discard命令有聯繫，一起看下源碼：

void discardCommand(client *c) {
    //如果當前客戶端沒有處於事務狀態，則返回錯誤信息
    if (!(c->flags & CLIENT_MULTI)) {
        addReplyError(c,"DISCARD without MULTI");
        return;
    }
    //刪除事務
    discardTransaction(c);
    //返回結果
    addReply(c,shared.ok);
}

//具體的刪除邏輯
void discardTransaction(client *c) {
    //釋放客戶端事務資源
    freeClientMultiState(c);
    //初始化客戶端事務資源
    initClientMultiState(c);
    //狀態位還原
    c->flags &= ~(CLIENT_MULTI|CLIENT_DIRTY_CAS|CLIENT_DIRTY_EXEC);
    //取消已watch的key，該函數上面文章中已經進行過分析，不贅述
    unwatchAllKeys(c);
}

//釋放事務隊列中的每個命令
void freeClientMultiState(client *c) {
    int j;
    for (j = 0; j < c->mstate.count; j++) {
        int i;
        multiCmd *mc = c->mstate.commands+j;
        //挨個釋放命令的參數
        for (i = 0; i < mc->argc; i++)
            decrRefCount(mc->argv[i]);
        zfree(mc->argv);
    }
     //最後釋放命令本身
    zfree(c->mstate.commands);
}

//事務相關欄位設為初始值
void initClientMultiState(client *c) {
    c->mstate.commands = NULL;
    c->mstate.count = 0;
}

到這裡，我們已經瞭解了開啟事務模式，把各個命令加入到事務命令執行數組中以及取消事務三個模塊的執行原理，最後一起看下事務的執行過程，代碼較長，需要慢慢看。

把一系列命令加入到事務命令數組中以後，客戶端執行exec命令就可以把其中的所有命令挨個執行完成了，分析exec命令源碼之前，我們應該可以想到redis的邏輯應該就是從客戶端的事務命令數組中取出所有命令一個一個執行，源碼如下：

void execCommand(client *c) {
    int j;
    robj **orig_argv;
    int orig_argc;
    struct redisCommand *orig_cmd;
    //標記是否需要把MULTI/EXEC傳遞到AOF或者slaves節點
    int must_propagate = 0; 
    //標記當前redis節點是否為主節點
    int was_master = server.masterhost == NULL;
    //如果客戶端沒有處於事務狀態，則返回錯誤提示信息
    if (!(c->flags & CLIENT_MULTI)) {
        addReplyError(c,"EXEC without MULTI");
        return;
    }

    //首先對兩個需要終止當前事務的條件進行判斷
    //1.當有WATCH的key被修改時則終止，返回一個nullmultibulk對象
    //2.當之前有命令加入事務命令數組出錯則終止，例如傳入的命令參數數量不對，會返回execaborterr
    if (c->flags & (CLIENT_DIRTY_CAS|CLIENT_DIRTY_EXEC)) {
        addReply(c, c->flags & CLIENT_DIRTY_EXEC ? shared.execaborterr :
                                                  shared.nullmultibulk);
        //刪除當前事務信息，前面已經分析過，不贅述
        discardTransaction(c);
        goto handle_monitor;
    }

    //把watch的key都刪除，上面文章已經分析過，不贅述
    unwatchAllKeys(c); 
    //保存當前命令上下文
    orig_argv = c->argv;
    orig_argc = c->argc;
    orig_cmd = c->cmd;
    addReplyMultiBulkLen(c,c->mstate.count);
    //遍歷事務命令數組
    for (j = 0; j < c->mstate.count; j++) {
        //把事務隊列中的命令參數取出賦值給client，因為命令是在client維度執行的
        c->argc = c->mstate.commands[j].argc;
        c->argv = c->mstate.commands[j].argv;
        c->cmd = c->mstate.commands[j].cmd;

        //同步事務操作到AOF或者集群中的從節點
        if (!must_propagate && !(c->cmd->flags & (CMD_READONLY|CMD_ADMIN))) {
            execCommandPropagateMulti(c);
            must_propagate = 1;
        }
        //執行具體命令
        call(c,CMD_CALL_FULL);

        //由於命令可以修改參數的值或者數量，因此重新保存命令上下文
        c->mstate.commands[j].argc = c->argc;
        c->mstate.commands[j].argv = c->argv;
        c->mstate.commands[j].cmd = c->cmd;
    }
    //恢複原始命令上下文
    c->argv = orig_argv;
    c->argc = orig_argc;
    c->cmd = orig_cmd;
    //事務執行完成，刪除該事務，前面已經分析過，不贅述
    discardTransaction(c);

    //確保EXEC會進行傳遞
    if (must_propagate) {
        int is_master = server.masterhost == NULL;
        server.dirty++;
        if (server.repl_backlog && was_master && !is_master) {
            char *execcmd = "*1\r\n$4\r\nEXEC\r\n";
            feedReplicationBacklog(execcmd,strlen(execcmd));
        }
    }
//monitor命令操作
handle_monitor:
    if (listLength(server.monitors) && !server.loading)
        replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc);
}

上面就是事務命令執行的整個邏輯，可以先排除集群跟AOF的同步邏輯，專註理解核心邏輯，代碼整體邏輯算是比較清晰的，搞明白了前面的幾個模塊以後，再看執行邏輯就不會太難。

三、redis事務命令總結

通過上、下兩篇文章對redis事務各個命令進行了分析，仔細閱讀應該可以瞭解整個事務執行框架，如果有任何問題或者疑惑，歡迎留言評論。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 判斷滾動條滑到底部觸發事件
    $(document).on("scroll", function () { //真實內容的高度 var pageHeight = Math.max(document.body.scrollHeight, document.body.offsetHeight); //視窗的高度 var viewpo ...
  • 開發中使用UEditor編輯器的註意事項
    最近在一個剛結束的一個項目中使用到了UEditor編輯器，下麵總結一下遇到的問題以及使用時需要註意的地方： 1. 使用UEditor插件需要先對其進行路徑配置： 在ueditor.config.js文件中 配置 ueditor.config.js文件相對Ueditor文件夾的位置； 2. UEdit ...
  • 開始bootstrap的學習
    終於過完雙十一，伺服器頂住了壓力，不知道為啥，突然的輕鬆，反而感覺有點無所適從，好久沒寫博客了，竟然發現還有人回我，很是開心，問題都是關於阿裡雲的，阿裡雲的吭確實多，其實關鍵在於，官方文檔還是少，出了問題，很多都要靠自己去嘗試，自己去找方法。 好了，今天開始學習bootstrap，自己本身是後端出身 ...
  • 幾款開發 CSS 最好的前端開發工具
    緊跟任何開發工具包的更新都是一件需要持續努力的事，特別是前端開發工具。 把你的註意力從方法和技術的洪流中移開一會，你就可能會錯過什麼！ 上周我遇到我的一個前端開發朋友，他很興奮地跟我談論他使用的一些新工具。其中最有意思的是使用 Grunt 來編譯 SCSS。 人們很容易忘記不是每個人都和你走在同一條 ...
  • css:段落文本兩端對齊
    效果圖： Css: ...
  • sass 常用用法筆記
    最近公司開發的h5項目，需要用到sass，所以領導推薦讓我去阮一峰大神的SASS用法指南博客學習，為方便以後自己使用，所以在此記錄。 一、代碼的重用 1、繼承：SASS允許一個選擇器，繼承另一個選擇器。 class2要繼承class1，就要使用@extend命令： 2、Mixin：Mixin有點像C ...
  • 使用springboot完成密碼的加密解密
    現今對於大多數公司來說，信息安全工作尤為重要，就像京東，阿裡巴巴這樣的大公司來說，信息安全是最為重要的一個話題，舉個簡單的例子： 就像這樣的密碼公開化，很容易造成一定的信息的泄露。所以今天我們要講的就是如何來實現密碼的加密和解密來提高數據的安全性。 在這首先要引入springboot融合mybati ...
  • Oracle 11g不能導出空表的三種解決方法
    http://www.pinhuba.com/oracle/101128.htm ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類