标签：
首先了解service broker是什么东西：
Service Broker 为 SQL Server 提供队列和可靠的消息传递。Service Broker 既可用于使用单个 SQL Server 实例的应用程序，也可用于在多个实例间分发工作的应用程序。（在单个 SQL Server 实例内，Service Broker 提供了一个功能强大的异步编程模型。数据库应用程序通常使用异步编程来缩短交互式响应时间，并增加应用程序总吞吐量）
broker具备的基本要素：message type，contract，queue，service（少数还需要存储，路由，证书，账号等支持才可以完成整个传输）
关于实例间传输时候密钥的理解：
假设有A,B,C三人，这三个人每个人都有自己的证书，并且将自己的密钥备份出公钥部分，这样的话其他两个人都会有自己的公钥，而私钥却不能够导出，只能够自己拥有。当需要传输消息的时候，A---->B：此时此刻，A有自己的私钥与B的公钥，同理B也有自己的私钥与A的公钥，当A传输信息给B的时候，先将信息通过B的公钥加密，加密后传送给B，而此时此刻，加密的信息只有B的私钥才可以解码，所以是绝对安全的。同理，当B--->A的时候，也是同样的道理
关于队列的理解：
队列就是有头有尾，从尾部插入，从头部读出，期间的顺序是不可以调动的，只能够按照顺序区读取。两方的队列queue都具有收发功能，并且可以很快的处理，因为在传输过程中有一个队列transmission_queue来存储传输过程的信息。
关于证书账户理解：
所谓的证书虽然可以认证，但是是必须要绑定一个用户的，就是证书在创建之初必须绑定赋予一个用户（with no login），绑定用户才可以给予相关的权限。
1：创建目标数据库
CREATE MESSAGE TYPE [//BothDB/2InstSample/RequestMessage] VALIDATION = WELL_FORMED_XML;
CREATE MESSAGE TYPE [//BothDB/2InstSample/ReplyMessage] VALIDATION = WELL_FORMED_XML; GO
创建消息类型必须的
CREATE CONTRACT [//BothDB/2InstSample/SimpleContract] ([//BothDB/2InstSample/RequestMessage] SENT BY INITIATOR, [//BothDB/2InstSample/ReplyMessage] SENT BY TARGET ); GO
创建约定也是必须的
CREATE QUEUE InstTargetQueue; CREATE SERVICE [//TgtDB/2InstSample/TargetService] AUTHORIZATION TargetUser ON QUEUE InstTargetQueue ([//BothDB/2InstSample/SimpleContract]); GO
创建目标队列以及服务，这个也是必须的，毋庸置疑啊。
2：创建发起方数据库
USE master; GO
IF EXISTS (SELECT * FROM sys.endpoints WHERE name = N‘InstInitiatorEndpoint‘)
DROP ENDPOINT InstInitiatorEndpoint; GO
CREATE ENDPOINT InstInitiatorEndpoint
STATE = STARTED AS TCP ( LISTENER_PORT = 4022 ) FOR SERVICE_BROKER (AUTHENTICATION = WINDOWS ); GO
同理先创建一个端点
USE master; GO
IF EXISTS (SELECT * FROM sys.databases WHERE name = N‘InstInitiatorDB‘)
DROP DATABASE InstInitiatorDB; GO
CREATE DATABASE InstInitiatorDB; GO USE InstInitiatorDB; GO
CREATE MASTER KEY ENCRYPTION BY PASSWORD = N‘‘; GO
CREATE USER InitiatorUser WITHOUT LOGIN; GO
（发起方数据库，主密钥以及用户）
CREATE CERTIFICATE InstInitiatorCertificate AUTHORIZATION InitiatorUser WITH SUBJECT = N‘Initiator Certificate‘, EXPIRY_DATE = N‘12/31/2010‘;
BACKUP CERTIFICATE InstInitiatorCertificate TO FILE = N‘C:\storedcerts\$ampleSSBCerts\InstInitiatorCertificate.cer‘; GO
（创建发起方的证书，并且备份出公钥）
CREATE MESSAGE TYPE [//BothDB/2InstSample/RequestMessage] VALIDATION = WELL_FORMED_XML;
CREATE MESSAGE TYPE [//BothDB/2InstSample/ReplyMessage] VALIDATION = WELL_FORMED_XML; GO
CREATE CONTRACT [//BothDB/2InstSample/SimpleContract] ([//BothDB/2InstSample/RequestMessage] SENT BY INITIATOR, [//BothDB/2InstSample/ReplyMessage] SENT BY TARGET ); GO
CREATE QUEUE InstInitiatorQueue;
CREATE SERVICE [//InstDB/2InstSample/InitiatorService] AUTHORIZATION InitiatorUser ON QUEUE InstInitiatorQueue; GO
（创建消息类型，约定，队列以及数据库service）
CREATE USER TargetUser WITHOUT LOGIN;
CREATE CERTIFICATE InstTargetCertificate AUTHORIZATION TargetUser FROM FILE = N‘C:\storedcerts\$ampleSSBCerts\InstTargetCertificate.cer‘ GO
（对目标对象的引用，此处这个证书的路径就是我们第一次备份出来的那个证书，我们将他拷贝出来到现在的主机上面路径，这样我们就可以拥有目标数据库的公钥，可以加密传输给另一台主机的消息，注意这里创建用户的名字是和我们要使用的证书公钥绑定的用户的名字是一致的，这样才可以进行加解密传输）
DECLARE @Cmd NVARCHAR(4000);
SET @Cmd = N‘USE InstInitiatorDB; CREATE ROUTE InstTargetRoute WITH SERVICE_NAME = N‘‘//TgtDB/2InstSample/TargetService‘‘, ADDRESS = N‘‘TCP://MyTargetComputer:4022‘‘;‘;
EXEC (@Cmd);
SET @Cmd = N‘USE msdb CREATE ROUTE InstInitiatorRoute WITH SERVICE_NAME = N‘‘//InstDB/2InstSample/InitiatorService‘‘, ADDRESS = N‘‘LOCAL‘‘‘;
EXEC (@Cmd); GO
CREATE REMOTE SERVICE BINDING TargetBinding TO SERVICE N‘//TgtDB/2InstSample/TargetService‘ WITH USER = TargetUser; GO
（创建路由，此处我们要注意的就是红色部分，我们可以使用主机名字或者主机IP都是可以的）
3：完成目标会话对象
USE InstTargetDB GO
CREATE USER InitiatorUser WITHOUT LOGIN;
CREATE CERTIFICATE InstInitiatorCertificate AUTHORIZATION InitiatorUser FROM FILE = N‘C:\storedcerts\$ampleSSBCerts\InstInitiatorCertificate.cer‘; GO
（创建引用，这个你懂得）
DECLARE @Cmd NVARCHAR(4000);
SET @Cmd = N‘USE InstTargetDB; CREATE ROUTE InstInitiatorRoute WITH SERVICE_NAME = N‘‘//InstDB/2InstSample/InitiatorService‘‘, ADDRESS = N‘‘TCP://MyInitiatorComputer:4022‘‘;‘; EXEC (@Cmd);
SET @Cmd = N‘USE msdb CREATE ROUTE InstTargetRoute WITH SERVICE_NAME = N‘‘//TgtDB/2InstSample/TargetService‘‘, ADDRESS = N‘‘LOCAL‘‘‘;
EXEC (@Cmd); GO
GRANT SEND ON SERVICE::[//TgtDB/2InstSample/TargetService] TO InitiatorUser; GO
CREATE REMOTE SERVICE BINDING InitiatorBinding TO SERVICE N‘//InstDB/2InstSample/InitiatorService‘ WITH USER = InitiatorUser; GO
(创建路由协议，与发起方创建的是一样一样的)
4：启动会话
USE InstInitiatorDB; GO
DECLARE @InitDlgHandle UNIQUEIDENTIFIER;
DECLARE @RequestMsg NVARCHAR(100);
BEGIN TRANSACTION;
BEGIN DIALOG @InitDlgHandle FROM SERVICE [//InstDB/2InstSample/InitiatorService] TO SERVICE N‘//TgtDB/2InstSample/TargetService‘ ON CONTRACT [//BothDB/2InstSample/SimpleContract] WITH ENCRYPTION = ON;
SELECT @RequestMsg = N‘Message for Target service.‘;
SEND ON CONVERSATION @InitDlgHandle MESSAGE TYPE [//BothDB/2InstSample/RequestMessage] (@RequestMsg);
SELECT @RequestMsg AS SentRequestMsg;
COMMIT TRANSACTION;
GO
（直接运行就可以）
5：接受请求并且发送答复
USE InstTargetDB; GO
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER;
DECLARE @RecvReqMsg NVARCHAR(100);
DECLARE @RecvReqMsgName sysname;
BEGIN TRANSACTION;
WAITFOR ( RECEIVE TOP(1) @RecvReqDlgHandle = conversation_handle, @RecvReqMsg = message_body, @RecvReqMsgName = message_type_name FROM InstTargetQueue ), TIMEOUT 1000;
SELECT @RecvReqMsg AS ReceivedRequestMsg;
IF @RecvReqMsgName = N‘//BothDB/2InstSample/RequestMessage‘
BEGIN
DECLARE @ReplyMsg NVARCHAR(100);
SELECT @ReplyMsg = N‘Message for Initiator service.‘;
SEND ON CONVERSATION @RecvReqDlgHandle MESSAGE TYPE [//BothDB/2InstSample/ReplyMessage] (@ReplyMsg);
END CONVERSATION @RecvReqDlgHandle;
END
SELECT @ReplyMsg AS SentReplyMsg;
COMMIT TRANSACTION; GO
DECLARE @RecvReplyMsg NVARCHAR(100);
DECLARE @RecvReplyDlgHandle UNIQUEIDENTIFIER;
BEGIN TRANSACTION;
WAITFOR ( RECEIVE TOP(1) @RecvReplyDlgHandle = conversation_handle, @RecvReplyMsg = message_body FROM InstInitiatorQueue ), TIMEOUT 1000;
END CONVERSATION @RecvReplyDlgHandle;
-- Display recieved request.
S
标签：
原文地址：http://www.cnblogs.com/shengdimaya/p/5403938.html
