C#中如何监控数据库的会话和阻塞？使用什么DMV？

来源：这里教程网时间：2026-02-21 17:26:17 作者：

在C#中监控SQL Server数据库的会话和阻塞，通常通过查询系统动态管理视图（DMV）来实现。你可以使用 SqlConnection 和 SqlCommand 执行查询，获取当前会话、阻塞信息以及等待资源的情况。

常用的DMV用于监控会话和阻塞

sys.dm_exec_sessions：提供所有会话的信息，如会话ID、登录名、连接时间等。 sys.dm_exec_requests：显示当前正在执行的请求，包括等待类型、阻塞会话ID（blocking_session_id）、等待资源等。 sys.dm_os_waiting_tasks：显示当前被阻塞或等待资源的任务，可用来识别阻塞链。 sys.dm_tran_locks：显示当前事务持有的锁信息，帮助分析锁冲突。 sys.dm_exec_sql_text：配合request_id或sql_handle，获取正在执行的SQL语句文本。 sys.dm_exec_connections：查看连接详情，如客户端地址、连接时间等。

C# 示例：检测阻塞会话

以下是一个简单的C#代码片段，用于查询当前存在阻塞的会话：

using System;
using System.Data.SqlClient;
<p>class Program
{
static void Main()
{
string connectionString = "Server=your_server;Database=master;Integrated Security=true;";</p><pre class='brush:php;toolbar:false;'>    using (var conn = new SqlConnection(connectionString))
    {
        conn.Open();
        string sql = @"
            SELECT 
                wt.session_id,
                wt.blocking_session_id,
                wt.wait_duration_ms,
                wt.wait_type,
                st.text AS waiting_sql,
                bt.text AS blocking_sql,
                s.login_name,
                s.host_name
            FROM sys.dm_os_waiting_tasks wt
            INNER JOIN sys.dm_exec_sessions s ON wt.session_id = s.session_id
            INNER JOIN sys.dm_exec_requests wr ON wt.session_id = wr.session_id
            CROSS APPLY sys.dm_exec_sql_text(wr.sql_handle) st
            LEFT JOIN sys.dm_exec_requests br ON wt.blocking_session_id = br.session_id
            OUTER APPLY sys.dm_exec_sql_text(br.sql_handle) bt
            WHERE wt.blocking_session_id IS NOT NULL
            ORDER BY wt.wait_duration_ms DESC";
        using (var cmd = new SqlCommand(sql, conn))
        {
            using (var reader = cmd.ExecuteReader())
            {
                while (reader.Read())
                {
                    Console.WriteLine($"会话 {reader["session_id"]} 被 {reader["blocking_session_id"]} 阻塞");
                    Console.WriteLine($"等待时长: {reader["wait_duration_ms"]}ms");
                    Console.WriteLine($"等待类型: {reader["wait_type"]}");
                    Console.WriteLine($"被阻塞SQL: {reader["waiting_sql"]}");
                    Console.WriteLine($"阻塞者SQL: {reader["blocking_sql"]}");
                    Console.WriteLine("---");
                }
            }
        }
    }
}

}