ReplicatorSettings Klasse

Paket:

system.fabric

• java.lang.Object
• • system.fabric.ReplicatorSettings

public class ReplicatorSettings

Ermöglicht es einem zustandsbehafteten Replikat, den FabricReplicator beim Erstellen zu konfigurieren. createReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings)

Zusammenfassung zum Konstruktor

Konstruktor	Beschreibung
ReplicatorSettings()

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
Duration	getBatchAcknowledgementInterval() Ruft die Zeit ab, die der Replizierer nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurücksendet wird. Bemerkungen:Bei anderen Vorgängen, die während dieses Zeitraums empfangen und bestätigt werden, werden die Bestätigungen in einer einzelnen Nachricht zurückgesendet. Das Erhöhen des system.fabric.ReplicatorSettings#batchAcknowledgementInterval Werts verringert die Latenz einzelner Replikationsvorgänge, erhöht jedoch den Durchsatz des Replikats. Der Standardwert ist 0,05 Sekunden (50 Millisekunden)
long	getInitialCopyQueueSize() Ruft die Anfangsgröße der Kopiervorgangswarteschlange in FabricReplicatorab, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält. Bemerkungen:Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
long	getInitialPrimaryReplicationQueueSize() Definiert die Anfangsgröße der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl der Vorgänge in der Warteschlange. Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts primär ist. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
long	getInitialReplicationQueueSize() Ruft die anfängliche Größe der Replikationswarteschlange ab.
long	getInitialSecondaryReplicationQueueSize() Definiert die Anfangsgröße der Warteschlange für sekundäre Replikationsvorgänge in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Sekundär/Leerlauf lautet. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
long	getMaxCopyQueueSize() Ruft die maximale Größe der Kopiervorgangswarteschlange in FabricReplicatorab, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße auf der sekundären Ebene erreicht wird, werden Vorgänge in der Kopierwarteschlange des primären Computers gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für den primären Computer Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024.
long	getMaxPrimaryReplicationQueueMemorySize() Definiert die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist. Der Standardwert ist 0. Dies bedeutet, dass es keine Arbeitsspeicherbeschränkung gibt.
long	getMaxPrimaryReplicationQueueSize() Definiert die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024 Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist.
Long	getMaxReplicationMessageSize() Ruft die maximale Größe einer Nachricht ab, die über den Replizierer übertragen werden kann. Dazu gehören Replikationsnachrichten, Kopieren von Nachrichten und Kopieren von Kontextnachrichten. Die Einheit der Darstellung ist Bytes. Bemerkungen:Der Standardwert ist 50 MB.
long	getMaxReplicationQueueMemorySize() Ruft die maximale Größe für den Speicher der Replikationswarteschlange ab. Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.
long	getMaxReplicationQueueSize() Ruft die maximale Größe für die Replikationswarteschlange ab.
long	getMaxSecondaryReplicationQueueMemorySize() Definiert die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts Sekundär/Leerlauf ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.
long	getMaxSecondaryReplicationQueueSize() Definiert die maximale Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden Vorgänge in der Replikationswarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 2048. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts sekundär/im Leerlauf ist.
Duration	getPrimaryWaitForPendingQuorumsTimeout() Definiert, wie lange der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, bevor eine Neukonfigurationsanforderung verarbeitet wird, was möglicherweise zum "Abbrechen" der ausstehenden Replikationsvorgänge führen kann. Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass Neukonfigurationen nicht auf den Empfang des Quorums für die ausstehenden Replikationsvorgänge gewartet werden. Dies hilft beim früheren Abschluss von Neukonfigurationen. Beachten Sie, dass größere Werte für diesen Parameter möglicherweise zu langsameren Neukonfigurationen führen können, was eine längere Dauer für das Failover eines primären Parameters bedeutet.
String	getReplicatorAddress() Konfiguriert die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet. Bemerkungen:Die Zeichenfolge ist als "hostname:port" formatiert, wobei der Hostname FQDN oder IP-Adresse sein kann. Der Standardwert ist localhost:0.
Duration	getRetryInterval() Definiert, wie lange die FabricReplicator Wartezeit dauert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, um zu bestätigen, dass die Nachricht empfangen wurde. Bemerkungen:Der Empfang einer Nachricht muss nicht unbedingt dazu führen, dass die Nachricht verarbeitet wurde. Wenn dieser Timer überschritten wird, wird die Nachricht erneut übertragen. Der Standardwert ist 5 Sekunden.
SecurityCredentials	getSecurityCredentials() Ermöglicht dem Dienst das Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.
boolean	isRequireServiceAck() Verhindert die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, indem er verlangt, dass der Dienst aufruft acknowledge() , bevor er den nächsten Vorgang pumpt. Bemerkungen:Nicht persistente Dienste, die eine explizite Bestätigung erfordern, können diese Eigenschaft auf True festlegen, um eine optimistische Bestätigung der Vorgänge durch den Replizierer zu verhindern. Diese Einstellung hat keine Auswirkungen auf persistente Dienste. Der Standardwert ist „FALSE“.
boolean	isSecondaryClearAcknowledgedOperations() In der Regel werden Vorgänge im sekundären Replikator in der Warteschlange beibehalten, um Replikate abfangen zu können, wenn sie zu einem primären Replikat höhergestuft werden. Wenn dieses Flag aktiviert ist, gibt der sekundäre Replikator den Vorgang frei, sobald er vom Benutzerdienst bestätigt wird. Bemerkungen:Der Standardwert ist false.
boolean	isUseStreamFaultsAndEndOfStreamOperationAck() Gibt an, ob der Replizierer Streamfehler verwendet. Bemerkungen:Der Standardwert ist false.
ReplicatorSettings	loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)
void	setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval) Legt fest, wie lange der Replizierer nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurück gesendet wird. Bemerkungen:Bei anderen Vorgängen, die in diesem Zeitraum empfangen und bestätigt werden, werden ihre Bestätigungen in einer einzigen Nachricht zurückgesendet. Das Erhöhen des system.fabric.ReplicatorSettings#batchAcknowledgementInterval Werts verringert die Latenz einzelner Replikationsvorgänge, erhöht jedoch den Durchsatz des Replikators. Standardwert ist 0,05 Sekunden (50 Millisekunden)
void	setInitialCopyQueueSize(long initialCopyQueueSize) Ruft die anfängliche Größe der Kopiervorgangswarteschlange in FabricReplicatorab, die noch Operationnicht vom Dienst gepumpt und verarbeitet wurde, oder legt diese fest. Bemerkungen:Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
void	setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize) Definiert die anfängliche Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange. Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts primär ist. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
void	setInitialReplicationQueueSize(long initialReplicationQueueSize) Legt die anfängliche Größe der Replikationswarteschlange fest.
void	setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize) Definiert die anfängliche Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Sekundär/Leerlauf ist Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.
void	setMaxCopyQueueSize(long maxCopyQueueSize) Legt die maximale Größe der Kopiervorgangswarteschlange in FabricReplicatorfest, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße auf der sekundären Ebene erreicht wird, werden Vorgänge in der Kopierwarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024.
void	setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize) Definiert die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.
void	setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize) Definiert die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024 Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts "Primär" ist.
void	setMaxReplicationMessageSize(long maxReplicationMessageSize) Legt die maximale Größe einer Nachricht fest, die über den Replizierer übertragen werden kann. Dazu gehören Replikationsnachrichten, Kopieren von Nachrichten und Kopieren von Kontextnachrichten. Die Einheit der Darstellung ist Bytes. Bemerkungen:Der Standardwert ist 50 MB.
void	setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize) Legt die maximale Größe für den Speicher der Replikationswarteschlange fest. Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.
void	setMaxReplicationQueueSize(long maxReplicationQueueSize) Legt die maximale Größe für die Replikationswarteschlange fest.
void	setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize) Definiert die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts Sekundär/Leerlauf ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.
void	setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize) Definiert die maximale Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden Vorgänge in der Replikationswarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 2048. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts sekundär/im Leerlauf ist.
void	setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout) Definiert, wie lange der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, bevor eine Neukonfigurationsanforderung verarbeitet wird, was möglicherweise zum "Abbrechen" der ausstehenden Replikationsvorgänge führen kann. Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass Neukonfigurationen nicht auf den Empfang des Quorums für die ausstehenden Replikationsvorgänge gewartet werden. Dies hilft beim früheren Abschluss von Neukonfigurationen. Beachten Sie, dass größere Werte für diesen Parameter möglicherweise zu langsameren Neukonfigurationen führen können, was eine längere Dauer für das Failover eines primären Parameters bedeutet.
void	setReplicatorAddress(String replicatorAddress) Konfiguriert die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet. Bemerkungen:Die Zeichenfolge ist als "hostname:port" formatiert, wobei der Hostname FQDN oder IP-Adresse sein kann. Der Standardwert ist localhost:0.
void	setRequireServiceAck(boolean requireServiceAck) Verhindert die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, indem er verlangt, dass der Dienst aufruft acknowledge() , bevor er den nächsten Vorgang pumpt. Bemerkungen:Nicht persistente Dienste, die eine explizite Bestätigung erfordern, können diese Eigenschaft auf True festlegen, um eine optimistische Bestätigung der Vorgänge durch den Replizierer zu verhindern. Diese Einstellung hat keine Auswirkungen auf persistente Dienste. Der Standardwert ist „FALSE“.
void	setRetryInterval(Duration retryInterval) Definiert, wie lange die FabricReplicator Wartezeit dauert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, um zu bestätigen, dass die Nachricht empfangen wurde. Bemerkungen:Der Empfang einer Nachricht muss nicht unbedingt dazu führen, dass die Nachricht verarbeitet wurde. Wenn dieser Timer überschritten wird, wird die Nachricht erneut übertragen. Der Standardwert ist 5 Sekunden.
void	setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations) In der Regel werden Vorgänge im sekundären Replikator in der Warteschlange beibehalten, um Replikate abfangen zu können, wenn sie zu einem primären Replikat höhergestuft werden. Wenn dieses Flag aktiviert ist, gibt der sekundäre Replikator den Vorgang frei, sobald er vom Benutzerdienst bestätigt wird. Bemerkungen:Der Standardwert ist false.
void	setSecurityCredentials(SecurityCredentials securityCredentials) Ermöglicht dem Dienst das Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.
void	setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck) Gibt an, ob der Replizierer Streamfehler verwendet. Bemerkungen:Der Standardwert ist false.
long	toNative(PinCollection pinCollection)
String	toString()

