科技行者

行者学院 转型私董会 科技行者专题报道 网红大战科技行者

知识库

知识库 安全导航

至顶网软件频道基于Service Broker的异步消息传递(1)

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

  • 扫一扫
    分享文章到微信

  • 扫一扫
    关注官方公众号
    至顶头条

这里演示同一个SQL Server中不同数据库之间的基于Service Broker的异步消息传递,其中Stored Procedure充当Service Program。HelloWorldDB为目标数据库,DotNetFun2则为消息发送发的数据库。

作者:Rickie Lee 来源:互联网 2007年9月12日

关键字: 异步消息 数据库 SQL Server SQL Server 各版本

  • 评论
  • 分享微博
  • 分享邮件
 

这里演示同一个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,具体操作可以参考《SQL Server 2005 Beta 2 Service Broker: Create 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中消息的状态。

    • 评论
    • 分享微博
    • 分享邮件
    邮件订阅

    如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。

    重磅专题
    往期文章
    最新文章