對於檢視未分發的命令數，我們通常這樣檢視。

然而當伺服器有很多釋出時，一個個開啟檢視就很麻煩

當然，如果想用指令碼檢視就更方便了，執行下面的語句

--檢視各發布訂閱未分發的命令數和估計時間
SELECT  'EXEC distribution.sys.sp_replmonitorsubscriptionpendingcmds @publisher = N'''
        + a.publisher + ''', @publisher_db = N''' + a.publisher_db
        + ''', @publication = N''' + a.publication + ''', @subscriber = N'''
        + c.name + ''', @subscriber_db = N''' + b.subscriber_db
        + ''', @subscription_type =' + CAST(b.subscription_type AS VARCHAR)
FROM    distribution.dbo.MSreplication_monitordata a ( NOLOCK )
INNER JOIN (
	SELECT   publication_id ,subscriber_id ,subscriber_db ,subscription_type
	FROM     distribution.dbo.MSsubscriptions (NOLOCK)
	GROUP BY publication_id ,subscriber_id ,subscriber_db ,subscription_type
) b ON a.publication_id = b.publication_id
INNER JOIN sys.servers c ( NOLOCK ) ON b.subscriber_id = c.server_id
WHERE   a.agent_type = 1
 

EXEC distribution.sys.sp_replmonitorsubscriptionpendingcmds 
@publisher = N'釋出伺服器'
, @publisher_db = N'釋出資料庫'
, @publication = N'釋出名稱'
, @subscriber = N'訂閱伺服器'
, @subscriber_db = N'訂閱資料庫'
, @subscription_type =0

/***************************************************************************/
/***************************************************************************/
 

但是，由於監控需要，只想統計所有釋出未分發的命令數“ pendingcmdcount”的總和，

本來想用下面這個方法把各個儲存過程的返回值插入到臨時表，但是沒有這種方法！！

CREATE TABLE #countab(pendingcmdcount int,estimatedprocesstime int)

INSERT INTO #countab(pendingcmdcount,estimatedprocesstime)
EXEC distribution.sys.sp_replmonitorsubscriptionpendingcmds 
@publisher = N'釋出伺服器'
, @publisher_db = N'釋出資料庫'
, @publication = N'釋出名稱'
, @subscriber = N'訂閱伺服器'
, @subscriber_db = N'訂閱資料庫'
, @subscription_type =0
 

實際伺服器有本地的連結伺服器，但是沒顯示出來，也用不了。雖然可以建立其他命名的，但不想建立太多連結伺服器。

於是想到更改系統的儲存過程！！~錯了，是參考系統儲存過程建立一個幾乎一樣定義的儲存過程。

即不需要distribution.sys.sp_replmonitorsubscriptionpendingcmds ，建立類似的dbo.sp_getsubscriptionpendingcmds ，如下

create procedure dbo.sp_getsubscriptionpendingcmds   
(  
    @publisher sysname -- cannot be null  
    ,@publisher_db sysname -- cannot be null  
    ,@publication sysname -- cannot be null  
    ,@subscriber sysname -- cannot be null  
    ,@subscriber_db sysname -- cannot be null  
    ,@subscription_type int
    ,@pendingcmdcount int output 
)  
as  
begin  
    set nocount on  
	declare @retcode int  
	,@agent_id int  
	,@publisher_id int  
	,@subscriber_id int  
	,@lastrunts timestamp  
	,@xact_seqno varbinary(16)  
	
	,@inactive int = 1  
	,@virtual int = -1  
 
    select @publisher_id = server_id from sys.servers where upper(name) = upper(@publisher)  
    select @subscriber_id = server_id from sys.servers where upper(name) = upper(@subscriber)  
    
    select @agent_id = id  
    from distribution.dbo.MSdistribution_agents   
    where publisher_id = @publisher_id   
        and publisher_db = @publisher_db  
        and publication in (@publication, 'ALL')  
        and subscriber_id = @subscriber_id  
        and subscriber_db = @subscriber_db  
        and subscription_type = @subscription_type  


    ;with dist_sessions (start_time, runstatus, timestamp)  
    as(  
        select start_time, max(runstatus), max(timestamp)   
        from distribution.dbo.MSdistribution_history  
        where agent_id = @agent_id  
        group by start_time   
    )  
    select @lastrunts = max(timestamp) from dist_sessions where runstatus in (2,3,4);  
    
    if (@lastrunts is null)  
    begin  
        if exists (
			select * from distribution.dbo.MSpublications p 
			inner join distribution.dbo.MSsubscriptions s on p.publication_id = s.publication_id  
			where p.publisher_id = @publisher_id   
			and p.publisher_db = @publisher_db  
			and p.publication = @publication  
			and p.immediate_sync = 1  
			and s.status = @inactive and s.subscriber_id = @virtual)   
        begin  
			select 'pendingcmdcount' = 0, N'estimatedprocesstime' = 0  
			return 0  
		end  
        
        select @lastrunts = max(timestamp) from distribution.dbo.MSdistribution_history where agent_id = @agent_id  
    end  

    select @xact_seqno = xact_seqno from distribution.dbo.MSdistribution_history where agent_id = @agent_id  and timestamp = @lastrunts  

    select @xact_seqno = isnull(@xact_seqno, 0x0)  


    DECLARE @countab TABLE ( pendingcmdcount int ) 
    insert into @countab (pendingcmdcount)  
        exec @retcode = distribution.sys.sp_MSget_repl_commands   
                                    @agent_id = @agent_id  
                                    ,@last_xact_seqno = @xact_seqno  
                                    ,@get_count = 2  
                                    ,@compatibility_level = 9000000  
    if (@retcode != 0 or @@error != 0)  
        return 1  

    select @pendingcmdcount=pendingcmdcount from @countab  

    return @pendingcmdcount
end  

上面的儲存過程主要更改3個地方，然後在其他一個數據庫執行，頁可在distribution執行。

1. 多一個返回引數，@pendingcmdcount int output ，返回未分發的命令數

2. 估計時間不需要，去掉

3. 查詢的每個表或內部儲存過程加資料庫字首distribution

接下來再用一個儲存過程把所有值加起來，給計數器！

新建一個作業，定時每分鐘執行，觀察效能計數器統計情況。

這樣也可以再cacti捕獲了！~