Details zum Konstruktor

ReplicatorSettings

public ReplicatorSettings()

Details zur Methode

getBatchAcknowledgementInterval

public Duration getBatchAcknowledgementInterval()

Ruft die Zeit ab, die der Replizierer nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurücksendet wird.

Bemerkungen:Bei anderen Vorgängen, die während dieses Zeitraums empfangen und bestätigt werden, werden die Bestätigungen in einer einzelnen Nachricht zurückgesendet. Das Erhöhen des system.fabric.ReplicatorSettings#batchAcknowledgementInterval Werts verringert die Latenz einzelner Replikationsvorgänge, erhöht jedoch den Durchsatz des Replikats. Der Standardwert ist 0,05 Sekunden (50 Millisekunden)

Gibt zurück:

Die Zeitspanne, die der Replizierer nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurücksendet wird.

getInitialCopyQueueSize

public long getInitialCopyQueueSize()

Ruft die Anfangsgröße der Kopiervorgangswarteschlange in FabricReplicatorab, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

Bemerkungen:Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Gibt zurück:

Die anfängliche Größe der Kopiervorgangswarteschlange in FabricReplicator, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

getInitialPrimaryReplicationQueueSize

public long getInitialPrimaryReplicationQueueSize()

Definiert die Anfangsgröße der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl der Vorgänge in der Warteschlange.

Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts primär ist. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Gibt zurück:

