发布订阅

数据库的发布订阅(Publish-Subscribe,简称 Pub/Sub)是一种消息传递模式,其中发布者将消息发送给一个或多个订阅者,而订阅者则接收并处理该消息。在这种模式下,发布者和订阅者之间是松耦合的,它们之间不需要直接通信,因此可以提高应用程序的可扩展性和灵活性。

在数据库中,发布订阅功能通常被用于实时数据更新、缓存同步、业务事件通知等场景。例如,当数据库中某个表的数据发生变化时,可以通过发布订阅功能实时通知订阅者,从而实现实时数据同步和处理。另外,也可以通过发布订阅功能来实现业务事件的通知,例如某个订单被取消、某个库存数量不足等等。

通常,数据库的发布订阅功能由两部分组成:发布者订阅者发布者负责发布消息,而订阅者则订阅相应消息以达到数据同步的目的。发布者和订阅者之间可以存在多对多的关系,即一个发布者可以向多个订阅者发布消息,而一个订阅者也可以订阅多个消息/数据。

应用场景

发布订阅功能具有多种典型的应用场景:

  • 数据同步:当一个数据库需要与另一个数据库保持同步时,发布订阅功能可以用来将数据更改发送到订阅者数据库。例如,当一个网站需要将数据从一个地理位置传输到另一个地理位置时,发布订阅功能可以用来确保两个数据库之间的数据同步。

  • 业务数据分发:发布订阅功能可以用来将业务数据分发到不同的系统或业务流程中。例如,当一个银行需要将客户账户信息分发到多个业务系统中时,发布订阅功能可以用来将数据分发到相应的系统中,确保各个业务流程之间的数据一致性。

  • 数据备份:发布订阅功能可以用来备份数据。例如,当一个数据库需要备份到另一个数据库时,发布订阅功能可以用来将数据备份到订阅者数据库中,以便在主数据库出现故障时恢复数据。

  • 实时数据处理:发布订阅功能可以用来实现实时数据处理。例如,当一个网站需要对来自不同用户的数据进行处理时,发布订阅功能可以用来将数据传输到处理程序中进行处理,以便实现实时数据分析和决策。

名词解释

  • 发布:在数据库中,发布通常指的是将一个数据库对象设置为可供其他租户访问的状态。这是数据共享和复制的一个重要步骤,发布的对象可以被其他租户订阅并获取数据。

  • 订阅:订阅是指一个数据库选择接收和复制发布的数据库对象的数据。

  • 发布端(Pub):发布端是执行发布操作的数据库。发布端负责创建和管理发布的对象,以及管理订阅该发布对象的数据库的访问权限。

  • 订阅端(Sub):订阅端是订阅发布对象的租户。

  • 发布对象:发布对象是在发布端创建并设置为可发布的数据库对象,即数据库。这些对象的数据可以被订阅端访问和复制。

  • 订阅对象:订阅对象是在订阅端复制和存储的发布对象。订阅对象的数据会根据发布端的数据进行更新。

发布订阅范围说明

发布/订阅应用范围

发布端(Pub)订阅端(Sub)均为 MatrixOne 的租户。

可发布/可订阅权限范围

  • 发布端(Pub)只有 ACCOUNTADMIN 或 MOADMIN 角色可以创建发布与订阅。
  • 订阅端(Sub)由 ACCOUNTADMIN 或 MOADMIN 角色操作访问订阅数据权限。

发布/订阅数据范围

  • 一个发布只能与单一数据库关联。
  • 发布和订阅只在数据库级别实现,目前还不支持直接进行表级别的发布和订阅。
  • 订阅端订阅库只具备读取权限。

  • 发布端(Pub)调整了发布的分享范围,那些不在新范围内的订阅端(Sub)如果已经创建了订阅库,那么对这个订阅库的访问将无效。

  • 发布端(Pub)尝试删除已经发布的数据库,那么此次删除将不会成功。

  • 发布端(Pub)删除了发布,但订阅库中的对应对象仍存在,此时订阅端(Sub)访问这个对象会触发错误,需要由订阅端(Sub)删除对应的订阅
  • 发布端(Pub)删除了发布对象,但在订阅库中的对应对象仍然存在,此时订阅端(Sub)访问这个对象会触发错误,需要由订阅端(Sub)删除对应的订阅对象

