当前位置： 首页 > news >正文

韩雪冬 网站wordpress手机导航栏模板

news 2025/9/23 16:54:02
韩雪冬 网站,wordpress手机导航栏模板,网站开发 强制兼容模式,南城做网站在多人实时编辑的场景下，SpreadJS 协同服务器需要持久化存储 文档信息、操作日志、快照分片 以及 里程碑快照。 如果你的系统更偏向关系型数据库，那么 MySQL 就是一个很合适的选择。 本文将带你实现 SpreadJS 协同服务器的 MySQL 数据库适配器。 &#…

在多人实时编辑的场景下，SpreadJS 协同服务器需要持久化存储 文档信息、操作日志、快照分片 以及 里程碑快照。
如果你的系统更偏向关系型数据库，那么 MySQL 就是一个很合适的选择。

本文将带你实现 SpreadJS 协同服务器的 MySQL 数据库适配器。

🗂️ 数据库建表设计

我们需要 4 张核心表：

  1. documents：存储文档基本信息（文档 ID、类型、版本号、快照版本号）
  2. operations：存储用户的操作记录，用于 OT 算法重放
  3. snapshot_fragments：存储快照的分片数据
  4. milestone_snapshot：存储里程碑快照，提升文档恢复速度

📌 建表 SQL 示例：

CREATE TABLE IF NOT EXISTS documents(id VARCHAR(255) PRIMARY KEY,type VARCHAR(255) NOT NULL,version INT NOT NULL,snapshot_version INT NOT NULL
);CREATE TABLE IF NOT EXISTS operations(doc_id VARCHAR(255) NOT NULL,version INT NOT NULL,operation TEXT NOT NULL,PRIMARY KEY(doc_id, version),FOREIGN KEY(doc_id) REFERENCES documents(id) ON DELETE CASCADE
);CREATE TABLE IF NOT EXISTS snapshot_fragments(doc_id VARCHAR(255) NOT NULL,fragment_id VARCHAR(255) NOT NULL,data TEXT NOT NULL,PRIMARY KEY(doc_id, fragment_id),FOREIGN KEY(doc_id) REFERENCES documents(id) ON DELETE CASCADE
);CREATE TABLE IF NOT EXISTS milestone_snapshot(doc_id VARCHAR(255) NOT NULL,version INT NOT NULL,snapshot TEXT NOT NULL,PRIMARY KEY(doc_id, version),FOREIGN KEY(doc_id) REFERENCES documents(id) ON DELETE CASCADE
);

⚠️ 列名并非固定，开发者可以根据需要调整。
如果要扩展更多业务数据，可以新建表，并通过 中间件 / 钩子函数 与协同服务集成。

🛠️ MySQL 适配器实现

适配器 MySQLDb 负责与数据库交互，实现以下功能：

  • 文档信息存取
  • 操作日志管理
  • 快照分片存储与更新
  • 事务保障一致性

核心逻辑：

  • getDocument / getSnapshot → 查询文档信息、快照和分片
  • getOps → 按版本范围获取操作日志
  • commitOp → 事务执行操作写入 & 文档版本更新
  • commitSnapshot → 事务更新快照版本 & 分片数据

示例：