Die Anfangsgröße der primären Replikationsvorgangswarteschlange in FabricReplicator

getInitialReplicationQueueSize

public long getInitialReplicationQueueSize()

Ruft die anfängliche Größe der Replikationswarteschlange ab.

Gibt zurück:

Die anfängliche Größe der Replikationswarteschlange.

getInitialSecondaryReplicationQueueSize

public long getInitialSecondaryReplicationQueueSize()

Definiert die Anfangsgröße der Warteschlange für sekundäre Replikationsvorgänge in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Sekundär/Leerlauf lautet. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Gibt zurück:

Die anfängliche Größe der Warteschlange für sekundäre Replikationsvorgänge in FabricReplicator, die Replikationen Operationenthält, die noch nicht vom Dienst gepumpt und verarbeitet wurden. Die Einheit hier ist die Anzahl der Vorgänge in der Warteschlange.

getMaxCopyQueueSize

public long getMaxCopyQueueSize()

Ruft die maximale Größe der Kopiervorgangswarteschlange in FabricReplicatorab, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße auf der sekundären Ebene erreicht wird, werden Vorgänge in der Kopierwarteschlange des primären Computers gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für den primären Computer Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024.

Gibt zurück:

Die maximale Größe der Kopiervorgangswarteschlange in FabricReplicator, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

