C#中如何监控数据库的会话和阻塞？使用什么DMV？-C#.Net教程-PHP中文网

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

幻夢星雲

发布： 2025-09-21 08:46:02

原创

1026人浏览过

答案：通过C#查询SQL Server的DMV可监控会话与阻塞。使用SqlConnection执行如sys.dm_os_waiting_tasks等视图联合查询，获取阻塞会话、等待时长、SQL语句等信息，并结合定时任务持续监控，需VIEW SERVER STATE权限。

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

在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("---");
                }
            }
        }
    }
}

登录后复制

}