export class MySQLDb extends Db {constructor(pool) {super();this.pool = pool;}async getDocument(docId) {console.log("Fetching document:", docId);const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT * FROM documents WHERE id = ?',[docId]);console.log("Fetched document rows:", rows);connection.release();if (0 === rows.length) return;const row = rows[0];return {id: row.id,type: row.type,version: row.version,snapshotVersion: row.snapshot_version};}async getSnapshot(docId) {console.log("Fetching snapshot for document:", docId);const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT * FROM documents WHERE id = ?',[docId]);connection.release();console.log("Fetched snapshot rows:", rows);if (0 === rows.length) return;const row = rows[0];const fragments = await this.getFragments(docId);return {id: row.id,v: row.snapshot_version,type: row.type,fragments: fragments};}async getFragments(docId) {console.log("Fetching fragments for document:", docId);const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT fragment_id, data FROM snapshot_fragments WHERE doc_id = ?',[docId]);console.log("Fetched fragments rows:", rows);connection.release();const fragments = {};for (const row of rows) {fragments[row.fragment_id] = JSON.parse(row.data);}return fragments;}async getFragment(docId, fragmentId) {console.log("Fetching fragment:", docId, fragmentId);const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT data FROM snapshot_fragments WHERE doc_id = ? AND fragment_id = ?',[docId, fragmentId]);connection.release();console.log("Fetched fragment rows:", rows);if (0 === rows.length) return;return JSON.parse(rows[0].data);}async getOps(docId, from, to) {console.log("Fetching operations for document:", docId, "from version:", from, "to version:", to);const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT operation FROM operations WHERE doc_id = ? AND version >= ?' + (to ? ' AND version <= ?' : '') + " ORDER BY version",to ? [docId, from, to] : [docId, from]);connection.release();console.log("Fetched operations rows:", rows);if (0 === rows.length) return [];return rows.map(row => JSON.parse(row.operation));}async commitOp(docId, op, document) {console.log("Committing operation:", docId, op, document);const connection = await this.pool.getConnection();try {connection.beginTransaction();// query version from document dbconst [rows] = await connection.execute('SELECT version FROM documents WHERE id = ?',[docId]);if (op.create) {console.log("Creating new document:", docId, rows);if (rows.length > 0) {await connection.rollback();return false;}await connection.execute('INSERT INTO documents (id, type, version, snapshot_version) VALUES (?, ?, ?, ?)',[docId, document.type, document.version, document.snapshotVersion]);await connection.execute('INSERT INTO operations (doc_id, version, operation) VALUES (?, ?, ?)',[docId, op.v, JSON.stringify(op)]);await connection.commit();console.log("Operation create successfully.");return true;}else if (op.del) {console.log("Deleting document:", docId, rows);if (rows.length === 0) {await connection.rollback();return false;}await connection.execute('DELETE FROM documents WHERE id = ?',[docId]);await connection.commit();console.log("Operation delete successfully.");return true;}else {console.log("Updating operation:", docId, op, rows);if (rows.length === 0 || rows[0].version !== op.v) {await connection.rollback();return false;}await connection.execute('INSERT INTO operations (doc_id, version, operation) VALUES (?, ?, ?)',[docId, op.v, JSON.stringify(op)]);await connection.execute('UPDATE documents SET version = ? WHERE id = ?',[document.version, docId]);await connection.commit();console.log("Operation update successfully.");return true;}} catch (error) {console.error('Error committing operation:', error);await connection.rollback();return false;}finally {connection.release();}}async commitSnapshot(docId, snapshot) {console.log("Committing snapshot for document:", docId, snapshot);const connection = await this.pool.getConnection();try {connection.beginTransaction();// query snapshot_version from document dbconst [rows] = await connection.execute('SELECT snapshot_version FROM documents WHERE id = ?',[docId]);if (0 === rows.length) {await connection.rollback();return false;}const currentSnapshotVersion = rows[0].snapshot_version;if (snapshot.fromVersion !== currentSnapshotVersion || snapshot.v <= currentSnapshotVersion) {await connection.rollback();return false;}await connection.execute('UPDATE documents SET snapshot_version = ? WHERE id = ?',[snapshot.v, docId]);if (snapshot.fragmentsChanges.deleteSnapshot) {await connection.execute('DELETE FROM snapshot_fragments WHERE doc_id = ?',[docId]);} else {const { createFragments, updateFragments, deleteFragments } = snapshot.fragmentsChanges;console.log("Committing snapshot fragments changes:", createFragments, updateFragments, deleteFragments);if (createFragments) {for (const [fragmentId, data] of Object.entries(createFragments)) {await connection.execute('INSERT INTO snapshot_fragments (doc_id, fragment_id, data) VALUES (?, ?, ?)',[docId, fragmentId, JSON.stringify(data)]);}}if (updateFragments) {for (const [fragmentId, data] of Object.entries(updateFragments)) {await connection.execute('UPDATE snapshot_fragments SET data = ? WHERE doc_id = ? AND fragment_id = ?',[JSON.stringify(data), docId, fragmentId]);}}if (deleteFragments) {for (const fragmentId of deleteFragments) {await connection.execute('DELETE FROM snapshot_fragments WHERE doc_id = ? AND fragment_id = ?',[docId, fragmentId]);}}}await connection.commit();return true;} catch (error) {console.error('Error committing snapshot:', error);await connection.rollback();return false;} finally {connection.release();}}async close() {await this.pool.end();}}

📌 数据流转示意：

用户操作 --> commitOp --> operations表--> documents表(version更新)
快照提交 --> commitSnapshot --> snapshot_fragments表--> documents表(snapshot_version更新)

🏷️ 里程碑快照存储

与 MongoDB 版本类似，MySQL 适配器也支持 里程碑快照，用于快速恢复文档。

实现类 MySQLMilestoneDb 提供两个接口：