getMaxPrimaryReplicationQueueMemorySize

public long getMaxPrimaryReplicationQueueMemorySize()

Definiert die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist. Der Standardwert ist 0. Dies bedeutet, dass es keine Arbeitsspeicherbeschränkung gibt.

Gibt zurück:

. Gibt die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicatorzurück, die Replikationsvorgänge Operationenthält. Die Einheit hier ist der virtuelle Speicherverbrauch der Warteschlange . Gibt long zurück.

getMaxPrimaryReplicationQueueSize

public long getMaxPrimaryReplicationQueueSize()

Definiert die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024 Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist.

Gibt zurück:

Die maximale Größe der primären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl der Vorgänge in der Warteschlange.

getMaxReplicationMessageSize

public Long getMaxReplicationMessageSize()

Ruft die maximale Größe einer Nachricht ab, die über den Replizierer übertragen werden kann. Dazu gehören Replikationsnachrichten, Kopieren von Nachrichten und Kopieren von Kontextnachrichten. Die Einheit der Darstellung ist Bytes.

Bemerkungen:Der Standardwert ist 50 MB.

Gibt zurück:

Die maximale Größe einer Nachricht, die über den Replizierer übertragen werden kann.

getMaxReplicationQueueMemorySize

public long getMaxReplicationQueueMemorySize()

Ruft die maximale Größe für den Speicher der Replikationswarteschlange ab.

Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.

Gibt zurück:

Die maximale Größe des Replikationswarteschlangenspeichers.

getMaxReplicationQueueSize

public long getMaxReplicationQueueSize()

Ruft die maximale Größe für die Replikationswarteschlange ab.

Gibt zurück:

die maximale Größe für die Replikationswarteschlange.

getMaxSecondaryReplicationQueueMemorySize

public long getMaxSecondaryReplicationQueueMemorySize()

Definiert die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts Sekundär/Leerlauf ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.

Gibt zurück:

Gibt die maximale Größe der Warteschlange des sekundären Replikationsvorgangs innerhalb FabricReplicatorvon zurück, die Replikationsvorgänge Operationenthält. Die Einheit hier ist der virtuelle Speicherverbrauch der Warteschlange.

getMaxSecondaryReplicationQueueSize

public long getMaxSecondaryReplicationQueueSize()

Definiert die maximale Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden Vorgänge in der Replikationswarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 2048. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts sekundär/im Leerlauf ist.

Gibt zurück:

Die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die replikationsvorgänge Operationenthält, die noch nicht vom Dienst gepumpt und verarbeitet wurden. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange.

getPrimaryWaitForPendingQuorumsTimeout

public Duration getPrimaryWaitForPendingQuorumsTimeout()

Definiert, wie lange der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, bevor eine Neukonfigurationsanforderung verarbeitet wird, was möglicherweise zum "Abbrechen" der ausstehenden Replikationsvorgänge führen kann.

Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass Neukonfigurationen nicht auf den Empfang des Quorums für die ausstehenden Replikationsvorgänge gewartet werden. Dies hilft beim früheren Abschluss von Neukonfigurationen. Beachten Sie, dass größere Werte für diesen Parameter möglicherweise zu langsameren Neukonfigurationen führen können, was eine längere Dauer für das Failover eines primären Parameters bedeutet.

Gibt zurück:

Die Zeitspanne, die der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, wenn eine Anforderung für den primären Replikattor zur Verarbeitung einer Neukonfiguration java.time.Durationvorliegt.

getReplicatorAddress

public String getReplicatorAddress()

Konfiguriert die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet.

Bemerkungen:Die Zeichenfolge ist als "hostname:port" formatiert, wobei der Hostname FQDN oder IP-Adresse sein kann. Der Standardwert ist localhost:0.

Gibt zurück:

Die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet.

getRetryInterval

public Duration getRetryInterval()

Definiert, wie lange die FabricReplicator Wartezeit dauert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, um zu bestätigen, dass die Nachricht empfangen wurde.

