如何:設定訂閱使用 Web 同步處理 (RMO 程式設計)
本主題中的程序,是設定合併式複寫的 Web 同步處理時所採取的第三個步驟。在啟用發行集及設定執行 Microsoft Internet Information Services (IIS) 的電腦之後,必須執行這個步驟。如需組態處理序的概觀,請參閱<如何:為合併式複寫設定 Web 同步處理 (RMO 程式設計)>。當您針對只能透過 HTTP 連接到發行者的訂閱者設定訂閱使用 Web 同步處理時,您必須適當地設定發行集。如需詳細資訊,請參閱<如何:設定發行集來允許 Web 同步處理 (RMO 程式設計)>。當您完成本主題中的程序之後,請同步處理您已建立的訂閱。如需詳細資訊,請參閱<如何:同步處理提取訂閱 (RMO 程式設計)>。
本主題將描述 Web 同步處理所需的參數。如需有關如何建立提取訂閱的詳細資訊,請參閱<如何:建立提取訂閱 (RMO 程式設計)>。
重要事項 |
---|
用於 Web 同步處理之 Web 伺服器的 URL (例如 https://server.domain.com/directory/replisapi.dll) 會指定 replisapi.dll 的位置。如果設定伺服器針對安全通訊端層 (SSL) 使用預設通訊埠 443 以外的通訊埠,您也必須提供通訊埠:https://server.domain.com:PortNumber/directory/replisapi.dll。URL 中的伺服器名稱必須與建立憑證時所用的名稱相同。例如,在內部網路中,您可以透過 https://server/ 來存取 Web 伺服器。但是,如果在建立憑證時使用了完整名稱 (例如 https://server.domain.com/),您就必須在 URL 中使用以下完整名稱:(https://server.domain.com/directory/replisapi.dll)。 |
設定訂閱使用 Web 同步處理
使用 ServerConnection 類別建立與訂閱者和發行者的連接。
使用步驟 1 中的發行者連接建立 MergePublication 類別的執行個體。
(選擇性) 如果訂閱資料庫不存在,請使用 SQL Server Management Objects (SMO) Database 類別建立此資料庫。如需詳細資訊,請參閱<建立、改變和移除資料庫>。
建立 MergePullSubscription 類別的執行個體。
設定下列訂閱屬性:
將 ConnectionContext 設為步驟 1 中建立之訂閱者的 ServerConnection。
將 DatabaseName 設為訂閱資料庫的名稱。
將 PublisherName 設為「發行者」的名稱。
將 PublicationDBName 設為發行集資料庫的名稱。
將 PublicationName 設為發行集的名稱。
將 UseWebSynchronization 設為 true 的值。
將 InternetUrl 設為主控 Web 同步處理之 Web 伺服器的位置。
將 SynchronizationAgentProcessSecurity 的 Login 和 Password 欄位分別設定為合併代理程式在訂閱者上執行時所使用之 Windows 帳戶的登入和密碼。當合併代理程式與本機訂閱者連接時,也會使用這個帳戶。
[!附註]
當發行集是由 sysadmin 固定伺服器角色的成員所建立時,不需要設定 SnapshotGenerationAgentProcessSecurity。如需詳細資訊,請參閱<複寫代理程式安全性模型>。
將 InternetSecurityMode 設定為 0 的值,並在使用 HTTP 基本驗證存取 Web 伺服器時,設定 InternetLogin 和 InternetPassword 的值。我們建議您針對 Web 同步處理使用這個驗證方法。如需詳細資訊,請參閱<保護透過網際網路的複寫>。
呼叫 Create 方法。
使用步驟 2 中 MergePublication 的執行個體,呼叫 MakePullSubscriptionWellKnown 方法,以便向發行者註冊提取訂閱。
當您針對只能透過 HTTP 的 Web 伺服器連接到發行者的訂閱者來設定訂閱使用 Web 同步處理時
使用 ServerConnection 類別建立與訂閱者的連接。
(選擇性) 如果訂閱資料庫不存在,可使用 SMO Database 類別建立此資料庫。如需詳細資訊,請參閱<建立、改變和移除資料庫>。
建立 MergePullSubscription 類別的執行個體。
設定下列訂閱屬性:
將 ConnectionContext 設定為步驟 1 中建立的 ServerConnection。
將 DatabaseName 設為訂閱資料庫的名稱。
將 PublisherName 設為「發行者」的名稱。
將 PublicationDBName 設為發行集資料庫的名稱。
將 PublicationName 設為發行集的名稱。
將 SubscriberType 設定為 Anonymous 的值。
將 UseWebSynchronization 設為 true 的值。
將 InternetUrl 設為主控 Web 同步處理之 Web 伺服器的位置。
將 SynchronizationAgentProcessSecurity 的 Login 和 Password 欄位分別設定為合併代理程式在訂閱者上執行時所使用之 Windows 帳戶的登入和密碼。當合併代理程式與本機訂閱者連接時,也會使用這個帳戶。
[!附註]
當發行集是由 sysadmin 固定伺服器角色的成員所建立時,不需要設定 SnapshotGenerationAgentProcessSecurity。如需詳細資訊,請參閱<複寫代理程式安全性模型>。
將 InternetSecurityMode 設定為 0 的值,並在使用 HTTP 基本驗證存取 Web 時,設定 InternetLogin 和 InternetPassword 的值。我們建議您針對 Web 同步處理使用這個驗證方法。如需詳細資訊,請參閱<保護透過網際網路的複寫>。
呼叫 Create 方法。
範例
下列範例會使用 Web 同步處理來建立與發行者同步處理的訂閱。
// Define the Publisher, publication, and databases.
string publicationName = "AdvWorksSalesOrdersMerge";
string publisherName = publisherInstance;
string subscriberName = subscriberInstance;
string subscriptionDbName = "AdventureWorks2008R2Replica";
string publicationDbName = "AdventureWorks2008R2";
string hostname = @"adventure-works\garrett1";
string webSyncUrl = "https://" + publisherInstance + "/WebSync/replisapi.dll";
//Create connections to the Publisher and Subscriber.
ServerConnection subscriberConn = new ServerConnection(subscriberName);
ServerConnection publisherConn = new ServerConnection(publisherName);
// Create the objects that we need.
MergePublication publication;
MergePullSubscription subscription;
try
{
// Connect to the Subscriber.
subscriberConn.Connect();
// Ensure that the publication exists and that
// it supports pull subscriptions and Web synchronization.
publication = new MergePublication();
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
publication.ConnectionContext = publisherConn;
if (publication.LoadProperties())
{
if ((publication.Attributes & PublicationAttributes.AllowPull) == 0)
{
publication.Attributes |= PublicationAttributes.AllowPull;
}
if ((publication.Attributes & PublicationAttributes.AllowWebSynchronization) == 0)
{
publication.Attributes |= PublicationAttributes.AllowWebSynchronization;
}
// Define the pull subscription.
subscription = new MergePullSubscription();
subscription.ConnectionContext = subscriberConn;
subscription.PublisherName = publisherName;
subscription.PublicationName = publicationName;
subscription.PublicationDBName = publicationDbName;
subscription.DatabaseName = subscriptionDbName;
subscription.HostName = hostname;
// Specify the Windows login credentials for the Merge Agent job.
subscription.SynchronizationAgentProcessSecurity.Login = winLogin;
subscription.SynchronizationAgentProcessSecurity.Password = winPassword;
// Enable Web synchronization.
subscription.UseWebSynchronization = true;
subscription.InternetUrl = webSyncUrl;
// Specify the same Windows credentials to use when connecting to the
// Web server using HTTPS Basic Authentication.
subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication;
subscription.InternetLogin = winLogin;
subscription.InternetPassword = winPassword;
// Ensure that we create a job for this subscription.
subscription.CreateSyncAgentByDefault = true;
// Create the pull subscription at the Subscriber.
subscription.Create();
Boolean registered = false;
// Verify that the subscription is not already registered.
foreach (MergeSubscription existing
in publication.EnumSubscriptions())
{
if (existing.SubscriberName == subscriberName
&& existing.SubscriptionDBName == subscriptionDbName
&& existing.SubscriptionType == SubscriptionOption.Pull)
{
registered = true;
}
}
if (!registered)
{
// Register the local subscription with the Publisher.
publication.MakePullSubscriptionWellKnown(
subscriberName, subscriptionDbName,
SubscriptionSyncType.Automatic,
MergeSubscriberType.Local, 0);
}
}
else
{
// Do something here if the publication does not exist.
throw new ApplicationException(String.Format(
"The publication '{0}' does not exist on {1}.",
publicationName, publisherName));
}
}
catch (Exception ex)
{
// Implement the appropriate error handling here.
throw new ApplicationException(String.Format(
"The subscription to {0} could not be created.", publicationName), ex);
}
finally
{
subscriberConn.Disconnect();
publisherConn.Disconnect();
}
' Define the Publisher, publication, and databases.
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publisherName As String = publisherInstance
Dim subscriberName As String = subscriberInstance
Dim subscriptionDbName As String = "AdventureWorks2008R2Replica"
Dim publicationDbName As String = "AdventureWorks2008R2"
Dim hostname As String = "adventure-works\garrett1"
Dim webSyncUrl As String = "https://" + publisherInstance + "/WebSync/replisapi.dll"
'Create connections to the Publisher and Subscriber.
Dim subscriberConn As ServerConnection = New ServerConnection(subscriberName)
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)
' Create the objects that we need.
Dim publication As MergePublication
Dim subscription As MergePullSubscription
Try
' Connect to the Subscriber.
subscriberConn.Connect()
' Ensure that the publication exists and that
' it supports pull subscriptions and Web synchronization.
publication = New MergePublication()
publication.Name = publicationName
publication.DatabaseName = publicationDbName
publication.ConnectionContext = publisherConn
If publication.LoadProperties() Then
If (publication.Attributes And PublicationAttributes.AllowPull) = 0 Then
publication.Attributes = publication.Attributes _
Or PublicationAttributes.AllowPull
End If
If (publication.Attributes And PublicationAttributes.AllowWebSynchronization) = 0 Then
publication.Attributes = publication.Attributes _
Or PublicationAttributes.AllowWebSynchronization
End If
' Define the pull subscription.
subscription = New MergePullSubscription()
subscription.ConnectionContext = subscriberConn
subscription.PublisherName = publisherName
subscription.PublicationName = publicationName
subscription.PublicationDBName = publicationDbName
subscription.DatabaseName = subscriptionDbName
subscription.HostName = hostname
subscription.CreateSyncAgentByDefault = True
' Specify the Windows login credentials for the Merge Agent job.
subscription.SynchronizationAgentProcessSecurity.Login = winLogin
subscription.SynchronizationAgentProcessSecurity.Password = winPassword
' Enable Web synchronization.
subscription.UseWebSynchronization = True
subscription.InternetUrl = webSyncUrl
' Specify the same Windows credentials to use when connecting to the
' Web server using HTTPS Basic Authentication.
subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication
subscription.InternetLogin = winLogin
subscription.InternetPassword = winPassword
' Create the pull subscription at the Subscriber.
subscription.Create()
Dim registered As Boolean = False
' Verify that the subscription is not already registered.
For Each existing As MergeSubscription In _
publication.EnumSubscriptions()
If existing.SubscriberName = subscriberName Then
registered = True
End If
Next
If Not registered Then
' Register the local subscription with the Publisher.
publication.MakePullSubscriptionWellKnown( _
subscriberName, subscriptionDbName, _
SubscriptionSyncType.Automatic, _
MergeSubscriberType.Local, 0)
End If
Else
' Do something here if the publication does not exist.
Throw New ApplicationException(String.Format( _
"The publication '{0}' does not exist on {1}.", _
publicationName, publisherName))
End If
Catch ex As Exception
' Implement the appropriate error handling here.
Throw New ApplicationException(String.Format( _
"The subscription to {0} could not be created.", publicationName), ex)
Finally
subscriberConn.Disconnect()
publisherConn.Disconnect()
End Try
這個範例會針對只能透過 HTTP 的 Web 伺服器連接到發行者的訂閱者,使用 Web 同步處理來建立與發行者同步處理的訂閱。
// The publication must support anonymous Subscribers, pull
// subscriptions, and Web synchronization.
// Define the Publisher, publication, and databases.
string publicationName = "AdvWorksSalesOrdersMerge";
string publisherName = publisherInstance;
string subscriberName = subscriberInstance;
string subscriptionDbName = "AdventureWorks2008R2Replica";
string publicationDbName = "AdventureWorks2008R2";
string hostname = @"adventure-works\garrett1";
string webSyncUrl = "https://" + publisherInstance + "/WebSync/replisapi.dll";
//Create the Subscriber connection.
ServerConnection conn = new ServerConnection(subscriberName);
// Create the objects that we need.
MergePullSubscription subscription;
try
{
// Connect to the Subscriber.
conn.Connect();
// Define the pull subscription.
subscription = new MergePullSubscription();
subscription.ConnectionContext = conn;
subscription.PublisherName = publisherName;
subscription.PublicationName = publicationName;
subscription.PublicationDBName = publicationDbName;
subscription.DatabaseName = subscriptionDbName;
subscription.HostName = hostname;
// Specify an anonymous Subscriber type since we can't
// register at the Publisher with a direct connection.
subscription.SubscriberType = MergeSubscriberType.Anonymous;
// Specify the Windows login credentials for the Merge Agent job.
subscription.SynchronizationAgentProcessSecurity.Login = winLogin;
subscription.SynchronizationAgentProcessSecurity.Password = winPassword;
// Enable Web synchronization.
subscription.UseWebSynchronization = true;
subscription.InternetUrl = webSyncUrl;
// Specify the same Windows credentials to use when connecting to the
// Web server using HTTPS Basic Authentication.
subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication;
subscription.InternetLogin = winLogin;
subscription.InternetPassword = winPassword;
// Ensure that we create a job for this subscription.
subscription.CreateSyncAgentByDefault = true;
// Create the pull subscription at the Subscriber.
subscription.Create();
}
catch (Exception ex)
{
// Implement the appropriate error handling here.
throw new ApplicationException(String.Format(
"The subscription to {0} could not be created.", publicationName), ex);
}
finally
{
conn.Disconnect();
}
' The publication must support anonymous Subscribers, pull
' subscriptions, and Web synchronization.
' Define the Publisher, publication, and databases.
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publisherName As String = publisherInstance
Dim subscriberName As String = subscriberInstance
Dim subscriptionDbName As String = "AdventureWorks2008R2Replica"
Dim publicationDbName As String = "AdventureWorks2008R2"
Dim hostname As String = "adventure-works\\garrett1"
Dim webSyncUrl As String = "https://" + publisherInstance + "/WebSync/replisapi.dll"
'Create the Subscriber connection.
Dim conn As ServerConnection = New ServerConnection(subscriberName)
' Create the objects that we need.
Dim subscription As MergePullSubscription
Try
' Connect to the Subscriber.
conn.Connect()
' Define the pull subscription.
subscription = New MergePullSubscription()
subscription.ConnectionContext = conn
subscription.PublisherName = publisherName
subscription.PublicationName = publicationName
subscription.PublicationDBName = publicationDbName
subscription.DatabaseName = subscriptionDbName
subscription.HostName = hostname
' Specify an anonymous Subscriber type since we can't
' register at the Publisher with a direct connection.
subscription.SubscriberType = MergeSubscriberType.Anonymous
' Specify the Windows login credentials for the Merge Agent job.
subscription.SynchronizationAgentProcessSecurity.Login = winLogin
subscription.SynchronizationAgentProcessSecurity.Password = winPassword
' Enable Web synchronization.
subscription.UseWebSynchronization = True
subscription.InternetUrl = webSyncUrl
' Specify the same Windows credentials to use when connecting to the
' Web server using HTTPS Basic Authentication.
subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication
subscription.InternetLogin = winLogin
subscription.InternetPassword = winPassword
' Ensure that we create a job for this subscription.
subscription.CreateSyncAgentByDefault = True
' Create the pull subscription at the Subscriber.
subscription.Create()
Catch ex As Exception
' Implement the appropriate error handling here.
Throw New ApplicationException(String.Format( _
"The subscription to {0} could not be created.", publicationName), ex)
Finally
conn.Disconnect()
End Try