Sequelize 乐观锁、读取复制与连接池

乐观锁

Sequelize 内置支持通过模型实例版本计数进行乐观锁。

乐观锁默认情况下处于禁用状态,可以通过在特定模型定义或全局模型配置中将 version 属性设置为 true 来启用。 有关更多详细信息,请参见模型基础

乐观锁允许并发访问模型记录以进行编辑,并防止冲突覆盖数据。 它通过检查自从读取以来另一个进程是否对记录进行了更改,并在检测到冲突时抛出 OptimisticLockError 来执行此操作。


读取复制

Sequelize 支持 读取复制, 即,当你要执行 SELECT 查询时,可以连接多个服务器。 当你执行读取复制时,你可以指定一台或多台服务器充当读取副本,并指定一台服务器充当写入主机,该主机处理所有写入和更新并将它们传播到副本(请注意,实际复制过程 不是 由 Sequelize 处理,而应由数据库后端设置)。

const sequelize = new Sequelize('database', null, null, {
  dialect: 'mysql',
  port: 3306,
  replication: {
    read: [
      { host: '8.8.8.8', username: 'read-1-username', password: process.env.READ_DB_1_PW },
      { host: '9.9.9.9', username: 'read-2-username', password: process.env.READ_DB_2_PW }
    ],
    write: { host: '1.1.1.1', username: 'write-username', password: process.env.WRITE_DB_PW }
  },
  pool: { // 如果要覆盖用于 读/写 池的参数,可以在此处执行
    max: 20,
    idle: 30000
  },
})

如果你有适用于所有副本的常规设置,则无需为每个实例提供它们。 在上面的代码中,数据库名称和端口将传播到所有副本。 如果将用户名和密码留给任何副本,则同样会生效。 每个副本具有以下参数:host, port, username, password, database。

Sequelize 使用池来管理与副本的连接。 在内部,Sequelize 将维护使用 pool 配置创建的两个池。

如果要修改这些设置,可以在实例化 Sequelize 时将 pool 作为参数传递,如上所示。

每个 write 或 useMaster: true 查询都将使用写入池。 对于 SELECT,将使用读取池。 使用基本的循环调度来切换只读副本。


连接池

如果要从单个进程连接到数据库,则应仅创建一个 Sequelize 实例。 Sequelize 将在初始化时建立连接池。 可以通过构造函数的 options 参数(使用 options.pool)来配置此连接池,如以下示例所示:

const sequelize = new Sequelize(/* ... */, {
  // ...
  pool: {
    max: 5,
    min: 0,
    acquire: 30000,
    idle: 10000
  }
});

如果要从多个进程连接到数据库,则必须为每个进程创建一个实例,但是每个实例的最大连接池大小应达到最大总大小。 例如,如果你希望最大连接池大小为90,并且有三个进程,则每个进程的 Sequelize 实例的最大连接池大小应为30。

查看笔记

扫码一下
查看教程更方便