发布订阅示例

发布订阅 - 图1

本章节将给出一个示例,介绍当前在 MatrixOne 集群中,存在 3 个租户,sys、acc1 与 acc2,按照操作顺序对三个租户进行操作:

  1. 发布者:sys 租户创建数据库 sub1 与表 t1,并发布 pub1:

    1. create database sub1;
    2. create table sub1.t1(a int,b int);
    3. create publication pub1 database sub;
  2. 订阅者:acc1 和 acc2 都创建订阅库 syssub1,于是得到共享的数据表 t1:

    1. -- acc1 acc2 创建订阅库的 sql 语句一致,此处不做赘述
    2. create database syssub1 from sys publication pub1;
    3. use syssub1;
    4. show tables;
    5. mysql> show tables;
    6. +--------------------+
    7. | Tables_in_syssub1 |
    8. +--------------------+
    9. | t1 |
    10. +--------------------+
    11. 2 rows in set (0.02 sec)
  3. 发布者:sys 租户创建数据表 t2:

    1. create table sub1.t2(a text);
  4. 订阅者:acc1 和 acc2 得到共享的数据表 t1 和 t2:

    1. show tables;
    2. +--------------------+
    3. | Tables_in_syssub1 |
    4. +--------------------+
    5. | t1 |
    6. +--------------------+
    7. | t2 |
    8. +--------------------+
    9. 2 rows in set (0.02 sec)
  5. 发布者:sys 租户创建数据库 sub2 与表 t2,并发布 pub2 给租户 acc1 和 acc3:

    1. create database sub2;
    2. create table sub2.t1(a float);
    3. create publication pub2 database sub2 account acc1,acc3;
  6. 订阅者:acc1 和 acc2 都创建订阅库 syssub2,acc1 得到共享的数据表 t1;acc2 创建订阅库 syssub2 失败:

    • acc1
    1. create database syssub2 from sys publication pub2;
    2. use syssub2;
    3. mysql> show tables;
    4. +--------------------+
    5. | Tables_in_syssub2 |
    6. +--------------------+
    7. | t1 |
    8. +--------------------+
    9. 2 rows in set (0.02 sec)
    • acc2
    1. create database syssub2 from sys publication pub2;
    2. > ERROR 20101 (HY000): internal error: the account acc3 is not allowed to subscribe the publication pub2
  7. 发布者:sys 租户修改发布 pub2 给全部租户:

    1. alter publication pub2 account all;
  8. 订阅者:acc2 创建订阅库 syssub2 成功,得到共享的数据表 t1:

    1. create database syssub2 from sys publication pub2;
    2. use syssub2;
    3. mysql> show tables;
    4. +--------------------+
    5. | Tables_in_syssub2 |
    6. +--------------------+
    7. | t1 |
    8. +--------------------+
    9. 2 rows in set (0.02 sec)
  9. 发布者:sys 租户删除发布 pub1:

    1. drop publication pub1;
  10. 订阅者:acc1 连接 syspub1 失败:

    1. use syssub1;
    2. ERROR 20101 (HY000): internal error: there is no publication pub1
  11. 订阅者:acc2 删除 syspub1:

    1. drop database syssub1;
  12. 发布者:sys 租户重新创建 pub1:

    1. create publication pub1 database sub;
  13. 订阅者:acc1 连接 syspub1 成功:

    1. create database syssub1 from sys publication pub1;
    2. use syssub1;
    3. mysql> show tables;
    4. +--------------------+
    5. | Tables_in_syssub1 |
    6. +--------------------+
    7. | t1 |
    8. +--------------------+
    9. 2 rows in set (0.02 sec)

参考文档

发布者参考文档

订阅者参考文档