使用MSMQ实现SQL SERVER的推送服务

第１９卷　

第２１期　

Ｖｏ１．１９　

Ｎｏ．２１　

电子设计工程　

Ｅｌｅｃｔｒｏｎｉｃ　Ｄｅｓｉｇｎ　Ｅｎｇｉｎｅｅｒｉｎｇ　

２０１１年１１月　

ＮＯＶ．２０１１　

使用ＭＳＭＱ实现ＳＱＬ　ＳＥＲＶＥＲ的推送服务　

翟乃强　

（青岛远洋船员学院现代教育技术中心，山东青岛２６６０７１）　

摘要：在传统的应用中，客户端从数据库拉取数据。在实时性较强，数据更新周期较长的应用中，一般采用短时间间　

隔的轮询方式．增加了数据库端的负担。利用数据库的触发器调用ＣＬＲ存储过程或者扩展存储过程，配合ＭＳＭＱ的　

消息传递能力．可以实现数据库推送数据的服务。　

关键词：数据库；推送服务；存储过程；消息队列；触发器　

中图分类号：１］Ｐ．３９１　文献标识码：Ａ　文章编号：１６７４—６２３６（２０１１）２１—００５０—０３　

Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ　ｏｆ　ＳＱＬ　ＳＥＲＶＥＲ　ｐｕｓｈ　ｓｅｒｖｉｃｅ　ｂｙ　ｓｉｕｎｇ　ＭＳＭＱ　

ＺＨＡＩ　Ｎａｉ—ｑｉａｎｇ　

（Ｍｏｄｅｒｎ　Ｅｄｕｃａｔｉｏｎ　Ｔｅｃｈｎｉｃａｌ　Ｃｅｎｔｅｒ，Ｑｉｎｇｄａｏ　Ｏｃｅａｎ　ＳｈｉｐｐｉｎｇＭａｒｉｎｅｒｓ　Ｃｏｌｌｅｇｅ，Ｑｉｎｇｄａｏ　２６６０７１，Ｃｈｉｎａ）　

Ａｂｓｔｒａｃｔ：Ｉｎ　ｔｒａｄｉｔｉｏｎａｌ　ａｐｐｌｉｃａｔｉｏｎｓ，ｃｌｉｅｎｔｓ　ｐｕｌｌ　ｄａｔａ　ｆｒｏｍ　ａ　ｄａｔａｂａｓｅ．Ｉｎ　ａ　ａｐｐｌｉｃａｔｉｏｎ　ｔｈａｔ　ｎｅｅｄ　ａ　ｒｅａｌ－ｔｉｍｅ　ｐｒｏｃｅｓｓｉｎｇ　ａｎｄ　

ｔｈｅ　ｄａｔａｂａｓｅ　ｕｐｄａｔｅ　ｃｙｃｌｅ　ｉｓ　ａ　ｖｅｒｙ　ｌｏｎｇ　ｔｉｍｅ，ｇｅｎｅｒａｌｌｙ　ａ　ｓｈｏｒｔ　ｉｎｔｅｒｖａｌ　ｏｆ　ｐｏｌｌｉｎｇ　ｗｈｉｃｈ　ｉｎｃｒｅａｓｅ　ｔｈｅ　ｂｕｒｄｅｎ　ｏｎ　ｔｈｅ　ｄａｔａｂａｓｅ　

ｓｉｄｅ　ｉｓ　ｕｓｅｄ．Ｕｓｉｎｇ　ｄａｔａｂａｓｅ　ｔｉｒｇｇｅｒｓ，ＣＬＲ　ｓｔｏｒｅｄ　ｐｒｏｃｅｄｕｒｅ　ｏｒ　ｅｘｔｅｎｄｅｄ　ｓｔｏｒｅｄ　ｐｒｏｃｅｄｕｒｅ，ｗｉｔｈ　ｔｈｅ　ＭＳＭＱ　ｍｅｓｓａｇｉｎｇ　

