Service Broker基礎(chǔ)應(yīng)用(上）

作者：邀月 2011-05-06 15:37:10

本文主要涉及Service Broker的基本概念及建立一個(gè)Service Broker應(yīng)用程序的基本步驟。

導(dǎo)讀：本文主要涉及Service Broker的基本概念及建立一個(gè)Service Broker應(yīng)用程序的基本步驟。

一、前言：

Service Broker為SQL Server提供消息隊(duì)列，這提供了從數(shù)據(jù)庫中發(fā)送異步事務(wù)性消息隊(duì)列的方法。Service Broker消息可以保證以適當(dāng)?shù)捻樞蚧蛟嫉陌l(fā)送順序不重復(fù)地一次性接收。并且因?yàn)閮?nèi)建在SQL Server中，這些消息在數(shù)據(jù)庫發(fā)生故障時(shí)是可以恢復(fù)的，也可以隨數(shù)據(jù)庫一起備份。在SQL Server 2008中，還引入了使用Create Broker Priority命令對會話設(shè)定優(yōu)先級，可以對重要的或不重要的會話進(jìn)行優(yōu)先級設(shè)定，以保證消息合理地處理。

本文假定一個(gè)在線數(shù)據(jù)庫BookStore中存儲了一些業(yè)務(wù)訂單。我們使用Service Broker應(yīng)用程序?qū)⑾l(fā)送到另一個(gè)數(shù)據(jù)庫BookDistribution，該數(shù)據(jù)庫是分離的應(yīng)用程序調(diào)用，該應(yīng)用程序控制倉庫入庫和出庫交付，并返回消息給BookStore。

創(chuàng)建Service Broker應(yīng)用程序大體步驟如下：

1、定義希望應(yīng)用程序執(zhí)行的異步任務(wù)。

2、確定Service Broker的發(fā)起方服務(wù)和目標(biāo)服務(wù)是否創(chuàng)建在同一個(gè)SQL Server實(shí)例中。如果是兩個(gè)實(shí)例，實(shí)例間的通信還需要?jiǎng)?chuàng)建經(jīng)過證書認(rèn)證或NT安全的身份認(rèn)證，并且要?jiǎng)?chuàng)建端點(diǎn)、路由以及對話安全模式。

3、如果沒有啟用，則在多方參與的數(shù)據(jù)庫中使用Alter Database命令設(shè)置Enable_broker以及Truseworthy數(shù)據(jù)庫選項(xiàng)。

4、為所有多方參與的數(shù)據(jù)庫創(chuàng)建數(shù)據(jù)庫主密鑰。

5、創(chuàng)建希望在服務(wù)之間發(fā)送的消息類型。

6、創(chuàng)建契約（Contract）來定義可以由發(fā)起方發(fā)送的各種消息以及由目標(biāo)發(fā)送的消息類型的種類。

7、同時(shí)在兩方參與的數(shù)據(jù)庫中創(chuàng)建用于保存消息的隊(duì)列。

8、同時(shí)在綁定特定約定到特定隊(duì)列的多方參與的數(shù)據(jù)庫中創(chuàng)建服務(wù)。

二、實(shí)例

下面我們通過一個(gè)示例來實(shí)現(xiàn)以上步驟：

（一）、啟用數(shù)據(jù)庫的Service Broker活動(dòng)

-- Enabling Databases for Service Broker Activity

USE master
GO
IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = 'BookStore')
CREATE DATABASE BookStore
GO
IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = 'BookDistribution')
CREATE DATABASE BookDistribution
GO
ALTER DATABASE BookStore SET ENABLE_BROKER
GO
ALTER DATABASE BookStore SET TRUSTWORTHY ON
GO
ALTER DATABASE BookDistribution SET ENABLE_BROKER
GO
ALTER DATABASE BookDistribution SET TRUSTWORTHY ON

（二）、創(chuàng)建數(shù)據(jù)庫主密鑰

-- Creating the DatabaseMaster Key for Encryption

USE BookStore
GO
CREATE MASTER KEY
ENCRYPTION BY PASSWORD = 'I5Q7w1d3'
GO

USE BookDistribution
GO
CREATE MASTER KEY
ENCRYPTION BY PASSWORD = 'D1J3q5z8X6y4'
GO

（三）、管理消息類型

使用CREATE MESSAGE TYPE（http://msdn.microsoft.com/en-us/library/ms187744.aspx）命令,

-- Managing Message Types

Use BookStore
GO
-- 發(fā)送圖書訂單的消息類型
CREATE MESSAGE TYPE [//SackConsulting/SendBookOrder]
VALIDATION = WELL_FORMED_XML
GO

--目標(biāo)數(shù)據(jù)庫發(fā)送的消息類型
CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived]
VALIDATION = WELL_FORMED_XML
GO