Bemerkungen:Der Empfang einer Nachricht muss nicht unbedingt dazu führen, dass die Nachricht verarbeitet wurde. Wenn dieser Timer überschritten wird, wird die Nachricht erneut übertragen. Der Standardwert ist 5 Sekunden.

Gibt zurück:

Die Zeit, die die FabricReplicator Wartezeiten erfordert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, damit das Sekundäre bestätigt, dass es die Nachricht empfangen hat.

getSecurityCredentials

public SecurityCredentials getSecurityCredentials()

Ermöglicht dem Dienst das Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.

Gibt zurück:

Der Dienst zum Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.

isRequireServiceAck

public boolean isRequireServiceAck()

Verhindert die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, indem er verlangt, dass der Dienst aufruft acknowledge() , bevor er den nächsten Vorgang pumpt.

Bemerkungen:Nicht persistente Dienste, die eine explizite Bestätigung erfordern, können diese Eigenschaft auf True festlegen, um eine optimistische Bestätigung der Vorgänge durch den Replizierer zu verhindern. Diese Einstellung hat keine Auswirkungen auf persistente Dienste. Der Standardwert ist „FALSE“.

Gibt zurück:

true, wenn die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, andernfalls false.

isSecondaryClearAcknowledgedOperations

public boolean isSecondaryClearAcknowledgedOperations()

In der Regel werden Vorgänge im sekundären Replikator in der Warteschlange beibehalten, um Replikate abfangen zu können, wenn sie zu einem primären Replikat höhergestuft werden. Wenn dieses Flag aktiviert ist, gibt der sekundäre Replikator den Vorgang frei, sobald er vom Benutzerdienst bestätigt wird.

Bemerkungen:Der Standardwert ist false.

Gibt zurück:

true, wenn der sekundäre Replikator den Vorgang loslässt, sobald er vom Benutzerdienst bestätigt wird; andernfalls false.

isUseStreamFaultsAndEndOfStreamOperationAck

public boolean isUseStreamFaultsAndEndOfStreamOperationAck()

Gibt an, ob der Replizierer Streamfehler verwendet.

Bemerkungen:Der Standardwert ist false.

Gibt zurück:

true, wenn der Replikator Streamfehler verwendet; andernfalls false.

loadFrom

public static ReplicatorSettings loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)

Parameter:

codePackageActivationContext

configPackageName

sectionName

setBatchAcknowledgementInterval

public void setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval)

Legt fest, wie lange der Replizierer nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurück gesendet wird.

Bemerkungen:Bei anderen Vorgängen, die in diesem Zeitraum empfangen und bestätigt werden, werden ihre Bestätigungen in einer einzigen Nachricht zurückgesendet. Das Erhöhen des system.fabric.ReplicatorSettings#batchAcknowledgementInterval Werts verringert die Latenz einzelner Replikationsvorgänge, erhöht jedoch den Durchsatz des Replikators. Standardwert ist 0,05 Sekunden (50 Millisekunden)

Parameter:

batchAcknowledgementInterval - Die Zeitspanne, die der Replikator nach dem Empfang eines Vorgangs wartet, bevor eine Bestätigung zurück gesendet wird.

setInitialCopyQueueSize

public void setInitialCopyQueueSize(long initialCopyQueueSize)

Ruft die anfängliche Größe der Kopiervorgangswarteschlange in FabricReplicatorab, die noch Operationnicht vom Dienst gepumpt und verarbeitet wurde, oder legt diese fest.

Bemerkungen:Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Parameter:

initialCopyQueueSize - Die anfängliche Größe der Kopiervorgangswarteschlange in FabricReplicator, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

setInitialPrimaryReplicationQueueSize

public void setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize)

Definiert die anfängliche Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange.

Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts primär ist. Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Parameter:

initialPrimaryReplicationQueueSize - Die anfängliche Größe der Warteschlange des primären Replikationsvorgangs in der Warteschlange FabricReplicator

setInitialReplicationQueueSize

public void setInitialReplicationQueueSize(long initialReplicationQueueSize)

Legt die anfängliche Größe der Replikationswarteschlange fest.

Parameter:

initialReplicationQueueSize - Die anfängliche Größe der Replikationswarteschlange.

setInitialSecondaryReplicationQueueSize

public void setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize)