ｃａｐａｂｉｌｉｔｉｅｓ，ａ　ｄａｔａｂａｓｅ　ｐｕｓｈ　ｄａｔａ　ｓｅｒｖｉｃｅ　ｉｓ　ｉｍｐｌｅｍｅｎｔｅｄ．　

Ｋｅｙ　ｗｏｒｄｓ：ｄａｔａｂａｓｅ；ｐｕｓｈ　ｓｅｒｖｉｃｅ；ｓｔｏｒｅｄ　ｐｒｏｃｅｄｕｒｅ；ｍｅｓｓａｇｅ　ｑｕｅｕｅ；ｔｒｉｇｇｅｒ　

数据库在现代信息技术里面具有重要的地位，多数的的　

应用系统都是以数据库为中心进行开发的。在数据库的相关　

操作中，数据的查询在应用中占有很大的部分，而查询均是　

证的复杂的参照完整性和数据的一致性。除此之外，触发器　

还有其他许多不同的功能：　

１）强化约束（Ｅｎｆｏｒｃｅ　ｒｅｓｔｒｉｃｔｉｏｎ）　

数据拉取的方式，即客户端提交请求，数据库端进行相关的　

操作并返回数据。在这种方式下，应用程序仅在有需要的时　

触发器能够实现比ＣＨＥＣＫ语句更为复杂的约束。　

２）跟踪变化Ａｕｄｉｉｔｎｇ　ｃｈａｎｇｅｓ　

候才向数据库提交请求，并获取数据。在某些特殊的多用户　

情况下，数据库中的数据不定时产生的变化需要实时的体现　

‘　触发器可以侦测数据库内的操作，从而不允许数据库中　

未经许可的指定更新和变化。　

在客户端时，常采用轮询的方式，可以根据需要处理事件的　

优先级或者实时性要求，设定查询频率，定时去数据库端拉　

取数据。当数据的处理实时性要求较高而数据库端产生数据　

变化的时间间隔较长的时候，就需要客户端频繁地去数据库　

端拉取数据，此时单位时间内将产生大量的拉取数据的请　

求，这些请求绝大部分是无效的而又不得不去做的，这些请

求将增大数据库端的负担和网络带宽的占用。针对这种情　

３）级联运行（Ｃａｓｃａｄｅｄ　ｏｐｅｒａｔｉｏｎ）。　

触发器可以侦测数据库内的操作，并自动地级联影响整　

个数据库的各项内容。例如，某个表上的触发器中包含有对　

另外一个表的数据操作（如删除，更新，插入）而该操作又导　

致该表上触发器被触发。　

４）存储过程的调用（Ｓｔｏｒｅｄ　ｐｒｏｃｅｄｕｒｅ　ｉｎｖｏｃａｔｉｏｎ）。　

为了响应数据库更新，触发器可以调用一个或多个存储　

况，提出了一种使用ＭＳＭＱ和触发器机制实现的数据库的推　

送服务，其本质是数据库端产生了数据变化，将对订阅了此　

过程，甚至可以通过外部过程的调用而在ＤＢＭＳ（数据库管　

理系统）本身之外进行操作。　

变化的客户端程序发送一个可查询的信息，然后等待客户端　

的查询。　

触发器一般情况下分为３种：ＢＥＦＯＲＥ，ＡＦＩＥＲ和　

ＩＮＳＴＥＡＤ　ＯＦ，分别用于在异动发生前执行、异动发生后执行　

１触发器　

触发器是用户预定义的一类由事件驱动的特殊存储过　

羹萎　

建立方式如下：　

兰　

程。当进行插入、删除、更新等操作时，触发器会自动执行【１］。　

触发器的主要作用就是其能够实现由主键和外键所不能保　

收稿日期：２０１１－０９—０６　稿件编号：２０１１０９０３４　

ＣＲＥＡＴＥ　ＴＲＩＧＧＥＲ　ｅｖｅｎｔｌ　

ＯＮ　ｔｂｌａｅ　

ＡＦＴＥＲ　ＩＮＳＥＲＴ　

作者简介：翟乃强（１９７７一），男，山东淄博人，硕士，讲师。研究方向：通信技术、图像处理、模式识别。　

－

５０－　

翟乃强　使用ＭＳＭＱ实现ＳＱＬ　ＳＥＲＶＥＲ的推送服务　

ＡＳ　

５）使用ＤＲＯＰ　ＡＳＳＥＭＢＬＹ删除存储过程。　

通过在触发器中运行建立的ＣＬＲ存储过程或者扩展存　

储过程，可以实现外部的消息发送。由于客户端程序的分布　

ＥＸＥＣ　ｓｏｍｅｐｒｏｃ　

因为触发器是事件驱动的，能够实时地获得数据改变的　

情况，因此可以作为数据库推送服务的发动者剐。各应用程　

序通过在数据库中建立相应的触发器来订阅所关注的数据　

式，消息的安全性、事务性等要求，考虑使用ＭＳＭＱ作为消息　

的中转方式。　

变化情况。对于多个应用程序关注相同事件的情形下．只需　

要建立一个触发器。　

３　ＭＳＭＱ　

ＭＳＭＱ（Ｍｉｃｒｏｓｏｆｔ　Ｍｅｓｓａｇｅ　Ｑｕｅｕｉｎｇ　Ｓｅｒｖｅｒ，消息队列）是一　

种消息处理基础结构和开发工具。用于在Ｍｉｃｒｏｓｏｆｔ　Ｗｉｎｄｏｗｓ　

２　ＣＬＲ存储过程和扩展存储过程　

存储过程（Ｓｔｏｒｅｄ　Ｐｒｏｃｅｄｕｒｅ）是一组为了完成特定功能的　

操作系统中创建分布式消息处理程序［６１。为消息队列开发的　

ＳＱＬ语句集，是利用ＳＱＬ　Ｓｅｒｖｅｒ所提供的Ｔｒａｎｓａｃｔ—ＳＱＬ语言　

所编写的程序。功能是将常用或复杂的工作，预先用ＳＱＬ语　

句写好并用一个指定名称存储起来。以后需要数据库提供与　

已定义好的存储过程的功能相同的服务时．只需调用此存储　

过程即可自动完成命令。存储过程经编译和优化后存储在数　

据库服务器中．可由应用程序通过一个调用来执行．而且允　

许用户声明变量。同时，存储过程可以接收和输出参数、返回　

执行存储过程的状态值，也可以嵌套调用。　

存储过程分为系统存储过程、本地存储过程、临时存储　

过程和扩展存储过程等。其中扩展存储过程（Ｅｘｔｅｎｄｅｄ　Ｓｔｏｒｅｄ　

Ｐｒｏｃｅｄｕｒｅｓ）是用户可以使用外部程序语言编写的存储过程．　

具有较强的灵活性。在ＳＱＬ　Ｓｅｒｖｅｒ中扩展存储过程又分为普　

通扩展存储过程和基于ＣＬＲ的扩展存储过程。　

触发器建立后需要将此事件发送到数据库外部．而不是　

简单的执行部分ＤＤＬ或者ＤＭＬ操作，因此需要数据库运行　

扩展存储过程或者ＣＬＲ存储过程。　

扩展存储过程是ＳＱＬ　Ｓｅｒｖｅｒ实例可以动态加载和运行　

的ＤＬＬ。扩展存储过程是使用ＳＱＬ　Ｓｅｒｖｅｒ扩展存储过程　

ＡＰＩ编写的，可直接在ＳＱＬ　Ｓｅｒｖｅｒ实例的地址空间中运行。　

扩展存储过程的显示方式和执行方式与常规存储过程一样。　

可以将参数传递给扩展存储过程，而且扩展存储过程也可以　

返回结果和状态。在ＳＱＬ　ＳＥＲＶＥＲ中可以使用Ｔｒａｎｓａｃｔ－ＳＱＬ　

语句ｓｐ＿ａｄｄｅｘｔｅｎｄｅｄｐｒｏｅ来调用扩展存储过程。由于扩展存　

储过程可能会产生内存泄漏或其他降低服务器的性能及可　

靠性的问题，在ＳＱＬ　ＳＥＲＶＥＲ　２００８以后的版本中将不提供　

支持Ｈ。　

ＣＬＲ存储过程使得可以在ＳＱＬ　Ｓｅｒｖｅｒ实例中创建在　

Ｍｉｃｒｏｓｏｆｔ．ＮＥＴ　Ｆｒａｍｅｗｏｒｋ公共语言运行时（ＣＬＲ）中创建的　

程序集中进行编程的数据库对象。能够利用由ＣＬＲ提供的　

众多编程模型的数据库对象包括触发器、存储过程、函数、聚　

合函数和类型等四。在ＳＱＬ　ＳＥＲＶＥＲ中使用ＣＬＲ存储过程的　

基本步骤是：　

１）使用．ＮＥＴ　Ｆｒａｍｅｗｏｒｋ开发环境开发建立程序集。　

２）使用Ｔｒａｎｓａｃｔ－ＳＱＬ语句ｓｐ＿ｃｏｎｆｉｇｕｒｅ启用ＳＱＬ　Ｓｅｖｒｅｒ　

中的ＣＬＲ运行环境。　

３）使用ＣＲＥＡＴＥ　ＡＳＳＥＭＢＬＹ加载程序集。　

４）使用ＣＲＥＡＴＥ　ＰＲＯＣＥＤＵＲＥ调用存储过程。　

应用程序向队列发送消息，当条件允许时这些消息会继续传　

送到最终目标。应用程序可以在异类网络的环境中进行通　

信，并能在会偶尔无法连通的计算机之间发送消息。消息队　

列提供了可靠的消息传递、高效的路由、安全性和基于优先　

级的消息处理。并支持在事务内发送消息。消息队列可以灵　

活的运行于单台计算机。工作组中或者是域中，也可以通过　

ＭＱＣ等其他软件在其他系统如ＵＮＩＸ中运行消息队列。也可　

以与其他类型的消息队列进行无缝对接册。　

客户端订阅的数据库数据变化信息，也应该对应的在　

ＭＳＭＱ中建立队列。ＭＳＭＱ队列可以存在于服务器端也可以　

存在于客户端。如果客户机与数据库在同一个子网中，并且　

不考虑加密及异构系统中的消息传递等，可以考虑单机或者　

工作组中的消息队列形式．否则就需要配置存在于域中的消　

息服务器。　

ＭＳＭＱ中的每一个队列都支持消息队列触发器。在这些　

触发器中可以定义触发规则，当队列中消息变化时调用ＣＯＭ　

组件或者可执行程序，用这种方式可实现通知等待消息的客　

户端程序。事实上，每一个消息队列都支持异步读取消息的　

方法，当没有新的消息到来时，读取的线程将被阻塞。可以通　

过这种方式等待事件的发生．而不使用消息队列的触发器。　

如图１所示。　

ＭＳＭＱ　

客　异步请求一　队列１　

端　

户　看数据则返回　

队列ｎ　

图１客户端通过异步请求访问消息队列　

Ｆｉｇ．１　Ｃｌｉｅｎｔ　ａｃｃｅｓｓ　ｔｏ　ａ　ｍｅｓｓａｇｅ　ｑｕｅｕｅ　ａｓｙｎｃｈｒｏｎｏｕｓｌｙ　

４整合　

实现ＳＱＬ　ＳＥＲＶＥＲ半推送式的服务。需要进行四部分的　

工作：　

１）在．ＮＥＴ　Ｆｒａｍｅｗｏｒｋ开发环境中开发基于ＣＬＲ的存储　

过程，用于向ＭＳＭＱ发送消息。　

２）根据客户端程序的需要在数据库中建立调用第（１）步　

存储过程的触发器。　

３）ＭＳＭＱ服务器中建立对应的队列，根据应用需求的安　

一

５１—　

《电子设计工程）２０１１年第２１期　

全性等因素可以使用事务性队列。　

４）客户端程序访问ＭＳＭＱ服务器预定义的队列。队列如　

