程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> 其他數據庫知識 >> 更多數據庫知識 >> SSB(SQLservice Service Broker) 入門實例介紹

SSB(SQLservice Service Broker) 入門實例介紹

編輯:更多數據庫知識

step 1:perpar database & data
復制代碼 代碼如下:
use master
go
Create database Inventory
go
use Inventory
go
Create table inventory
(
    TitleId nvarchar(6) not null,
    Quantity int not null,
    primary key (TitleId,Quantity)
);
go

insert inventory values ('pc1001',100);
insert inventory values ('pc1002',200);
insert inventory values ('pc1003',300);
insert inventory values ('pc1004',400);


step 2: 創建整個SSB的基礎框架.

 首先創建信息類型
復制代碼 代碼如下:
Create Message Type [//mark/v10/types/inventory]
Create Message Type [//mark/v10/types/inventoryresponse]

創建合約
復制代碼 代碼如下:
Create contracts [//mark/v10/contracts/inventorycontract]
(
    [//mark/v10/types/inventory] send by initiator,
    [//mark/v10/types/inventoryresponse] send by target 
);


創建隊列與服務

復制代碼 代碼如下:
create queue [inventory client queue];
create service [//mark/v10/services/inventory client]
    on queue [inventory client queue]

    go
    --create inventory service
    create queue [inventory queue];
    create service [//mark/v10/services/inventory]
    on queue [inventory queue]
    (
        [//mark/v10/contracts/inventorycontract]
    );


step 3:發送消息到消息隊列中

復制代碼 代碼如下:
use Inventory
go
--send message
begin transaction
    declare @dialog_id uniqueidentifier
    begin dialog conversation @dialog_id
        from service [//mark/v10/services/inventory client]
        to service '//mark/v10/services/inventory'
        on contract [//mark/v10/contracts/inventorycontract]
        with encryption = off;
        send on conversation @dialog_id message type [//mark/v10/types/inventory]
        (
        '<InventoryUpdate>
        <TitleId>pc1001</TitleId>
        <Quantity>102</Quantity>
        </InventoryUpdate>'   
        );
        commit transaction;

發送成功後,可以查詢 inventory_queue
復制代碼 代碼如下:
select conversation_handle, cast(message_body as xml) as conversation_body from [Inventory queue]

這裡只是查詢了兩列。
 
其中conversation_body 就是 我們發出的信息了。

 setp 4: 從 inventory queue 中獲取信息並更新數據

復制代碼 代碼如下:
use inventory
go
begin transaction
    declare @dialog_id uniqueidentifier
    declare @message_body xml
    declare @amount int;
    declare @title nvarchar(128);

    receive
        @dialog_id = conversation_handle,
        @message_body = message_body
    from [dbo].[Inventory queue]

    print 'handle is' + cast(@dialog_id as nvarchar(90))
    print 'message body is' + cast(@message_body as  nvarchar(max) )
    if(@dialog_id is not null)
    begin
        set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
        set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
        print 'a:'+cast(@amount as nvarchar(100))
        print 'b:'+@title;

        Update inventory set Quantity = @amount where TitleId = @title;
        end
        end conversation @dialog_id;
    commit transaction;

操作成功後再去查詢inventory queue的表 猶豫裡面的數據已經被receive 出來 就為空了。

數據同時被更新了



step 5: 接下來做個自動監聽功能,只要有信息發送到隊列,相關隊列,就可以自動執行功能.

首先建立個存儲過程,(把receive 中的那段代碼拿過來就可以了)
復制代碼 代碼如下:
use Inventory
go
--create procedure to receive message and update table
create proc InventoryProc as

begin transaction
    declare @dialog_id uniqueidentifier
    declare @message_body xml
    declare @amount int;
    declare @title nvarchar(128);

    waitfor(
    receive
        @dialog_id = conversation_handle,
        @message_body = message_body
    from [dbo].[Inventory queue]),timeout 5000;

    print 'handle is' + cast(@dialog_id as nvarchar(90))
    print 'message body is' + cast(@message_body as  nvarchar(max) )
    if(@dialog_id is not null)
    begin
        set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
        set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
        print 'a:'+cast(@amount as nvarchar(100))
        print 'b:'+@title;

        Update inventory set Quantity = @amount where TitleId = @title;
        end
        end conversation @dialog_id;
    commit transaction;
    go

隊列監聽
復制代碼 代碼如下:
alter queue [inventory queue]
        with activation(
            status = on,
            procedure_name=    InventoryProc,
            max_queue_readers=2,
            execute as self
        );

        go

完成後,只要發送隊列信息後,就可以了

PS: 我們定義了 兩個隊列 還有個 inventory client queue

這個隊列保存的是成功或者error 提示。用receive 方法也可以提取出來。
復制代碼 代碼如下:
select message_type_name from [Inventory client queue]

 

以上的 message type  service 等信息   如圖所示,都在這裡.

以上是SSB的入門實例,以後會再寫一篇實際應用上的(以上的sql code 都是純手工輸入,可能還存在錯誤(雖然校驗了兩遍),如果發生錯誤,對不起大家了。)

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved