Service Broker学习（一）-低调大师

Service Broker学习（一）

2017-12-18 500

0.参考文献：

SQL Server 2005 Service Broker 初探

1.Service Broker 编程

Service Broker 功能通过 SQL Server 中的新对象启用，这些新对象可以由一组 T-SQL 扩展来创建和操作。为了数据库程序员的方便，使用了他们熟悉的用于配置其他数据库对象的 CREATE、ALTER 和 DROP DDL 语句来配置 Service Broker 应用程序。用于创建 Service Broker 对话以及在对话中发送和接收消息的命令是 Transact SQL 语言的 DML 扩展。接收命令的语法与选择命令相似，它返回包含消息的行集，就像选择命令返回包含行的行集一样。熟悉 Transact SQL 编程的开发人员会发现学习 Service Broker 编程非常容易。用于为 Service Broker 编程的客户端 API 与用于为所有数据库编程的 API 相同，例如 OLEDB、ODBC、ADO、ADO.NET 等等。下面是 Service Broker 使用的对象。

1.1.队列(QUEUE)

Service Broker 使用队列在消息发送程序和消息接收程序之间提供松散耦合。发送程序可以使用 SEND 命令将消息放到队列中，然后应用程序继续操作(不用等待接受程序发送确认回复)并依靠 Service Broker 来确保消息到达其目标位置。

队列允许较大的计划灵活性。例如，发送程序可以发送多条消息以供多个接收程序并行处理。接收程序可能在消息发送很长时间后才处理消息，但由于传入消息进行了排队，因此接收程序可以按其自己的速率处理消息，而且发送程序无须等待接收程序完成处理便可继续操作。

1.2.对话(DIALOG)

Service Broker 还实现了对话，对话是两个端点之间的双向消息流。对话中的所有消息都进行了排序，而且对话消息总是按照发送的顺序传送。该顺序在事务、输入线程、输出线程以及系统崩溃和重新启动过程中都保持不变。

对话是一种会话类型。Service Broker 会话是持久可靠的通信通道。在以后的 SQL Server 版本中，Service Broker 将包括一对多的单向会话，也称为可靠的“发布-订阅”。在 SQL Server 2005 中，对话是唯一的会话类型，因此这两个术语同义。

每条消息都包括唯一标识与它相关的对话的会话句柄。例如，某个订单输入应用程序可能同时使用发货应用程序、库存应用程序和帐单应用程序打开了对话。因为每个应用程序中的消息都具有唯一的会话句柄，所以可以轻松地确定发送每条消息的应用程序。

下面的关系图显示对话的消息流：

1.3.消息类型(MESSAGE TYPE)

当前，所有 Service Broker 消息都与特定的消息类型相关联。消息类型是与消息一起传送的标签，因此接收消息的应用程序可以确定所接收消息的类型。此外，如果消息包含 XML 文档，则消息类型可以与 XML 架构集合相关联。如果为某个消息类型指定了架构集合，则所接收的该类型消息将在收到时根据架构集合进行验证，而没有通过架构验证的消息将会被拒绝。

1.4.规范(CONTRACT)

Service Broker 规范是一个消息类型集合。一个对话总是与一个规范相关联，而规范定义哪些消息类型可以通过对话发送。

1.5.服务(SERVICE)

Service Broker 服务将一个或多个规范与一个队列相关联。规范定义可以将哪些消息类型发送到队列。服务名称用于建立对话的端点。服务名称用作实际队列的别名，因此您可以编写引用服务名称的 Service Broker 程序，然后在部署应用程序时将它与实际队列相关联。

2.Service Broker“Hello World”

大多数编程语言书籍都以“Hello World”示例开始，因此我们也在 Service Broker 中使用 Hello World 作为示例。为简化示例，我使用可以从 SQL Server Management Studio 查询窗口运行的 T-SQL 进行编写。大多数 Service Broker 应用程序将作为普通的数据库应用程序，这些应用程序由通过 ADO 或 ADO.NET 与数据库进行通信的可执行程序和使用 T-SQL 或 .NET 语言编写的 SQL Server 存储过程构成。

要发送和接收消息，必须首先创建向 Service Broker 描述应用程序的消息传送部分的元数据对象。在 SQL Server 2005 中，使用新添加的 DDL 语句来创建、修改和删除 Service Broker 元数据。

代码示例

 
 
 View Code 

执行上述代码以后，我们可以查看SSMS中HelloWorldDB的Servic Broker属性，如下图所示，主要列出了我们创建的队列、服务等信息：

本文转自xwdreamer博客园博客，原文链接：http://www.cnblogs.com/xwdreamer/archive/2012/06/29/2570389.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/347389

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

关系型数据的分布式处理系统：Cobar

Cobar简介 Cobar是关系型数据的分布式处理系统，它可以在分布式的环境下像传统数据库一样为您提供海量数据服务。 Github：https://github.com/alibaba/cobar 整体架构图： image 快速启动场景系统对外提供的数据库名是dbtest,并且其中有两张表tb1和tb2。 tb1表的数据被映射到物理数据库dbtest1的tb1上。 tb2表的一部分数据被映射到物理数据库dbtest2的tb2上，另外一部分数据被映射到物理数据库dbtest3的tb2 上。如下图所示： image 详情请参考：https://github.com/alibaba/cobar/wiki/Quick-Start 产品约束使用JDBC时，推荐使用5.1以上版本Driver进行连接。不支持跨库的关联操作：join、分页、排序、子查询。不支持rewriteBatchedStatements=true参数设置,默认为false。不支持useServerPrepStmts=true参数设置,默认为false。 BLOB, BINARY, VARBINARY字段不能使用。若特...

2017-12-19

518

一、上篇回顾上篇我们讲述了比较常用的适配器模式，并且分析了适配器的一般使用场景： 1、我们在使用第三方的类库，或者说第三方的API的时候，我们通过适配器转换来满足现有系统的使用需求。 2、我们的旧系统与新系统进行集成的时候，我们发现旧系统的数据无法满足新系统的需求，那么这个时候，我们可能需要适配器，完成调用需求。 3、我们在使用不同数据库之间进行数据同步。(我这里只是分析的是通过程序来说实现的时候的情况。还有其他的很多种方式[数据库同步])。并且讲述了对象适配器和类适配器的区别：对象适配器：不是通过继承的方式，而是通过对象组合的方式来进行处理的，我们只要学过OO的设计原则的都知道，组合相比继承是推荐的方式。类适配器：通过继承的方式来实现，将旧系统的方法进行封装。对象适配器在进行适配器之间的转换过程中，无疑类适配器也能完成，但是依赖性会加大，并且随着适配要求的灵活性，可能通过继承膨胀的难以控制。并且由于C#中不支持多继承，以至于限制我们的继承的策略。而对象组合的方式则不会有太多的限制。我们在上篇中还讲述了适配器之间的转配，但是没有给出一个示例代码：我们...

2017-12-19

514

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。