果针对于单个客户端。则使异步的Ｒｅｃｅｉｖｅ方法读取，此方法　

ＹＡＯ　Ｙｕ－ｃｈｕｎ，ＰＡＮ　Ｌｉｎ・ｓｅｎ，ＷＡＮＧ　Ｆａｎ．Ｄａｔａｂａｓｅ　ｔｒｉｇｇｅｒｓ　

ａｎｄ　ｔｈｅｉｒ印ｐｌｉｃａｔｉｏｎ［Ｊ］．Ｊｏｕｒｎａｌ　ｏｆ　Ｃｈｏｎｇｑｉｎｇ　Ｊｉａｎｚｈｕ　

Ｕｎｉｖｅｒｓｉｔｙ，２００３，２５（５）：１２８－１２９．　

读取完毕将从队列中删除此消息。如果针对于多个客户端，　

则需要建立消息队列时要ＰＥＥＫ方法读取，由各客户端相互　

协调消息的读取删除等操作嘲。　

【２】黄晓涛．数据库触发器实现数据库系统的主动功ｆｉＥ［Ｊ］．计　

算机应用研究，１９９９，９（４７）：４７－４８．　

ＨＵＡＮＧ　Ｘｉａｏ・ｔａｏ．Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ　ｏｆ　ａｃｔｉｖｅ￣ａｔｕｒｅ　ｂｙ　

整个ＳＱＬ　ＳＥＲＶＥＲ的半推送服务的方式如图２所示。　

ｄａｔａｂａｓｅ　ｔｉｒｇｇｅｒ［Ｊ】．Ａｐｐｌｉｃａｔｉｏｎ　Ｒｅｓｅａｒｃｈ　Ｏｆ　Ｃｏｍｐｕｔｅｒｓ，　

１９９９，９（４７）：４７－４８．　

［３】张文超，张臻，李军怀．基于触发器机制的主动数据库模　

型研究［Ｊ］．计算机应用，２００６，２６（１０）：２４１８—２４１９．　

ＺＨＡＮＧ　Ｗｅｎ－ｃｈａｏ，ＺＨＡＮＧ　Ｊｉｎｇ，ＬＩ　Ｊｕｎ－ｈｕａｉ．Ｎｅｗ　ｍｏｄｅｌ　ｏｆ　

ｎ　ａａｃｔｉｖｅ　ｄａｔａｂａｓｅ　ｂａｓｅｄ　ｏｎ　ｔｒｉｇｇｅｒｓ　ＣｏｍｐｕｔｅｒＡｐｐ　ｌｉｃａｔｉｏｎｓ，　

２０ｏ６．２６（１０）：２４１８—２４１９．　

图２半推送式服务的实现　

Ｆｉｇ．２　Ｉｍｐｌｅｍｅｎｔａｔｉｏｎ　ｏｆ　ｓｅｍｉ－ｐｕｓｈ　ｓｅｒｖｉｃｅ　

［４】扩展存储过程【ＥＢ／ＯＬ］．［２Ｏｌ　１—０９—ｏ６】Ｉ　ｈｔｔｐ：／／ｔｅｅｈｎｅｔ．ｍｉｃｒｏｓｏｆｔ．　

ｃｏｍ／ｚｈ—ｃｎ／ｌｉｂｒａｒｙ／ｍｓ１７５２００．ａｓｐｘ．　

５结束语　．　

被动式提供服务的数据库系统。利用ＣＬＲ或扩展存储过　

【５】ＣＬＲ存储过程【ＥＢ／ＯＬ］．￣０１１－０９＿ｏ６］．ｈｔｔｐ：／／ｔｅｃｈｎｅｔ．ｍｉｃｒｏｓｏｆｔ．　

ｃｏｍ／ｚｈ—ｃｎ／ｌｉｂｒａｒｙ／ｍｓ１９０７９０．ａｓｐｘ　

【６】王松磊，陈永生．基于消息队列的独立通信层的设计与应　

程与ＭＳＭＱ服务一起可以提供主动的数据推送服务。在某些　

实时性要求高且数据变化周期长的情形下能够提高效率。降　

