在transactional replication中，在publication中执行了一个更新，例如：update table set col=? Where ?，如果table中含有大量的数据行，那么该操作会产生大量数据更新操作。在subscription端，这个更新操作会分解成多条command（默认情况下产生一个Transaction，每个数据行产生一个Command）。Distribution Agent包含两个子进程，Reader和Writer。 Reader负责从 Distribution 数据库中读取数据，Writer负责将reader读取的数据写入到订阅数据库。Reader是通过 sys.sp_MSget_repl_commands 来读取Distribution数据库中（读取Msrepl_transactions表和Msrepl_Commands表）的数据。
CREATE PROCEDURE sys.sp_MSget_repl_commands ( @agent_id int, @last_xact_seqno varbinary(16), @get_count tinyint = 0, -- 0 = no count, 1 = cmd and tran (legacy), 2 = cmd only @compatibility_level int = 7000000, @subdb_version int = 0, @read_query_size int = -1 )
1，在Distribution Agent同步数据到Subscriber中时，发现Subscriber中有很多Session处于 ASYNC_NETWORK_IO，说明该Session返回的数据集太大，导致Writer不能及时将Command读取，使用Distribution Latency增加，该Session正在执行的sp是：sys.sp_MSget_repl_commands，正在执行的语句如下，这条查询用于返回Distribution Agent读取的Commands。
select rc.xact_seqno, rc.partial_command, rc.type,
rc.command_id, rc.command, rc.hashkey,
-- extra columns for the PeerToPeer resultset
-- originator_id, srvname, dbname, originator_publication_id, originator_db_version, originator_lsn
NULL, NULL, NULL, NULL, NULL, NULL, rc.article_id
from
MSrepl_commands rc with (nolock, INDEX(ucMSrepl_commands))
JOIN dbo.MSsubscriptions s with (INDEX(ucMSsubscriptions))
-- At end, we use the FASTFIRSTROW option which tends to force
-- a nested inner loop join driven from MSrepl_commands
ON (rc.article_id = s.article_id)
where
s.agent_id = @agent_id and
rc.publisher_database_id = @publisher_database_id and
rc.xact_seqno > @last_xact_seqno and
rc.xact_seqno <= @max_xact_seqno and
(rc.type & @snapshot_bit) <> @snapshot_bit and
(rc.type & ~@snapshot_bit) not in ( 37, 38 )
and (@compatibility_level >= 9000000
or (rc.type & ~@postcmd_bit) not in (47))
order by rc.xact_seqno, rc.command_id asc
OPTION (FAST 1)
通过SQL Server Profile抓取当前正在执行的SQL，从抓取的大量语句中发现，一般只会用到前四个参数，第三个和第四个参数的值是固定不变的，分别是0和10000000。
exec sp_MSget_repl_commands 74,0x0008ECE200307E10014C00000000,0,10000000
2，Distribution Agent 读取的Commnd数量
sys.sp_MSget_repl_commands 返回的Result Set的大小跟变量 @max_xact_seqno 有关
rc.xact_seqno > @last_xact_seqno and rc.xact_seqno <= @max_xact_seqno
对变量 @max_xact_seqno 的赋值，是由 @read_query_size 参数控制的，在调用该sp时，其值是默认值-1。下面代码表示 将 dbo.MSrepl_commands 最大的 xact_seqno 赋值给变量@max_xact_seqno，那么Distribution Agent 每次都会读取所有的Command。
--Note4: The max_xact_seqno is calculated based on the @read_query_size parameter --- this parameter limit the number of commands retrieved by this call. if(@read_query_size <= 0)
begin
select @max_xact_seqno = max(xact_seqno) from MSrepl_commands with (READPAST)
where
publisher_database_id = @publisher_database_id and
command_id = 1 and
type <> -2147483611
end
else
begin
-- calculate the @max_xact_seqno from the next @read_query_size commands.
declare @GetMaxCommand nvarchar(1024)
select @GetMaxCommand = N‘select top ‘ + convert(nvarchar(1024),@read_query_size)+
N‘ @max_xact_seqno = xact_seqno from MSrepl_commands with (READPAST)
where
publisher_database_id = @publisher_database_id and
type <> -2147483611 and
xact_seqno > @last_xact_seqno
order by xact_seqno, command_id asc‘
exec sys.sp_executesql
@GetMaxCommand,
N‘@max_xact_seqno varbinary(16) output ,@last_xact_seqno varbinary(16),@publisher_database_id int‘,
@publisher_database_id = @publisher_database_id,
@max_xact_seqno = @max_xact_seqno output,
@last_xact_seqno=@last_xact_seqno
if(@max_xact_seqno is null)
select @max_xact_seqno = @last_xact_seqno
end
3，为@read_query_size传递一个参数值，而不是使用默认值 -1，由于该sp是system stored procedure，不能直接修改，而Distribution Agent profile中也没有参数能够控制Reader读取的Command数量。
参考文档：
SQL Server复制系列4 – Transactional replication中如何跳过一个事务