4、最后一个对象是路由,但它是可选的。路由只有在数据库服务器之间发送消息时才是必须的。路由与接收消息服务的本地副本器密不可分。如果服务器接收的消息是另外一个使用数据库镜像的服务器的镜像,那么就必须使用一个MIRROR_ADDRESS参数。如果想让路由自动删除,那么可以设置LIFETIME标志。
WITH SERVICE_NAME = '[tcp://SearchSQLServer/SampleService]',
BROKER_INSTANCE = 'AB2F3EB9-6662-4AAF-8682-A9A48C3BDD3B',
ADDRESS = 'TCP://RemoteServer:8888',
MIRROR_ADDRESS = 'TCP://MirrorServer:8888'
BROKER_INSTANCE参数是service_broker_guid字段的值,它来自远程服务器上的数据库的sys.databases视图。
为了实现队列之间的消息发送,必须使用两个命令。第一个是BEGIN DIALOG命令,然后是SEND命令。使用BEGIN DIALOG命令在发送和接收服务器之间来创建一个会话。如果使用一个已有的会话,那么就不需要使用BEGIN DIALOG命令。在使用BEGIN DIALOG命令创建了新的会话之后,就可以用SEND命令在会话上发送消息,其中消息的发送是通过BEGIN DIALOG命令返回的句柄实现。
@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循环用来处理程序的一次运行中的队列上的所有消息。
@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,会话结束了。这个结束会话消息必须由发送队列处理以便
将数据从队列中删除。建议在发送队列上使用基本程序来自动清除这些消息。
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
完成这个程序之后,当消息到达时,可以通过QUEUE的ACTIVATION命令来使用ALTER QUEUE命令设置一个队列自动地运行该程序。你可以设置程序的并行执行数目,将MAX_QUEUE_READERS设置为大于1。在高负荷的系统中,或当处理花费一定时间时,附加队列读取器可以通过并行方式加速数据处理。
WITH ACTIVATION (STATUS=ON,
PROCEDURE_NAME = dbo.usp_ProcessAck,
MAX_QUEUE_READERS = 2,
EXECUTE AS SELF)
SQL Server Service Broker的安装可能有点复杂,并且在因特网上相关的文档也不是很多。但是,一旦安装并正确运行了服务代理,它可以提供一个坚如磐石的内部或外部数据库通信平台,实现系统之间数据的快速一致发送。