--Service broker示例
--下面将创建一个向数据库添加员工的简单示例。
--需求是能够让初级人力资源员工向公司的人力资源系统添加记录。因为它的经理需要在记录得到一个永远的ID之前查看记录，我们决定创建的应用程序把接收的记录在被审查之前都放在一个“贮藏”表中。
---在我的测试系统上，我创建了一个只含有Employee表的serviceBrokerExample数据库。那个表只含有一个名为EmployeeInfo的列，它的数据类型为XML，这是我应用程序接受的格式。利用以下代码可以在
--测试系统上创建这些对像：
--create db
--create database servicebrokerexample
go
--create table
use servicebrokerexample
go
create table employee
(
employeeinfo xml null
) on [primary]
go
--创建了这些后，就可以创建系统使用的消息类型了。这里我指定类型以确保数据是适当的XML格式，但在生产环境中通常需要引用一个完整的XML架构文件：
create message type
[serviceBroker/example/employee/addEmployee]
validation=well_formed_xml
--现在可以创建系统使用的约定了，会话的每一方都有。可以看出，其中使用了刚刚创建的AddEmployee消息类型：
create contract
[serviceBroker/example/employee/addEmployeeContract]
(
[serviceBroker/example/employee/addEmployee]
Sent by initiator
)
go
--下面就是我的从队列读取数据并插入到数据库的存储过程。这里使用的是XML转换函数把数据放置到数据库。有两个存储过程：其中一个插入，另一个检查并清空队列。
create proc addEmployee
@mb xml
as
insert into employee(employeeinfo)
values(@mb)
go

--读取队列的存储过程如下：
create proc ProcessEmployee
as
begin
    begin tran
        declare @ch uniqueidentifier
        declare @mb varbinary(max)
        waitfor
        (
        receive top (1) @ch=conversation_handle,@mb=message_body
            from employeequeue
        ),
        timeout 1500

        execute addEmployee @mb
        end conversation @ch
    commit tran

end
--员工就位后需要创建存储数据的队列。创建队列时，需要关联一个用来处理它的服务程序(在本例中就是存储过程)
create queue [employeequeue]
with status=on,
activation
(
procedure_name=ProcessEmployee,
max_queue_readers=5,
execute as self
)
go
--现在差不多了，接下来需要创建应答会话请求的服务，并把它与前面的约定关联起来：
create service addemployeeservice
on queue [employeequeue]
(
[serviceBroker/example/employee/addEmployeeContract]
)
go
--现在系统准备好了，可以使用使用sql server management studio 检查这些对像。
--当服务器准备好service broker会话后，就可以开始一个完整的示例事件了。
--代码如下：发送
declare @ch uniqueidentifier
declare @employeename xml
set @employeename='<name>mary</name>'

begin dialog conversation @ch
from service addemployeeservice
to service
'[serviceBroker/example/employee/addEmployeeContract]'
on contract
[serviceBroker/example/employee/addEmployeeContract];

send on conversation @ch
message type
[serviceBroker/example/employee/addEmployee] (@employeename)

go

---接收
GO

DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER;
DECLARE @RecvReqMsg NVARCHAR(100);
DECLARE @RecvReqMsgName sysname;


RECEIVE TOP(1)
    @RecvReqDlgHandle = conversation_handle,
    @RecvReqMsg = message_body,
    @RecvReqMsgName = message_type_name
FROM [employeequeue];

SELECT @RecvReqMsg AS ReceivedRequestMsg;

IF @RecvReqMsgName =
   N'serviceBroker/example/employee/addEmployee'
BEGIN
     DECLARE @ReplyMsg NVARCHAR(100);
     SELECT @ReplyMsg =
     N'<ReplyMsg>Message for Initiator service.</ReplyMsg>';
 
     SEND ON CONVERSATION @RecvReqDlgHandle
          MESSAGE TYPE
          [serviceBroker/example/employee/addEmployee]
          (@ReplyMsg);

     END CONVERSATION @RecvReqDlgHandle;
END

SELECT @ReplyMsg AS SentReplyMsg;


--要检查的话，可以使用动态管理视图

select * from sys.dm_broker_activated_tasks
select * from sys.dm_broker_connections
select * from sys.dm_broker_forwarded_messages
select * from sys.dm_broker_queue_monitors
go
select * from employee
go
SELECT * FROM [dbo].[employeequeue]

GO