|
1.创建测试数据库
create database ServerbrokerTest
on primary(
name=ServerbrokerTest_data,
filename='C:Program FilesMicrosoft SQL ServerMSSQL11.SQLEXPRESSMSSQLDATAServerbrokerTest_data.mdf',
size=5,
maxsize=unlimited,
filegrowth=1
)
Log on
(
name=student_log,
filename='C:Program FilesMicrosoft SQL ServerMSSQL11.SQLEXPRESSMSSQLDATAServerbrokerTest_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上查询队列内容为空，不知道该怎么办？
（编辑：李大同）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!
|