低数据库服务端的负担和网络压力。本文提出的推送方式是　

由数据库通过消息通知客户端来进行查询。可以称之为半推　

送的服务方式。如果客户端对于数据变化需求确定，可以通　

过存储过程将需要的数据经ＭＳＭＱ序列直接发送到客户端．　

这样也就完成了数据库的完全推送服务。　

参考文献：　

用［Ｊ】．计算机应用，２０１０，３０（２）：２１—２２．　

ＷＡＮＧ　Ｓｏｎｇ—ｌｅｉ，ＣＨＥＮ　Ｙｏｎｇ—ｓｈｅｎｇ．Ｄｅｓｉｇｎ　ａｎｄ　ａｐｐｌｉｃａｔｉｏｎ　

ｉｎｄｅｐｅｎｄｅｎｔ　ｏｆ　ｃｏｍｍｕｎｉｃａｔｉｏｎ　ｌａｙｅｒ　ｂａｓｅｄ　ｏｎ　ｍｅｓｓａｇｅ　

ｑｕｅｕ￣．Ｊｏｕｒｎａｌ　ｏｆＣｏｍｐｕｔｅｒＡｐｐ　ｌｉｃａｆｉｏｎｓ，２０１０，３０（２）￣１－２Ｚ　

【７】使用消息队列　Ｂ　Ｌ］．［２０１　１－０９－０６］．ｈｔｔｐＪ／ｔｅｅｈｎｅｔ．ｍｉｃｒｏｓｏｆｔ．　

ｃｏｍ／ｚｈ－ｃｎ／ｌｉｂｒａｒｙ／ｃｃ７３９１８９（ＷＳ．１Ｏ）．ｓｐｘ．ａ　

【８】Ｓｅｎｄ　ＭＳＭＱ　Ｍｅｓｓａｇｅｓ　Ｓｅｃｕｒｅｌｙ　Ａｃｒｏｓｓ　ｔｈｅ　Ｉｎｔｅｒｎｅｔ　ｗｉｔｈ　

ＨＴｒＰ　ｎｄ　ａＳＯＡＰ　Ｂ／Ｏ　［２Ｏｌ　１－－０９＿０嘲．ｈｔｔｐ＇Ｊｈｎｓｄｎ．ｍｉｃｒｏｓｏｆｔ．　

ｃｏｍ／ｚｈ—ｃｎ／ｍａｇａｚｉｎｅ／ｃｃ１６４０４１（ｅｎ－ｕｓ）．ｓｐｘ．ａ　

【１】姚渝眷，潘林森，王凡．数据库触发器及应用【Ｊ］．重庆建筑　

大学学报，２００３，２５（５）：１２８—１２９．　

（上接第４９页）　

ｓｗａｒｍ　ｏｐｔｉｍｉｚａｔｉｏｎ［Ｍ］．Ｎｅｗ　Ｙｏｒｋ：Ｅｖｏｌｕｔｉｏｎａｒｙ　Ｐｒｏｇｒａｍｍｉｎｇ，　

１９９８．　

Ｐｉｓｃａｔａｗａｙ，ＮＪ：ＩＥＥＥ　Ｐｒｅｓｓ，１９９８：３０３－３０８．　

【８】纪震，廖惠连，昊青华．粒子群算法及应用【Ｍ】．北京：科学出　

版社．２００９．　

［７］Ｓｈｉ　Ｙ，Ｅｂｅｒｈａｒｔ　Ｒ　Ｃ．Ａ　ｍｏｄｉｉｆｅｄ　ｐａｒｔｉｃｌｅ　ｓｗａｒｌｎ　ｏｐｔｉｍｉｚｅｒ［Ｃ】　

／／ＩＥＥＥ　Ｉｎｔｅｒｎａｔｉｏｎａｌ　Ｃｏｎｆｅｒｅｎｃｅ　ｏｎ　Ｅｖｏｌｕｔｉｏｎａｒｙ　Ｃｏｍｐｕｔａｔｉｏｎ．　

一

５２—