SqlServer service broker 分布式系统（赵松涛）深入浅出 2005 数据库编程

概述1.创建测试数据库 create database ServerbrokerTest on primary( name=ServerbrokerTest_data, filename='C:\Program Files\Microsoft SQL Server\MSSQL11.SQLEXPRESS\MSSQL\DATA\ServerbrokerTest_data.mdf', size=5, max

1.创建测试数据库

create database ServerbrokerTest
on primary(
name=ServerbrokerTest_data,
filename='C:\Program files\Microsoft sql Server\MSsql11.sqlEXPRESS\MSsql\DATA\ServerbrokerTest_data.mdf',
size=5,
maxsize=unlimited,
filegrowth=1
)
Log on
(
name=student_log,
filename='C:\Program files\Microsoft sql Server\MSsql11.sqlEXPRESS\MSsql\DATA\ServerbrokerTest_log.ldf',
size=1,
maxsize=20,
filegrowth=3
)

2.激活数据库的broker功能

 

SELECT IS_broKER_ENABLED FROM MASTER.SYS.DATABASES
WHERE name='ServerbrokerTest';

成功：

，说明已经激活

若不成功： ALTER DATABASE DB_broKERTEST SET ENABLE_broKER  激活broker功能 将其激活

 

3.定义消息类型

--定义消息类型,必须是格式正确的xml
USE ServerbrokerTest
GO
CREATE MESSAGE TYPE 
MessageTypeEMail --消息类型名
VALIDATION = WELL_FORMED_XML  --验证为标准xml格式

4.定义约定  定义约定名称为 ContractEMail 约定的所有者为dbo. SENT BY 用户指定哪个端点可以发送所指示的消息类型的消息.约定将记录服务可以用来拥有特定会话的消息.每个会话都有两个端点:发起方端点(启动会话的服务)和目标端点(发起方要联系的服务).ANY代表任意.

--定义约定（消息类型和传递方向）

USE ServerbrokerTest
GO
CREATE CONTRACT ContractEMail
AUTHORIZATION dbo
(MessageTypeEMail SENT BY ANY)

 

5.定义队列

--定义队列  消息发出队列
USE ServerbrokerTest
GO
CREATE QUEUE dbo.QueueSENDEMail

--定义队列  接收消息的队列
USE ServerbrokerTest
GO
CREATE QUEUE dbo.QueueRECEIVEEMail

 

 

6.定义服务

--定义服务，该服务为消息发出服务，使用消息发出队列
USE ServerbrokerTest
GO
CREATE SERVICE ServiceSendEMail
AUTHORIZATION dbo ON QUEUE dbo.QueueSENDEMail

--定义服务，该服务为消息接收服务，使用接收消息队列
USE ServerbrokerTest
GO
CREATE SERVICE ServiceReceiveEMail
AUTHORIZATION dbo ON QUEUE dbo.QueueRECEIVEEMail

 

7.定义路由

--由于这里使用的是同一个sqlServer 实例上的同一个数据库，所以可以使用默认的路由
USE ServerbrokerTest
GO
CREATE ROUTE autocreatedLocal
AUTHORIZATION dbo WITH ADDRESS = N'LOCAL'

 

8.编写主程序

在定义好上述Service broker 对象后，我们可以编写一段sql代码来完成消息异步传送和接收.

--编写主程序
--在定义好上述Service broker 对象后，我们可以编写一段sql代码来完成消息异步传送和接收
--开启事务
USE ServerbrokerTest
GO
BEGIN TRAN
--定义会话变量
DECLARE @dialogID uniqueIDentifIEr
DECLARE @emailmessage XML
--启动会话
BEGIN  DIALOG CONVERSATION @dialogID
 FROM SERVICE ServiceSendEMail
 TO SERVICE 'ServiceReceiveEMail'
 ON CONTRACT ContractEMail
 WITH ENCRYPTION =OFF  --加密功能关闭
 --定义消息变量及内容
 
 SET @emailmessage=N'<emailcontent>欢迎使用Service broker </emailcontent>';
 
 SEND ON CONVERSATION @dialogID
 MESSAGE TYPE MessageTypeEMail
 (@emailmessage);
--结束回话
END CONVERSATION @dialogID
--提交事务
COMMIT TRAN
--查询队列的内容]
 
SELECT * FROM   dbo.QueueSENDEMail
SELECT * FROM   dbo.QueueRECEIVEEMail

 

sqlServer2012上查询队列内容为空，不知道该怎么办？

总结

以上是内存溢出为你收集整理的SqlServer service broker 分布式系统（赵松涛）深入浅出 2005 数据库编程全部内容，希望文章能够帮你解决SqlServer service broker 分布式系统（赵松涛）深入浅出 2005 数据库编程所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。