关闭 x
IT技术网
    技 采 号
    ITJS.cn - 技术改变世界
    • 实用工具
    • 菜鸟教程
    IT采购网 中国存储网 科技号 CIO智库

    IT技术网

    IT采购网
    • 首页
    • 行业资讯
    • 系统运维
      • 操作系统
        • Windows
        • Linux
        • Mac OS
      • 数据库
        • MySQL
        • Oracle
        • SQL Server
      • 网站建设
    • 人工智能
    • 半导体芯片
    • 笔记本电脑
    • 智能手机
    • 智能汽车
    • 编程语言
    IT技术网 - ITJS.CN
    首页 » SQL语言 »Service Broker基础应用(上)

    Service Broker基础应用(上)

    2011-05-06 15:37:00 出处:ITJS
    分享

    导读:本文主要涉及Service Broker的基本概念及建立一个Service Broker应用程序的基本步骤。

    一、前言:

    Service Broker为SQL Server提供消息队列,这提供了从数据库中发送异步事务性消息队列的方法。Service Broker消息可以保证以适当的顺序或原始的发送顺序不重复地一次性接收。并且因为内建在SQL Server中,这些消息在数据库发生故障时是可以恢复的,也可以随数据库一起备份。在SQL Server 2008中,还引入了使用Create Broker Priority命令对会话设定优先级,可以对重要的或不重要的会话进行优先级设定,以保证消息合理地处理。

    本文假定一个在线数据库BookStore中存储了一些业务订单。我们使用Service Broker应用程序将消息发送到另一个数据库BookDistribution,该数据库是分离的应用程序调用,该应用程序控制仓库入库和出库交付, 并返回消息给BookStore。

    创建Service Broker应用程序大体步骤如下:

    1、定义希望应用程序执行的异步任务。

    2、确定Service Broker的发起方服务和目标服务是否创建在同一个SQL Server实例中。假如是两个实例,实例间的通信还需要创建经过证书认证或NT安全的身份认证,并且要创建端点、路由以及对话安全模式。

    3、假如没有启用,则在多方参与的数据库中使用Alter Database命令设置Enable_broker以及Truseworthy数据库选项。

    4、为所有多方参与的数据库创建数据库主密钥。

    5、创建希望在服务之间发送的消息类型。

    6、创建契约(Contract)来定义可以由发起方发送的各种消息以及由目标发送的消息类型的种类。

    7、同时在两方参与的数据库中创建用于保存消息的队列。

    8、同时在绑定特定约定到特定队列的多方参与的数据库中创建服务。

    二、实例

    下面我们通过一个示例来实现以上步骤:

    (一)、启用数据库的Service Broker活动

    -- Enabling Databases for Service Broker Activity

    USE master

    IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = 'BookStore')

    IF NOT EXISTS (SELECT name FROM sys.databases WHERE name = 'BookDistribution')

    ALTER DATABASE BookStore SET ENABLE_BROKER

    ALTER DATABASE BookStore SET TRUSTWORTHY ON

    ALTER DATABASE BookDistribution SET ENABLE_BROKER

    ALTER DATABASE BookDistribution SET TRUSTWORTHY ON

    (二)、创建数据库主密钥

    -- Creating the DatabaseMaster Key for Encryption

    USE BookStore

    CREATE MASTER KEY

    GO

    USE BookDistribution

    CREATE MASTER KEY

    GO

    (三)、管理消息类型

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

    -- Managing Message Types

    Use BookStore

    -- 发送图书订单的消息类型

    VALIDATION = WELL_FORMED_XML

    CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived]

    Use BookDistribution

    -- 发送图书订单的消息类型

    VALIDATION = WELL_FORMED_XML

    CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived]

    CREATE CONTRACT

    ( [//SackConsulting/SendBookOrder]

    SENT BY TARGET

    CREATE CONTRACT

    ( [//SackConsulting/SendBookOrder]

    SENT BY TARGET

    --保存BookDistribution过来的消息

    GO

    USE BookDistribution

    --保存BookStore过来的消息

    GO

    (六)、创建服务

    服务定义端点,然后使用它来将消息队列绑定到一个或多个契约上。服务使用队列和契约来定义一个或一组任务。有点拗口,是不是?

    服务是消息的发起方和接收方强制约定的规则,并将消息路由到正确的序列。

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

    -- Creating Services

    Use BookStore

    CREATE SERVICE [//SackConsulting/BookOrderService]

    ([//SackConsulting/BookOrderContract])

    CREATE SERVICE [//SackConsulting/BookDistributionService]

    ([//SackConsulting/BookOrderContract])

    DECLARE @Conv_Handler uniqueidentifier

    BEGIN DIALOG CONVERSATION @Conv_Handler--创建会话

    TO SERVICE '//SackConsulting/BookDistributionService'

    '<order id="3439" customer="22" orderdate="2/15/2011">

    MESSAGE TYPE [//SackConsulting/SendBookOrder]

    SELECT message_type_name, CAST(message_body as xml) message,

    --创建一个表存放接收到的订单信息

    DECLARE @Conv_Handler uniqueidentifier

    DECLARE @OrderMsg xml

    --从队列中获取消息,将接收值赋于局部变量

    @Conv_Handler = conversation_handle,

    -- 将变量值插入表中

    (@Conv_Handler,@Conv_Group, @OrderMsg )

    -- 使用XQuery进行抽取以响应消息订单

    '<orderreceived id= "' +

    '"/>';

    -- 使用既有的会话句柄,发送响应消息到发起方

    MESSAGE TYPE [//SackConsulting/BookOrderReceived]

    (十)、结束会话

    -- Ending a Conversation

    USE BookStore

    -- 创建订单确认表

    DECLARE @Conv_Handler uniqueidentifier

    DECLARE @OrderMsg xml

    RECEIVE TOP(1) @Conv_Handler = conversation_handle,

    INSERT dbo.BookOrderConfirmation

    END CONVERSATION @Conv_Handler;

    DECLARE @Conv_Handler uniqueidentifier

    DECLARE @OrderMsg xml

    RECEIVE TOP(1) @Conv_Handler = conversation_handle,

    -- 双方必须都结束会话

    @message_type_name = 'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'

    END CONVERSATION @Conv_Handler;

    END

    --查询会话状态

    SELECT state_desc, conversation_handle

    FROM sys.conversation_endpoints

    三、小结

    本文通过一个实例演示了一个用来发送图书订单消息分发控制数据库的简单的消息交换应用程序。发起方发送图书订单,发回一个响应,并在两个数据库上使用END Conservation结束会话。现实场景中可以转换为其他消息类型、契约、服务和队列。合理运用Service Broker应用程序的异步特性可以防止因应用程序挂起而导致业务系统产生瓶颈。

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

    上一篇返回首页 下一篇

    声明: 此文观点不代表本站立场;转载务必保留本文链接;版权疑问请联系我们。

    别人在看

    Destoon 模板存放规则及语法参考

    Destoon系统常量与变量

    Destoon系统目录文件结构说明

    Destoon 系统安装指南

    Destoon会员公司主页模板风格添加方法

    Destoon 二次开发入门

    Microsoft 将于 2026 年 10 月终止对 Windows 11 SE 的支持

    Windows 11 存储感知如何设置?了解Windows 11 存储感知开启的好处

    Windows 11 24H2 更新灾难:系统升级了,SSD固态盘不见了...

    小米路由器买哪款?Miwifi热门路由器型号对比分析

    IT头条

    Synology 对 Office 套件进行重大 AI 更新,增强私有云的生产力和安全性

    01:43

    StorONE 的高效平台将 Storage Guardian 数据中心占用空间减少 80%

    11:03

    年赚千亿的印度能源巨头Nayara 云服务瘫痪,被微软卡了一下脖子

    12:54

    国产6nm GPU新突破!砺算科技官宣:自研TrueGPU架构7月26日发布

    01:57

    公安部:我国在售汽车搭载的“智驾”系统都不具备“自动驾驶”功能

    02:03

    技术热点

    最全面的前端开发指南

    Windows7任务栏桌面下角的一些正在运行的图标不见了

    sql server快速删除记录方法

    SQL Server 7移动数据的6种方法

    SQL Server 2008的新压缩特性

    每个Java程序员必须知道的5个JVM命令行标志

      友情链接:
    • IT采购网
    • 科技号
    • 中国存储网
    • 存储网
    • 半导体联盟
    • 医疗软件网
    • 软件中国
    • ITbrand
    • 采购中国
    • CIO智库
    • 考研题库
    • 法务网
    • AI工具网
    • 电子芯片网
    • 安全库
    • 隐私保护
    • 版权申明
    • 联系我们
    IT技术网 版权所有 © 2020-2025,京ICP备14047533号-20,Power by OK设计网

    在上方输入关键词后,回车键 开始搜索。Esc键 取消该搜索窗口。