[ASP.NET] 使用Lock鎖定在多使用者或多執行緒下新增編號確保編號不重複

2012-06-07

35037
0
ASP.NET (C#)
2012-12-07

摘要:[ASP.NET] 使用Lock鎖定在多使用者或多執行緒下新增編號確保編號不重複

前言

執行專案中常常出現的一個功能就是使用者要新增流水編號，而建立流水編號的方法大部分都是從資料表中取得最大編號加1再新增回去，但撰寫新增流水編號時常常可能一不小心而忘記考慮當有眾多使用者同時在建立資料時會同時取得同樣的編號後新增入資料庫，而造成編號重複的情況發生。

為了防止這種情況的發生我們可以使用 Lock 陳述式、交易隔離等級等方法來處理，

接下來就來看看使用Lock 陳述式該如何處理。

範例

Lock 陳述式

lock 關鍵字可將陳述式區塊標記為關鍵區段 (Critical Section)，其做法是為指定的物件取得互斥鎖定、執行陳述式，接著釋出該鎖定。

用法如下:

Object thisLock = new Object();
lock (thisLock)
{
    // Critical code section
}

thisLock 是用來判斷物件是否處於獨佔狀態，必須是參考型別的物件，

於 Lock 區段內稱之為關鍵區段，如有程式運行到Lock區段內後，當期他的程式想要存取此區段程式時將被要求等待Lock區段內的程式運行完成後才可進入，

接下來我實際建立一個網站測式，

Step 1

建立一個空白網站
於網站中新增一個精簡的SQL Server資料庫名為db.mdf
建立一新網頁頁面名為Default.aspx
Default.aspx 輸入以下HTML碼:

    <asp:Label ID="Label1" runat="server" Text="測試Lock陳述式"></asp:Label>
    <br /> <br />
    <asp:Button ID="btnNonLock" runat="server" Text="無Lock新增資料" 
        onclick="btnNonLock_Click" />
    <asp:Button ID="btnLock" runat="server" Text="有Lock新增資料" 
        onclick="btnLock_Click" />
    <br />
    <asp:Button ID="btnQry" runat="server" Text="查詢資料表" onclick="btnQry_Click" />
    <asp:Button ID="btnClearDB" runat="server" Text="清空資料表" 
        onclick="btnClearDB_Click" />
    <br />
    <asp:GridView ID="GridView1" runat="server" AutoGenerateColumns="False" 
        DataKeyNames="ProNo" DataSourceID="SqlDataSource1">
        <Columns>
            <asp:BoundField DataField="ProNo" HeaderText="ProNo" ReadOnly="True" 
                SortExpression="ProNo" />
            <asp:BoundField DataField="ProName" HeaderText="ProName" 
                SortExpression="ProName" />
        </Columns>
    </asp:GridView>
    <asp:SqlDataSource ID="SqlDataSource1" runat="server" 
        ConnectionString="<%$ ConnectionStrings:ConnectionString %>" 
        SelectCommand="SELECT * FROM [Product]"></asp:SqlDataSource>

Step 2

由於我需要模擬多使用者的情況，所以在這邊我始用多執行緒去模擬，

於 Default.aspx.cs 中加入以下程式碼:

建立一個提供給 Lock 的物件

    // 提供Lock鎖定的物件
    private static object thisLock = new object();

    protected void Page_Load(object sender, EventArgs e)
    {
    }

在我的測試中提供了兩種測試: 1. 無Lock新增 2.有Lock新增

    /// 
    /// 未鎖定新增按鈕事件
    /// 
    protected void btnNonLock_Click(object sender, EventArgs e)
    {
        for (int i = 0; i < 20; i++)
        {
            Thread thread = new Thread(new ParameterizedThreadStart(NonLockInsert));
            thread.Start(i);
        }
    }

    /// 
    /// 鎖定新增按鈕事件
    /// 
    protected void btnLock_Click(object sender, EventArgs e)
    {
        for (int i = 0; i < 20; i++)
        {
            Thread thread = new Thread(new ParameterizedThreadStart(LockInsert));
            thread.Start(i);
        }
    }

    /// 
    /// 查詢資料按鈕事件
    /// 
    protected void btnQry_Click(object sender, EventArgs e)
    {
        GridView1.DataBind();
    }

    /// 
    /// 清除資料按鈕事件
    /// 
    protected void btnClearDB_Click(object sender, EventArgs e)
    {
        using (SqlConnection myConnection = new SqlConnection(SqlDataSource1.ConnectionString))
        {
            SqlCommand myCommand = new SqlCommand();
            myCommand.Connection = myConnection;
            myCommand.CommandText = "Delete From Product";
            myConnection.Open();
            myCommand.ExecuteNonQuery();
        }
        GridView1.DataBind();
    }

    /// 
    /// 未鎖定新增方法
    /// 
    private void NonLockInsert(object i)
    {
        using (SqlConnection myConnection = new SqlConnection(SqlDataSource1.ConnectionString))
        {
            SqlCommand myCommand = new SqlCommand();
            myCommand.Connection = myConnection;
            myCommand.CommandText = "Insert Product (ProNo,ProName) values (@ProNo,@ProName)";
            myCommand.Parameters.AddWithValue("@ProNo", GetProductSerialNumber());
            myCommand.Parameters.AddWithValue("@ProName", "Product_" + i);
            myConnection.Open();
            myCommand.ExecuteNonQuery();
        }
    }

    /// 
    /// 鎖定新增方法
    /// 
    private void LockInsert(object i)
    {
        
        lock (thisLock)
        {
            using (SqlConnection myConnection = new SqlConnection(SqlDataSource1.ConnectionString))
            {
                SqlCommand myCommand = new SqlCommand();
                myCommand.Connection = myConnection;
                myCommand.CommandText = "Insert Product (ProNo,ProName) values (@ProNo,@ProName)";
                myCommand.Parameters.AddWithValue("@ProNo", GetProductSerialNumber());
                myCommand.Parameters.AddWithValue("@ProName", "Product_" + i);
                myConnection.Open();
                myCommand.ExecuteNonQuery();
            }
        }
    }

    /// 
    /// 取得產品最大編號
    /// 
    private string GetProductSerialNumber()
    {
        using (SqlConnection myConnection = new SqlConnection(SqlDataSource1.ConnectionString))
        {
            SqlCommand myCommand = new SqlCommand();
            myCommand.Connection = myConnection;
            myCommand.CommandText = "Select ISNULL(Max(ProNo),0) From Product";
            myConnection.Open();
            string MaxNumber = myCommand.ExecuteScalar().ToString().Trim();
            if (MaxNumber == "0")
                return DateTime.Now.ToString("yyyyMMdd") + "01";
            else
            {
                int sn = int.Parse(MaxNumber.Substring(8, 2));
                sn++;
                string fsn = "0" + sn;
                return DateTime.Now.ToString("yyyyMMdd") + fsn.Substring(fsn.Length - 2);
            }
        }
    }

在上面的程式理簡單撰寫了兩種不同的新增方法，實際在測試後就可以發現其中的分別，

先測試無Lock時，當多人同時操作新增資料表時的情況，先點選「無Lock新增資料」後在點選「查詢資料」。