Wie Node.js Sequelize die Lese-/Schreibtrennung der Datenbank implementiert

1. Vorwort

Beim Erstellen einer hochgradig gleichzeitigen Webanwendung muss die Datenbank zusätzlich zur Einführung einer Lastausgleichslösung auf der Anwendungsebene auch hohe Verfügbarkeit und hohe Parallelität unterstützen. Die am häufigsten verwendete Lösung zur Datenbankoptimierung besteht darin, Daten durch Master-Slave-Replikation zu synchronisieren und dann die gleichzeitige Ladekapazität der Datenbank durch Lese-/Schreibtrennung (MySQL-Proxy) zu verbessern.

1. Replikationsoption und Lese-/Schreibtrennung

Sequelize unterstützt die Lese-/Schreibtrennung. Sie können eine Sequelize-Instanz zum Lesen und Schreiben erstellen Eine bequemere Möglichkeit besteht darin, die Lese-/Schreibdatenbank beim Erstellen einer Instanz separat über die Replikationsoption anzugeben.

Um die Lese-/Schreibreplikation in Sequelize zu verwenden, können Sie beim Initialisieren von Sequelize manchmal ein Objekt an seine Replikationsoption übergeben. Dieses Objekt hat zwei Eigenschaften: Lesen und Schreiben. write ist ein einzelnes Objekt (d. h.: Schreibvorgänge werden von einem einzelnen Server verarbeitet), während read ein Array ist, das Objekte enthält (d. h.: Lesevorgänge werden von mehreren Servern verarbeitet). Jeder Lese- und Schreibserver kann die folgenden Attribute enthalten:

· Host – der Host des Datenbankservers

· Port – der Host-Port des Datenbankservers

· Benutzername – Benutzernamen überprüfen

· Passwort – Passwort überprüfen

· Datenbank – Datenbank, die verbunden werden soll

2. Sequelize read/ Beispiel für Schreibtrennung

In einem Cluster mit mehreren Datenbanken, der die Master-Slave-Replikation verwendet, können Sie es im Leseattribut des Replikationsobjekts festlegen. Dieses Attribut ist ein Array, in dem sich eine oder mehrere Serververbindungen befinden können übergeben. Kopie. Der Lesevorgang entspricht dem Betrieb auf dem Slave-Knoten im Datenbankcluster, der alle SELECT-Abfragevorgänge (Lesevorgänge) abwickelt. Das Schreibattribut des Replikationsobjekts ist ein Objekt, das die Serververbindung darstellt. Der Schreibvorgang entspricht dem Primärknoten. Er verarbeitet alle Einfüge-, Aktualisierungs- und Löschvorgänge (Schreibvorgänge).

var sequelize = new Sequelize('database', null, null, {
 dialect: 'mysql',
 port: 3306
 replication: {
  read: [
   { host: '192.168.1.33', username: 'itbilu.com', password: 'pwd' },
   { host: 'localhost', username: 'root', password: null }
  ],
  write: { host: 'localhost', username: 'root', password: null }
 },
 pool: { // 如果需要重写链接池，请在 pool 选项中修改
  maxConnections: 20,
  maxIdleTime: 30000
 },
})

Alle globalen Einstellungen gelten für alle Knotenkopien, sodass keine Notwendigkeit besteht, sie für jede Instanz separat anzugeben. Im obigen Beispiel gelten der Datenbankname und die Portnummer für alle Knotenreplikate, ebenso wie die Optionen für Benutzername und Passwort. Wenn ein Knotenreplikat keine globalen Einstellungen verwendet, muss es in den Replikationsoptionen separat angegeben werden.

Hinweis: Sequelize richtet keine Master-Slave-Replikationsknoten und keine Datensynchronisierung (Replikation) zwischen Knoten ein. Diese Vorgänge werden tatsächlich von MySQL (oder der von Ihnen verwendeten Datenbank) ausgeführt. Sequelize ist nur für das Schreiben oder Lesen von Daten von den Master- und Slave-Knoten verantwortlich.

Sequelize verwendet einen Verbindungspool, um Knotenreplikate zu verwalten.

Die Standardoptionen sind:

{
 maxConnections: 10,
 minConnections: 0,
 maxIdleTime:1000
}