本文演示的是同一个SQL Server中不同数据库之间的基于Service Broker的异步消息传递，其中Stored Procedure充当Service Program。HelloWorldDB为目标数据库。
本文演示的是同一个SQL Server中不同数据库之间的基于Service Broker的异步消息传递，其中Stored Procedure充当Service Program。HelloWorldDB为目标数据库，DotNetFun2则为消息发送发的数据库。
同时，假设Server Broker的基本对象类型已经创建，如MessageType(XMLMessage), Contract(XMLContract), Queue(SendingQueue and ReceivingQueue)等等，具体操作可以参考《A simple tutorial on SQL Server 2005 Beta 2 Service Broker》。另外，因为在不同的Databases之间进行消息传递，因此需要创建Route。
1.创建Stored Procedure作为Internal Service Program。
USE HelloWorldDB
GO
Alter Procedure HelloWorldResponder
As
Begin
Declare @conversationHandle UNIQUEIDENTIFIER
Declare @message_body nvarchar(MAX)
Declare @message_type_name SYSNAME
WHILE (1=1)
BEGIN
BEGIN TRANSACTION
-- Wait for 1 seconds for messages to arrive
WAITFOR (
-- For simplicity we process one message at a time
RECEIVE TOP(1)
@message_type_name=message_type_name,
@conversationHandle=conversation_handle,
@message_body=message_body
FROM [ReceivingQueue]), TIMEOUT 1000
-- If a message was received, process it, else skip
IF (@@rowcount <= 0)
BREAK;
-- If this is a XML message,
-- respond with an appropriate greeting
IF @message_type_name = 'XMLMessage'
BEGIN
SEND ON CONVERSATION @conversationHandle
MESSAGE TYPE XMLMessage
('<hello>Hello From Rickie</hello>')
END CONVERSATION @conversationHandle
END
COMMIT
END
COMMIT
END
GO |
该Stored Procedure负责从ReceivingQueue中检索消息，并根据Queue的Retention设置，来确定从Queue中移除消息或更新Queue中消息的状态。
2.设置目标队列（Target Queue）的激活机制
Use HelloWorldDB
go
ALTER QUEUE [ReceivingQueue] WITH
ACTIVATION (
STATUS = ON, -- Turn on internal activation
PROCEDURE_NAME = [HelloWorldResponder], -- Our stored proc
MAX_QUEUE_READERS = 4, -- Up to 4 concurrent readers
EXECUTE AS SELF) -- Execute as user of incoming dialog |
设置上述创建的Stored Procedure，该Stored Procedure将被激活并处理Queue中的消息。
京公网安备 11010802021500号