程Service Broker實(shí)現(xiàn))
SQL Server 2008中SQL應(yīng)用系列--目錄索引上文SQL Server 2008中Service Broker基礎(chǔ)應(yīng)用上、SQL Server 2008中Service Broker基礎(chǔ)應(yīng)用下演示了在同一個(gè)SQL Server實(shí)例的不同數(shù)據(jù)庫之間實(shí)現(xiàn)Service Broker其實(shí)更常見的是在不同的SQL Server實(shí)例之間進(jìn)行通信本文將通過實(shí)例演示如何進(jìn)行Service Broker遠(yuǎn)程通信。以下是實(shí)現(xiàn)遠(yuǎn)程Service Broker的基本步驟一、啟用傳輸安全二、啟用對話安全三、創(chuàng)建路由四、創(chuàng)建遠(yuǎn)程服務(wù)綁定下圖顯示的是兩個(gè) SQL Server 實(shí)例間的 Service Broker 網(wǎng)絡(luò)通信的高級視圖。準(zhǔn)備工作/************************************************************/ ------遠(yuǎn)程Service Broker ------ 3wlive.cn -----源服務(wù)器實(shí)例,在本例中為ap4/agronet09 USE master GO -- Enable Service Broker for the database ALTER DATABASE BookStore SET ENABLE_BROKER GO ALTER DATABASE BookStore SET TRUSTWORTHY ON GO USE BookStore GO -- Create the messages CREATE MESSAGE TYPE [//SackConsulting/SendBookOrder] VALIDATION WELL_FORMED_XML GO CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived] VALIDATION WELL_FORMED_XML GO -- Create the contract CREATE CONTRACT [//SackConsulting/BookOrderContract] ( [//SackConsulting/SendBookOrder] SENT BY INITIATOR, [//SackConsulting/BookOrderReceived] SENT BY TARGET ) GO -- Create the queue CREATE QUEUE BookStoreQueue WITH STATUSON GO -- Create the service CREATE SERVICE [//SackConsulting/BookOrderService] ON QUEUE dbo.BookStoreQueue ([//SackConsulting/BookOrderContract]) GO -----目標(biāo)服務(wù)器實(shí)例,在本例中為ap2/agronetserver USE master GO IF NOT EXISTS (SELECT name FROM sys.databases WHERE name BookDistribution) CREATE DATABASE BookDistribution GO -- Enable Service Broker for the database ALTER DATABASE BookDistribution SET ENABLE_BROKER GO ALTER DATABASE BookDistribution SET TRUSTWORTHY ON GO USE BookDistribution GO -- Create the messages CREATE MESSAGE TYPE [//SackConsulting/SendBookOrder] VALIDATION WELL_FORMED_XML GO CREATE MESSAGE TYPE [//SackConsulting/BookOrderReceived] VALIDATION WELL_FORMED_XML GO -- Create the contract CREATE CONTRACT [//SackConsulting/BookOrderContract] ( [//SackConsulting/SendBookOrder] SENT BY INITIATOR, [//SackConsulting/BookOrderReceived] SENT BY TARGET ) GO -- Create the queue CREATE QUEUE BookDistributionQueue WITH STATUSON GO -- Create the service CREATE SERVICE [//SackConsulting/BookDistributionService] ON QUEUE dbo.BookDistributionQueue ([//SackConsulting/BookOrderContract]) GO一、啟用傳輸安全在Service Broker的安全傳輸是指兩個(gè)SQL Server實(shí)例之間進(jìn)行網(wǎng)絡(luò)連接時(shí)啟用或限制它們之間的加密通信。傳輸安全是在SQL Server實(shí)例級別因此這個(gè)示例演示如何創(chuàng)建在兩個(gè)SQL Server實(shí)例的主數(shù)據(jù)庫對象。您可以選擇兩種形式的運(yùn)輸安全Windows身份驗(yàn)證或基于證書的安全認(rèn)證。-- Enabling Transport Security -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE master GO CREATE MASTER KEY ENCRYPTION BY PASSWORD 1294934A! -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE master GO CREATE MASTER KEY ENCRYPTION BY PASSWORD 1294934B! -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 CREATE CERTIFICATE AP4MasterCert WITH SUBJECT Ap4 Transport Security SB, EXPIRY_DATE 5/4/2012 GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver CREATE CERTIFICATE AP2MasterCert WITH SUBJECT AP2 Transport Security SB, EXPIRY_DATE 5/4/2012 GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 BACKUP CERTIFICATE AP4MasterCert TO FILE H:/SqlBackup/AP4MasterCert.cer GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver BACKUP CERTIFICATE AP2MasterCert TO FILE H:/SqlBackup/AP2MasterCert.cer GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 CREATE ENDPOINT SB_AP4_Endpoint STATE STARTED AS TCP (LISTENER_PORT 4020) FOR SERVICE_BROKER (AUTHENTICATION CERTIFICATE AP4MasterCert, ENCRYPTION REQUIRED) GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver CREATE ENDPOINT SB_AP2_Endpoint STATE STARTED AS TCP (LISTENER_PORT 4021) FOR SERVICE_BROKER (AUTHENTICATION CERTIFICATE AP2MasterCert, ENCRYPTION REQUIRED) GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 CREATE LOGIN SBLogin WITH PASSWORD Used4TransSec GO CREATE USER SBUser FOR LOGIN SBLogin GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver CREATE LOGIN SBLogin WITH PASSWORD Used4TransSec GO CREATE USER SBUser FOR LOGIN SBLogin GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 GRANT CONNECT ON Endpoint::SB_AP4_Endpoint TO SBLogin GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver GRANT CONNECT ON Endpoint::SB_AP2_Endpoint TO SBLogin GO ----在源實(shí)例上執(zhí)行 Ap4/agronet09 ----需要從AP2上復(fù)制到AP4下H:/SqlBackup,邀月注 CREATE CERTIFICATE AP2MasterCert AUTHORIZATION SBUser FROM FILE H:/SqlBackup/AP2MasterCert.cer GO ---- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver ----需要從AP4上復(fù)制到AP2下H:/SqlBackup邀月注 CREATE CERTIFICATE AP4MasterCert AUTHORIZATION SBUser FROM FILE H:/SqlBackup/AP4MasterCert.cer GO二、啟用對話安全設(shè)置安全對話的詳細(xì)用法請參看MSDN:Service Broker 對話安全設(shè)置 | Microsoft Learn。/***********************************************************************/ -- Enabling Dialog Security -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO CREATE MASTER KEY ENCRYPTION BY PASSWORD 1294934A! GO CREATE CERTIFICATE BookStoreCert WITH SUBJECT BookStore SB cert, EXPIRY_DATE 5/4/2012 GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO CREATE MASTER KEY ENCRYPTION BY PASSWORD 1294934B! GO CREATE CERTIFICATE BookDistributionCert WITH SUBJECT BookDistributionCert SB cert, EXPIRY_DATE 5/4/2012 GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO BACKUP CERTIFICATE BookStoreCert TO FILE H:/SqlBackup/BookStoreCert.cer GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO BACKUP CERTIFICATE BookDistributionCert TO FILE H:/SqlBackup/BookDistributionCert.cer GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO CREATE USER BookDistributionUser WITHOUT LOGIN GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO CREATE USER BookStoreUser WITHOUT LOGIN GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 ----需要從AP2上復(fù)制到AP4下H:/SqlBackup,邀月注 USE BookStore GO CREATE CERTIFICATE BookDistributionCert AUTHORIZATION BookDistributionUser FROM FILE H:/SqlBackup/BookDistributionCert.cer GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver ----需要從AP4上復(fù)制到AP2下H:/SqlBackup邀月注 USE BookDistribution GO CREATE CERTIFICATE BookStoreCert AUTHORIZATION BookStoreUser FROM FILE H:/SqlBackup/BookStoreCert.cer GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO GRANT SEND ON SERVICE::[//SackConsulting/BookOrderService] TO BookDistributionUser GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO GRANT SEND ON SERVICE::[//SackConsulting/BookDistributionService] TO BookStoreUser三、創(chuàng)建路由使用命令CREATE ROUTEhttp://msdn.microsoft.com/en-us/library/ms186742.aspx創(chuàng)建路由/************************創(chuàng)建路由 3wlive.cn****************/ -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO CREATE ROUTE Route_BookDistribution WITH SERVICE_NAME //SackConsulting/BookDistributionService, ADDRESS TCP://192.168.1.99:4021 GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO ----SERVICE BROKER 609 CREATE ROUTE Route_BookStore WITH SERVICE_NAME //SackConsulting/BookOrderService, ADDRESS TCP://192.168.1.6:4020 GO四、創(chuàng)建遠(yuǎn)程服務(wù)綁定使用命令CREATE REMOTE SERVICE BINDINGCREATE REMOTE SERVICE BINDING (Transact-SQL) - SQL Server | Microsoft Learn創(chuàng)建遠(yuǎn)程服務(wù)綁定/*********************創(chuàng)建遠(yuǎn)程服務(wù)綁定 3wlive.cn ***********/ -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 USE BookStore GO CREATE REMOTE SERVICE BINDING BookDistributionBinding TO SERVICE //SackConsulting/BookDistributionService WITH USER BookDistributionUser GO -- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO CREATE REMOTE SERVICE BINDING BookStoreBinding TO SERVICE //SackConsulting/BookOrderService WITH USER BookStoreUser GO -- 在源實(shí)例上執(zhí)行 Ap4/agronet09 Use BookStore GO DECLARE Conv_Handler uniqueidentifier DECLARE OrderMsg xml; BEGIN DIALOG CONVERSATION Conv_Handler FROM SERVICE [//SackConsulting/BookOrderService] TO SERVICE //SackConsulting/BookDistributionService ON CONTRACT [//SackConsulting/BookOrderContract]; SET OrderMsg order id3439 customer22 orderdate9/25/2008 LineItem ItemNumber22 ISBN1-59059-592-0 Quantity10 / /order; SEND ON CONVERSATION Conv_Handler MESSAGE TYPE [//SackConsulting/SendBookOrder] (OrderMsg);查看結(jié)果-- 在目標(biāo)實(shí)例上執(zhí)行 Ap2/agronetserver USE BookDistribution GO SELECT message_type_name, CAST(message_body as xml) message, queuing_order, conversation_handle, conversation_group_id FROM dbo.BookDistributionQueue最終結(jié)果參考1、Service Broker 通信協(xié)議 Service Broker 通信協(xié)議 | Microsoft Learn下文將介紹SQL Server 2008中新增的很酷的功能Service broker事件通知。邀月注本文版權(quán)由邀月和CSDN共同所有轉(zhuǎn)載請注明出處。助人等于自助!3wlive.cn