Definiert die anfängliche Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Sekundär/Leerlauf ist Der Standardwert ist 64. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen.

Parameter:

initialSecondaryReplicationQueueSize - Die anfängliche Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die replikationsvorgänge Operationenthält, die noch nicht vom Dienst gepumpt und verarbeitet wurden. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange.

setMaxCopyQueueSize

public void setMaxCopyQueueSize(long maxCopyQueueSize)

Legt die maximale Größe der Kopiervorgangswarteschlange in FabricReplicatorfest, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße auf der sekundären Ebene erreicht wird, werden Vorgänge in der Kopierwarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024.

Parameter:

maxCopyQueueSize - Die maximale Größe der Kopiervorgangswarteschlange in FabricReplicator, die noch nicht vom Dienst gepumpt und verarbeitete Kopiervorgänge Operationenthält.

setMaxPrimaryReplicationQueueMemorySize

public void setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize)

Definiert die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts Primär ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.

Parameter:

maxPrimaryReplicationQueueMemorySize - die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Auslastung des virtuellen Arbeitsspeichers der Warteschlange . Gibt long zurück.

setMaxPrimaryReplicationQueueSize

public void setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize)

Definiert die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 1024 Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts "Primär" ist.

Parameter:

maxPrimaryReplicationQueueSize - Die maximale Größe der Warteschlange des primären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange.

setMaxReplicationMessageSize

public void setMaxReplicationMessageSize(long maxReplicationMessageSize)

Legt die maximale Größe einer Nachricht fest, die über den Replizierer übertragen werden kann. Dazu gehören Replikationsnachrichten, Kopieren von Nachrichten und Kopieren von Kontextnachrichten. Die Einheit der Darstellung ist Bytes.

Bemerkungen:Der Standardwert ist 50 MB.

Parameter:

maxReplicationMessageSize - Die maximale Größe einer Nachricht, die über den Replikator übertragen werden kann.

setMaxReplicationQueueMemorySize

public void setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize)

Legt die maximale Größe für den Speicher der Replikationswarteschlange fest.

Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.

Parameter:

maxReplicationQueueMemorySize - Die maximale Größe des Replikationswarteschlangenspeichers.

setMaxReplicationQueueSize

public void setMaxReplicationQueueSize(long maxReplicationQueueSize)

Legt die maximale Größe für die Replikationswarteschlange fest.

Parameter:

maxReplicationQueueSize - die maximale Größe für die Replikationswarteschlange.

setMaxSecondaryReplicationQueueMemorySize

public void setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize)

Definiert die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Diese Einstellung ist spezifisch für den Replikator, wenn die Rolle des Diensts Sekundär/Leerlauf ist. Der Standardwert ist 0. Dies bedeutet, dass es kein Speicherlimit gibt.

Parameter:

maxSecondaryReplicationQueueMemorySize - Gibt die maximale Größe der Warteschlange des sekundären Replikationsvorgangs innerhalb FabricReplicatorvon zurück, die Replikationsvorgänge Operationenthält. Die Einheit hier ist der virtuelle Speicherverbrauch der Warteschlange.

setMaxSecondaryReplicationQueueSize

public void setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize)

Definiert die maximale Größe der sekundären Replikationsvorgangswarteschlange in FabricReplicator, die Replikationsvorgänge Operationenthält.

Bemerkungen:Wenn diese Warteschlangengröße erreicht ist, werden Vorgänge in der Replikationswarteschlange des Primären Gepuffert. Wenn sich diese Warteschlange ebenfalls füllt, werden für die primäre Instanz Ausnahmen angezeigt system.fabric.FabricErrorCode#ReplicationQueueFull . Der Standardwert ist 2048. Beachten Sie, dass die Werte für diesen Parameter eine Leistung von 2 aufweisen müssen. Diese Einstellung ist spezifisch für den Replizierer, wenn die Rolle des Diensts sekundär/im Leerlauf ist.

Parameter:

maxSecondaryReplicationQueueSize - Die maximale Größe der Warteschlange des sekundären Replikationsvorgangs in FabricReplicator, die replikationsvorgänge Operationenthält, die noch nicht vom Dienst gepumpt und verarbeitet wurden. Die Einheit hier ist die Anzahl von Vorgängen in der Warteschlange.

setPrimaryWaitForPendingQuorumsTimeout

public void setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout)