--執(zhí)行同樣的定義
Use BookDistribution
GO
-- 發(fā)送圖書訂單的消息類型
CREATE MESSAGE TYPE [//SackConsulting/SendBookOrder]
VALIDATION = WELL_FORMED_XML
GO

--目標(biāo)數(shù)據(jù)庫發(fā)送的消息類型
CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived]
VALIDATION = WELL_FORMED_XML
GO

--注意，此處沒有定義消息的內(nèi)容。實(shí)際的消息是消息類型的實(shí)例。

（四）、創(chuàng)建契約（Contract）

使用Create Contract（http://msdn.microsoft.com/en-us/library/ms178528.aspx）

-- Creating Contracts

Use BookStore
GO
CREATE CONTRACT
[//SackConsulting/BookOrderContract]
( [//SackConsulting/SendBookOrder]
SENT BY INITIATOR,
[//SackConsulting/BookOrderReceived]
SENT BY TARGET
)
GO

USE BookDistribution
GO
CREATE CONTRACT
[//SackConsulting/BookOrderContract]
( [//SackConsulting/SendBookOrder]
SENT BY INITIATOR,
[//SackConsulting/BookOrderReceived]
SENT BY TARGET
)
GO

--發(fā)起方和目標(biāo)的定義必須相同

（五）、創(chuàng)建隊(duì)列

隊(duì)列用來保存數(shù)據(jù)。使用命令Create queue（http://msdn.microsoft.com/en-us/library/ms190495.aspx）

-- Creating Queues

Use BookStore
GO
--保存BookDistribution過來的消息
CREATE QUEUE BookStoreQueue
WITH STATUS=ON
GO

USE BookDistribution
GO
--保存BookStore過來的消息
CREATE QUEUE BookDistributionQueue
WITH STATUS=ON
GO

（六）、創(chuàng)建服務(wù)

服務(wù)定義端點(diǎn)，然后使用它來將消息隊(duì)列綁定到一個(gè)或多個(gè)契約上。服務(wù)使用隊(duì)列和契約來定義一個(gè)或一組任務(wù)。有點(diǎn)拗口，是不是？

服務(wù)是消息的發(fā)起方和接收方強(qiáng)制約定的規(guī)則，并將消息路由到正確的序列。

使用Create Service（http://msdn.microsoft.com/en-us/library/ms190332.aspx）命令。

-- Creating Services

Use BookStore
GO
CREATE SERVICE [//SackConsulting/BookOrderService]
ON QUEUE dbo.BookStoreQueue--指定的隊(duì)列綁定到契約
([//SackConsulting/BookOrderContract])
GO

USE BookDistribution
GO
CREATE SERVICE [//SackConsulting/BookDistributionService]
ON QUEUE dbo.BookDistributionQueue--指定的隊(duì)列綁定到契約
([//SackConsulting/BookOrderContract])
GO

（七）、啟動(dòng)對話

對話會話（dialog conservation）是在服務(wù)之間進(jìn)行消息交換的操作。

使用Begin Dialog Conversation（http://msdn.microsoft.com/en-us/library/ms187377.aspx）命令創(chuàng)建新的會話。使用Send（http://msdn.microsoft.com/en-us/library/ms188407.aspx）來發(fā)送消息。使用End Conversation命令（http://msdn.microsoft.com/en-us/library/ms177521.aspx）結(jié)束會話。

-- Initiating a Dialog

Use BookStore
GO

--保存會話句柄和訂單信息
DECLARE @Conv_Handler uniqueidentifier
DECLARE @OrderMsg xml;

BEGIN DIALOG CONVERSATION @Conv_Handler--創(chuàng)建會話
FROM SERVICE [//SackConsulting/BookOrderService]
TO SERVICE '//SackConsulting/BookDistributionService'
ON CONTRACT [//SackConsulting/BookOrderContract];
SET @OrderMsg =
'<order id="3439" customer="22" orderdate="2/15/2011">
<LineItem ItemNumber="1" ISBN="1-59059-592-0" Quantity="1" />
</order>';
SEND ON CONVERSATION @Conv_Handler--發(fā)送到BookDistribution數(shù)據(jù)庫的隊(duì)列中
MESSAGE TYPE [//SackConsulting/SendBookOrder]
(@OrderMsg);

（八）、查詢隊(duì)列中傳入的消息

-- Querying the Queue for IncomingMessages

USE BookDistribution
GO
SELECT message_type_name, CAST(message_body as xml) message,
queuing_order, conversation_handle, conversation_group_id
FROM dbo.BookDistributionQueue

查詢結(jié)果：

（九）、檢索并響應(yīng)消息

使用Receive語句（http://msdn.microsoft.com/en-us/library/ms186963.aspx）從隊(duì)列中讀取行（消息），也可以刪除已經(jīng)讀取的消息。Receive的結(jié)果可以填充到常規(guī)表中，也可以在局部變量中執(zhí)行其他操作，或發(fā)送到其他service Broker消息。如果消息是XML數(shù)據(jù)類型的消息，則可以直接借助TSQL的XQuery來操作。

-- Receiving and Responding to aMessage

USE BookDistribution
GO
--創(chuàng)建一個(gè)表存放接收到的訂單信息
CREATE TABLE dbo.BookOrderReceived
(BookOrderReceivedID int IDENTITY (1,1) NOT NULL,
conversation_handle uniqueidentifier NOT NULL,
conversation_group_id uniqueidentifier NOT NULL,
message_body xml NOT NULL)
GO

-- 聲明變量
DECLARE @Conv_Handler uniqueidentifier
DECLARE @Conv_Group uniqueidentifier
DECLARE @OrderMsg xml
DECLARE @TextResponseMsg varchar(8000)
DECLARE @ResponseMsg xml
DECLARE @OrderID int;

--從隊(duì)列中獲取消息，將接收值賦于局部變量
RECEIVE TOP(1) @OrderMsg = message_body,--TOP指定最多一條消息
@Conv_Handler = conversation_handle,
@Conv_Group = conversation_group_id
FROM dbo.BookDistributionQueue;

-- 將變量值插入表中
INSERT dbo.BookOrderReceived
(conversation_handle, conversation_group_id, message_body)
VALUES
(@Conv_Handler,@Conv_Group, @OrderMsg )

-- 使用XQuery進(jìn)行抽取以響應(yīng)消息訂單
SELECT @OrderID = @OrderMsg.value('(/order/@id)[1]', 'int' )
SELECT @TextResponseMsg =
'<orderreceived id= "' +
CAST(@OrderID as varchar(10)) +
'"/>';
SELECT @ResponseMsg = CAST(@TextResponseMsg as xml);

-- 使用既有的會話句柄，發(fā)送響應(yīng)消息到發(fā)起方
SEND ON CONVERSATION @Conv_Handler
MESSAGE TYPE [//SackConsulting/BookOrderReceived]

（十）、結(jié)束會話

-- Ending a Conversation

USE BookStore
GO
-- 創(chuàng)建訂單確認(rèn)表
CREATE TABLE dbo.BookOrderConfirmation
(BookOrderConfirmationID int IDENTITY (1,1) NOT NULL,
conversation_handle uniqueidentifier NOT NULL,
DateReceived datetime NOT NULL DEFAULT GETDATE(),
message_body xml NOT NULL)

DECLARE @Conv_Handler uniqueidentifier
DECLARE @Conv_Group uniqueidentifier
DECLARE @OrderMsg xml
DECLARE @TextResponseMsg varchar(8000);

RECEIVE TOP(1) @Conv_Handler = conversation_handle,
@OrderMsg = message_body
FROM dbo.BookStoreQueue

INSERT dbo.BookOrderConfirmation
(conversation_handle, message_body)
VALUES (@Conv_Handler,@OrderMsg );

END CONVERSATION @Conv_Handler;
GO

USE BookDistribution
GO
DECLARE @Conv_Handler uniqueidentifier
DECLARE @Conv_Group uniqueidentifier
DECLARE @OrderMsg xml
DECLARE @message_type_name nvarchar(256);

RECEIVE TOP(1) @Conv_Handler = conversation_handle,
@OrderMsg = message_body,
@message_type_name = message_type_name
FROM dbo.BookDistributionQueue

-- 雙方必須都結(jié)束會話
IF
@message_type_name = 'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
BEGIN
END CONVERSATION @Conv_Handler;
END

--查詢會話狀態(tài)

SELECT state_desc, conversation_handle
FROM sys.conversation_endpoints

三、小結(jié)

本文通過一個(gè)實(shí)例演示了一個(gè)用來發(fā)送圖書訂單消息分發(fā)控制數(shù)據(jù)庫的簡單的消息交換應(yīng)用程序。發(fā)起方發(fā)送圖書訂單，發(fā)回一個(gè)響應(yīng)，并在兩個(gè)數(shù)據(jù)庫上使用END Conservation結(jié)束會話?，F(xiàn)實(shí)場景中可以轉(zhuǎn)換為其他消息類型、契約、服務(wù)和隊(duì)列。合理運(yùn)用Service Broker應(yīng)用程序的異步特性可以防止因應(yīng)用程序掛起而導(dǎo)致業(yè)務(wù)系統(tǒng)產(chǎn)生瓶頸。

原文鏈接：http://www.cnblogs.com/downmoon/archive/2011/04/05/2005900.html

【編輯推薦】