【TechTarget中国原创】BROKER_INSTANCE参数是service_broker_guid字段的值，它来自远程服务器上的sys.databases 数据库视图。
在队列之间发送消息，我们必须使用两个命令：第1个是BEGIN DIALOG命令，然后是SEND命令。使用BEGIN DIALOG命令来在发送和接收服务之间创建一个会话。如果我们使用一个已经存在的会话，那么我们就不需要使用BEGIN DIALOG命令。在使用BEGIN DIALOG命令创建了一个新的会话之后，通过使用BEGIN DIALOG命令返回的会话句柄，我们就可以使用SEND命令在会话上发送消息。
DECLARE/font> @dialog_handle UNIQUEIDENTIFIER,
@XMLData XML ;
SET @XMLData = (SELECT * FROM sys.tables FOR XML AUTO)
BEGIN DIALOG @dialog_handle
FROM SERVICE [tcp://SearchSQLServer/SampleService]
TO SERVICE 'tcp://SearchSQLServer/SampleService'
ON CONTRACT [tcp://SearchSQLServer/SampleContract];
SEND ON CONVERSATION @dialog_handle
MESSAGE TYPE [tcp://SearchSQLServer/SampleMessageType]
(@XMLData); |
可以使用RECEIVE命令来查看和处理消息。RECEIVE命令与SELECT很相似，它们都返回数据。然而，当使用RECEIVE命令时，消息只能接收一次。在消息被接收之后，如果它是会话的最后一个消息——大多数人在会话中只是输入一个消息——那么，使用END CONVERSATION命令来关闭它。RECEIVE命令可以与WAITFOR命令一起使用，而WHILE循环则在一个运行过程的队列中处理所有消息。
DECLARE @dialog_handle UNIQUEIDENTIFIER,
@XMLData XML ;
RECEIVE TOP (1) @dialog_handle = conversation_handle, @XMLData =
CAST(message_body AS XML)
FROM [tcp://SearchSQLServer/SampleQueue]
END CONVERSATION @dialog_handle
SELECT @XMLData |
当结束会话时，事实上会有一个消息从接收队列发送到发送队列来通知发送队列、服务和SQL Server会话已经关闭了。这个结束会话的消息必须由发送队列来处理，以便从队列删除数据。我们建议在发送队列上使用一个基本过程来自动清除这些消息。
CREATE PROCEDURE usp_ProcessAck
AS
DECLARE @xml AS XML
DECLARE @dialog_handle as uniqueidentifier
WHILE 1=1
SET @dialog_handle = NULL
WAITFOR ( RECEIVE TOP (1) @dialog_handle = conversation_handle, @xml =
cast(message_body as xml)
FROM [tcp://SearchSQLServer/SampleQueue]), TIMEOUT 1000
IF @dialog_handle IS NULL
break
END CONVERSATION @dialog_handle
END
GO |
在我们创建了这个过程之后，再使用ALTER QUEUE来创建队列来自动地在消息到达时通过使用QUEUE的ACTIVATION命令自动运行该过程。我们可以通过设置MAX_QUEUE_READERS大于1来设置过程的并行执行数目。在繁重负荷的系统中，或者当处理花费一段时间时，额外的队列读取程序可以通过并行队列的数据处理来加速数据处理。
ALTER QUEUE [tcp://SearchSQLServer/SampleQueue]
WITH ACTIVATION (STATUS=ON,
PROCEDURE_NAME = dbo.usp_ProcessAck,
MAX_QUEUE_READERS = 2,
EXECUTE AS SELF) |
SQL Server Service Broker的配置可能很复杂，同时在因特网上关于它的文档也不多。然而，一旦配置并且正确地运行了Service Broker，那么它可以提供一个坚实的内部数据库或者外部数据库通信平台来快速一致地在系统之间发送数据。