  • saveMilestoneSnapshot → 定期保存完整快照
  • getMilestoneSnapshot → 查找 ≤指定版本 的最近快照

示例：

export class MySQLMilestoneDb {constructor(pool, interval) {this.pool = pool;this.interval = interval || 100; // 默认间隔}async saveMilestoneSnapshot(snapshot) {const connection = await this.pool.getConnection();try {await connection.beginTransaction();await connection.execute('INSERT INTO milestone_snapshot (doc_id, version, snapshot) VALUES (?, ?, ?)',[snapshot.id, snapshot.v, JSON.stringify(snapshot)]);await connection.commit();return true;} catch (error) {await connection.rollback();return false;} finally {connection.release();}}async getMilestoneSnapshot(id, version) {const connection = await this.pool.getConnection();const [rows] = await connection.execute('SELECT * FROM milestone_snapshot WHERE doc_id = ? AND version <= ? ORDER BY version DESC LIMIT 1',[id, version]);connection.release();if (0 === rows.length) return;return JSON.parse(rows[0].snapshot);}
}

📌 恢复流程：

里程碑快照 (v=1000) + 增量操作 (1001-1020) = 最新文档

⚙️ 在 DocumentServices 中集成

最后，在协同服务器中配置 MySQL 适配器：

const mySqlAdapter = new MySQLDb(mySqlPool);
const MySQLMilestoneAdapter = new MySQLMilestoneDb(mySqlPool, 100);const documentServices = new OT.DocumentServices({ db: mySqlAdapter, milestoneDb: MySQLMilestoneAdapter
});server.useFeature(OT.documentFeature(documentServices));

至此，SpreadJS 协同服务器即可使用 MySQL 作为后端存储。

✅ 总结

本文展示了如何基于 MySQL 为 SpreadJS 协同服务器实现数据库适配，主要内容包括：

  1. 建表设计 → documents / operations / snapshot_fragments / milestone_snapshot
  2. MySQL 适配器实现 → 支持事务，保证操作和快照一致性
  3. 里程碑快照 → 提升文档恢复效率
  4. 服务集成 → 在 DocumentServices 中配置适配器

通过 MySQL，你可以获得更强的数据一致性和事务控制能力，非常适合企业级协同编辑场景。

扩展链接

SpreadJS 协同服务器 MongoDB 数据库适配支持

http://www.dtcms.com/a/396293.html

相关文章：

  • 天津网站优化公司做个简单的网站多少钱
  • 浙江企业响应式网站建设设计做少儿培训网站的公司
  • 仿站小工具+wordpress联雅网站建设
  • jsp网站建设课程设计厦门城乡住房建设厅网站
  • 基于目标导向扩散模型与影响函数的EHR数据生成方法
  • 公司网站怎么优化电商网站设计工作内容
  • 网站建站公司有必要做吗互联网产品运营推广方案
  • ansible安装与模块使用
  • 网站建设分金手指专业二五wordpress主题no.7
  • 免费关键词挖掘网站柳州市住房建设保障网
  • 想用好 AI 辅助编程，什么最重要？
  • 福州省建设局网站成都三合一网站建设
  • 河北省建设工程网站建设银行个人网站
  • 关于组件封装
  • 德国购物网站大全wordpress空间服务器
  • 应持续抓好二级网站的建设工作免费制作永久个人网站
  • 【Linux网络编程】数据链路层 高级IO模型
  • 网站怎么做下拉刷新合肥仿站定制模板建站
  • 程序员做项目网站关于中秋节网页设计实训报告
  • 16.Linux RAID 存储技术
  • 网站摇奖活动怎么做只做特卖的网站
  • LLM安全基础入门：揭开大模型安全的面纱
  • 响应式外贸网站案例做公众号主页面的有哪些网站
  • 建企业网站需要多少钱网站建设摊销会计分录
  • 手机与pc的网站开发中国好公司网站建设
  • 网站建设公司好哪家好免费网站推广工具有哪些
  • 无锡外贸网站制作宜城网站定制
  • 数据图表展示网站茶叶 企业 网站建设
  • 南京建设工程网站石家庄营销推广网站
  • 太原网站制作最新招聘信息宿迁哪里做网站