Node.js Sequelize如何實作資料庫的讀寫分離

一、前言

在建構高並發的Web應用時，除了應用層要採取負載平衡方案外，資料庫也要支援高可用和高並發性。使用較多的資料庫最佳化方案是：透過主從複製(Master-Slave)的方式來同步數據，再透過讀寫分離(MySQL-Proxy)來提升資料庫的並發負載能力。

1. replication選項與讀寫分離

Sequelize 支援讀/寫分離，要實現讀/寫分離可以分別為讀和寫各創建一個Sequelize實例，更方便的使用方式是在創建實例時，透過replication選項分別指定讀/寫資料庫。

要在Sequelize中使用讀/寫複製，可以在初始化Sequelize時有時向其replication選項傳遞一個物件.這個物件read、write兩個屬性。 write是一個單一的物件(即：由單一伺服器處理寫入)，而read則是包含物件的陣列(即：由多台伺服器處理讀取)。每台read、write伺服器都可以包含以下屬性：

     · host - 資料庫伺服器的主機

     · port - 
     · password - 驗證密碼

     · database - 要連接的資料庫

2. Sequelize讀/寫分離範例

在使用主從複製的多台資料庫叢集中，可以透過在replication物件的，可以在其中傳入一個或多個伺服器連接副本。讀取操作相當於對資料庫叢集中的從節點進行操作，它會處理所有SELECT查詢操作(讀取操作)。而replication對象的write屬性是一個表示伺服器連接的對象，寫入操作相當於主節點，它會處理所有插入、更新、刪除操作(寫入操作)。

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
 },
})

   

所有的整體性設置，都會適用於所有節點副本，所以並不需要為每個實例單獨指定。在上例中，資料庫名稱和連接埠號碼會套用於所有節點副本，使用者名稱和密碼選項也同樣適用。如果某一節點副本不使用全域設置，則需要在replication選項中單獨指定。

注意：Sequelize 並不會設定主從複製節點及節點間的資料同步(複製)，這些操作實際上由MySQL(或你所使用的資料庫)完成。而 Sequelize 只負責從主從節點寫入或讀取資料。

Sequelize 會使用連接池來管理節點副本。

預設選項是：

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