发布订阅

发布订阅

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

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

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

应用场景

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

数据同步：当一个数据库需要与另一个数据库保持同步时，发布订阅功能可以用来将数据更改发送到订阅者数据库。例如，当一个网站需要将数据从一个地理位置传输到另一个地理位置时，发布订阅功能可以用来确保两个数据库之间的数据同步。
业务数据分发：发布订阅功能可以用来将业务数据分发到不同的系统或业务流程中。例如，当一个银行需要将客户账户信息分发到多个业务系统中时，发布订阅功能可以用来将数据分发到相应的系统中，确保各个业务流程之间的数据一致性。
数据备份：发布订阅功能可以用来备份数据。例如，当一个数据库需要备份到另一个数据库时，发布订阅功能可以用来将数据备份到订阅者数据库中，以便在主数据库出现故障时恢复数据。
实时数据处理：发布订阅功能可以用来实现实时数据处理。例如，当一个网站需要对来自不同用户的数据进行处理时，发布订阅功能可以用来将数据传输到处理程序中进行处理，以便实现实时数据分析和决策。

发布订阅示例

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

发布者：sys 租户创建数据库 sub1 与表 t1，并发布 pub1：

create database sub1;
create table sub1.t1(a int,b int);
create publication pub1 database sub;

订阅者：acc1 和 acc2 都创建订阅库 syssub1，于是得到共享的数据表 t1：

-- acc1 和 acc2 创建订阅库的 sql 语句一致，此处不做赘述
create database syssub1 from sys publication pub1;
use syssub1;
show tables;
mysql> show tables;
+--------------------+
| Tables_in_syssub1  |
+--------------------+
| t1                 |
+--------------------+
2 rows in set (0.02 sec)

发布者：sys 租户创建数据表 t2：
```
create table sub1.t2(a text);
```

订阅者：acc1 和 acc2 得到共享的数据表 t1 和 t2：

show tables;
+--------------------+
| Tables_in_syssub1  |
+--------------------+
| t1                 |
+--------------------+
| t2                 |
+--------------------+
2 rows in set (0.02 sec)

发布者：sys 租户创建数据库 sub2 与表 t2，并发布 pub2 给租户 acc1 和 acc3：

create database sub2;
create table sub2.t1(a float);
create publication pub2 database sub2 account acc1,acc3;

订阅者：acc1 和 acc2 都创建订阅库 syssub2，acc1 得到共享的数据表 t1；acc2 创建订阅库 syssub2 失败：

acc1

create database syssub2 from sys publication pub2;
use syssub2;
mysql> show tables;
+--------------------+
| Tables_in_syssub2  |
+--------------------+
| t1                 |
+--------------------+
2 rows in set (0.02 sec)

acc2

create database syssub2 from sys publication pub2;
> ERROR 20101 (HY000): internal error: the account acc3 is not allowed to subscribe the publication pub2

发布者：sys 租户修改发布 pub2 给全部租户：
```
alter publication pub2 account all;
```

订阅者：acc2 创建订阅库 syssub2 成功，得到共享的数据表 t1：

create database syssub2 from sys publication pub2;
use syssub2;
mysql> show tables;
+--------------------+
| Tables_in_syssub2  |
+--------------------+
| t1                 |
+--------------------+
2 rows in set (0.02 sec)

发布者：sys 租户删除发布 pub1：
```
drop publication pub1;
```

订阅者：acc1 连接 syspub1 失败：

use syssub1;
ERROR 20101 (HY000): internal error: there is no publication pub1

订阅者：acc2 删除 syspub1：
```
drop database syssub1;
```
发布者：sys 租户重新创建 pub1：
```
create publication pub1 database sub;
```

订阅者：acc1 连接 syspub1 成功：

create database syssub1 from sys publication pub1;
use syssub1;
mysql> show tables;
+--------------------+
| Tables_in_syssub1  |
+--------------------+
| t1                 |
+--------------------+
2 rows in set (0.02 sec)

发布订阅

发布订阅

应用场景

发布订阅示例

参考文档

发布者参考文档

订阅者参考文档

限制