您的位置: 贵州信息网 > 历史

解析:基于Service Broker的异步消息传递(1)

发布时间:2019-09-13 20:34:33

本文演示的是同一个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 HelloWorldDBGOAlter Procedure HelloWorldResponderAsBeginDeclare @conversationHandle UNIQUEIDENTIFIERDeclare @message_body nvarchar(MAX)Declare @message_type_name SYSNAMEWHILE (1=1)BEGINBEGIN TRANSACTION-- Wait for 1 seconds for messages to arriveWAITFOR (-- For simplicity we process one message at a timeRECEIVE TOP(1)@message_type_name=message_type_name,@conversationHandle=conversation_handle,@message_body=message_bodyFROM [ReceivingQueue]), TIMEOUT 1000-- If a message was received, process it, else skipIF (@@rowcount <= 0)BREAK;-- If this is a XML message,-- respond with an appropriate greetingIF @message_type_name = 'XMLMessage'BEGINSEND ON CONVERSATION @conversationHandleMESSAGE TYPE XMLMessage('<hello>Hello From Rickie</hello>')END CONVERSATION @conversationHandleENDCOMMITENDCOMMITENDGO

该Stored Procedure负责从ReceivingQueue中检索消息,并根据Queue的Retention设置,来确定从Queue中移除消息或更新Queue中消息的状态。 2.设置目标队列(Target Queue)的激活机制 Use HelloWorldDBgoALTER QUEUE [ReceivingQueue] WITHACTIVATION (STATUS = ON, -- Turn on internal activationPROCEDURE_NAME = [HelloWorldResponder], -- Our stored procMAX_QUEUE_READERS = 4, -- Up to 4 concurrent readersEXECUTE AS SELF) -- Execute as user of incoming dialog

设置上述创建的Stored Procedure,该Stored Procedure将被激活并处理Queue中的消息。

小孩积食用什么药好
小孩发烧40度怎么办怎样退烧快
小便黄是什么症状
小孩咳嗽有痰吃什么好
猜你会喜欢的
猜你会喜欢的