Definiert, wie lange der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, bevor eine Neukonfigurationsanforderung verarbeitet wird, was möglicherweise zum "Abbrechen" der ausstehenden Replikationsvorgänge führen kann.

Bemerkungen:Der Standardwert ist 0. Dies bedeutet, dass Neukonfigurationen nicht auf den Empfang des Quorums für die ausstehenden Replikationsvorgänge gewartet werden. Dies hilft beim früheren Abschluss von Neukonfigurationen. Beachten Sie, dass größere Werte für diesen Parameter möglicherweise zu langsameren Neukonfigurationen führen können, was eine längere Dauer für das Failover eines primären Parameters bedeutet.

Parameter:

primaryWaitForPendingQuorumsTimeout - Die Zeitspanne, die der primäre Replikator auf den Empfang eines Quorums von Bestätigungen für alle ausstehenden Replikationsvorgänge wartet, wenn eine Anforderung für den primären Replikattor zur Verarbeitung einer Neukonfiguration java.time.Durationvorliegt.

setReplicatorAddress

public void setReplicatorAddress(String replicatorAddress)

Konfiguriert die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet.

Bemerkungen:Die Zeichenfolge ist als "hostname:port" formatiert, wobei der Hostname FQDN oder IP-Adresse sein kann. Der Standardwert ist localhost:0.

Parameter:

replicatorAddress - Die Adresse, die dieser Replikator bei der Kommunikation mit anderen Replikatoren verwendet.

setRequireServiceAck

public void setRequireServiceAck(boolean requireServiceAck)

Verhindert die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, indem er verlangt, dass der Dienst aufruft acknowledge() , bevor er den nächsten Vorgang pumpt.

Bemerkungen:Nicht persistente Dienste, die eine explizite Bestätigung erfordern, können diese Eigenschaft auf True festlegen, um eine optimistische Bestätigung der Vorgänge durch den Replizierer zu verhindern. Diese Einstellung hat keine Auswirkungen auf persistente Dienste. Der Standardwert ist „FALSE“.

Parameter:

requireServiceAck - true, wenn die optimistische Bestätigung von Vorgängen in nicht persistenten Diensten, andernfalls false.

setRetryInterval

public void setRetryInterval(Duration retryInterval)

Definiert, wie lange die FabricReplicator Wartezeit dauert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, um zu bestätigen, dass die Nachricht empfangen wurde.

Bemerkungen:Der Empfang einer Nachricht muss nicht unbedingt dazu führen, dass die Nachricht verarbeitet wurde. Wenn dieser Timer überschritten wird, wird die Nachricht erneut übertragen. Der Standardwert ist 5 Sekunden.

Parameter:

retryInterval - Die Zeit, die die FabricReplicator Wartezeiten erfordert, nachdem eine Nachricht vom primären an das sekundäre gesendet wurde, damit das Sekundäre bestätigt, dass es die Nachricht empfangen hat.

setSecondaryClearAcknowledgedOperations

public void setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations)

In der Regel werden Vorgänge im sekundären Replikator in der Warteschlange beibehalten, um Replikate abfangen zu können, wenn sie zu einem primären Replikat höhergestuft werden. Wenn dieses Flag aktiviert ist, gibt der sekundäre Replikator den Vorgang frei, sobald er vom Benutzerdienst bestätigt wird.

Bemerkungen:Der Standardwert ist false.

Parameter:

secondaryClearAcknowledgedOperations - true, wenn der sekundäre Replikator den Vorgang loslässt, sobald er vom Benutzerdienst bestätigt wird; andernfalls false.

setSecurityCredentials

public void setSecurityCredentials(SecurityCredentials securityCredentials)

Ermöglicht dem Dienst das Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.

Parameter:

securityCredentials - Der Dienst zum Definieren von Sicherheitsanmeldeinformationen zum Schützen des Datenverkehrs zwischen Replikatoren.

setUseStreamFaultsAndEndOfStreamOperationAck

public void setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck)

Gibt an, ob der Replizierer Streamfehler verwendet.

Bemerkungen:Der Standardwert ist false.

Parameter:

useStreamFaultsAndEndOfStreamOperationAck - true, wenn der Replikator Streamfehler verwendet; andernfalls false.

toNative

public long toNative(PinCollection pinCollection)

Parameter:

pinCollection

toString

public String toString()