(SymmetricDS快速入门指南)Chapter 1. Quick Start Guide

本文档是SymmetricDS3.6.14文档的第1章节Quick Start Guide文档的翻译，的目的是帮助读者快速搭建1个SymmetricDS集群并普及1些基本概念术语。

本文档描写了如何在两个SymmetricDS节点之间同步两个相同schema的数据库。下面的例子构建了1个分销业务模型，有1个中央数据库（我们叫它root或corp节点）和多个零售商店的数据库（我们叫它client或store节点）。对本教程，我们将只有1个store（商店）节点，以下图。如果你愿意，可以再教程的结束后，自己扩大这个例子，配置第2个商店。

在这个例子中，我们将安装两个独立的SymmetricDS代表两个不同的服务器。1个代表store服务器，1个代表corp服务器。每个SymmetricDS安装副本将负责1个数据库，也就是1个SymmetricDS就是1个SymmetricDS术语中的节点。1个SymmetricDS安装副本负责1个数据库，代表1个节点，这类配置是最经常使用的（我们可以选择配置1个安装副本负责两个节点，这叫做multi-homing，将会在教程的最后讨论）。你极可能在1个机器上运行两个SymmetricDS副本，我们将运行两个SymmetricDS安装副本在两个不同的端口。我们将使用8080运行corp服务器，9090运行store服务器，以下图。

Corp SymmetricDS安装副本将负责捕获store真个item（item表和item_selling_price表）的数据变化，像itemnumber，描写和商店的价格。Store真个SymmetricDS捕获销售交易（sale_transaction表和sale_return_line_item表）数据的变化，比如销售的时间和商品。价格信息只发送给与价格相干的特定的商店，从而减少发送到每一个商店的定价信息数据的数量。举个例子，换句话说，商店001的商品的定价信息只会发送给商店001的数据库，不会发送给商店002的数据库。

这个简单的配置总是使客户端发起与root节点的通讯，这是1种相当常见的配置。在这个配置中，client将定期的从数据库服务器中拉数据附加到root节点上，client也会将捕获到的变化推送到root节点。

概述已足够多了，下面我们开始，我们将依照下面的步骤行动：

1.      安装和配置两个SymmetricDS利用程序

2.      创建SymmetricDS配置文件和用来存储corp数据和store数据的数据库表。

3.      在corp数据库中创建零售数据

4.      启动SymmetricDS服务器，然后注册store节点到corp节点

5.      发送数据的初始负载到store节点

6.      履行1个数据推送和数据拉取操作

7.      验证发送和接收到的batch的信息

Installing SymmetricDS

首先，我们将安装两个SymmetricDS的副本，然后分别配置其与数据库的连接信息：

1.      下载SymmetricDS安装文件

2.      创建两个文件夹代表两个机器。1个寄存Corp节点的安装副本，另外一个寄存store节点的安装副本。例如，你可以将这两个文件夹命名为sym-corp和sym-store001，下面将假定你是这样命名的。解压上面下载的文件到两个文件夹中。

3.      属性文件用来寄存启动SymmetricDS需要的最小的配置信息。复制corp样例属性文件到corp engine文件夹，然后复制store属性文件到store的engine文件夹。如果你使用的是上面建议的文件夹命名，你将做下面的复制动：

和

4.      阅读两个属性文件，查看不同的配置。例如，root节点给定1个值为corp的组ID，store节点给定1个值为store的组ID；root节点给定了1个值为000的外部ID，store节点给定了1个值为001的外部节点。

下面是两个节点中engine目录下的两个配置文件都有的配置属性，指定了如何连接特定的数据库服务器（下面的值只是例子）：

5.      下1步，在store-001.properties文件中设置下面的属性，指定root节点所在的位置：

6.      Tip，1个engine的URL是下面这类通用的格式：

URL中的engine.name部份来自节点的配置文件。

1.2. Creating and Populating Your Databases

Important

你必须先为你的root节点和client节点创建数据库。创建的数据库的名字和上边配置文件中配置必须1致。

首先，通过下面的步骤，在root节点的数据库中创建例子的数据库表，加载样例数据，加载样例配置：

1.      打开1个命令行提示符，然落后入到corp安装副本的samples文件夹下

2.      在root节点中通过履行下面的命令为item，price和sale创建样例表：

来自命令行的正告信息是安全的可以疏忽。

另外一个关于属性文件的扼要描写。在启动阶段，SymmetricDS寻觅engines文件夹中的1个或多个属性文件。由于我们已在命令行中指定了1个―engine参数，所以SymmetricDS将会寻觅特定命名的文件，corp-000.properties。在这个例子中，由于在engines文件夹中只有1个属性文件，所以SymmetricDS将会默许加载这个属性文件中的配置。因此，在这个例子中，不指定―engine参数也是可以的。加上这个参数，运行这个例子是，可以减少由于启动错了安装副本而致使的毛病。SymmetricDS将会抱怨丢失了你指定的属性配置文件。

3.      下1步，在corp节点的数据库中创建SymmetricDS特定的数据库表。这些表将包括同步操作的配置信息。下面的命令使用自动创建的特性创建所有必要的SymmetricDS系统表：

4.      最后1步，履行下面的操作，加载样例商品与交易数据和SymmetricDS配置信息到root节点的数据库：

Important

上面的操作，针对MySQL，需要履行insert_sample_mysql.sql文件。针对大小写敏感的表和列的命名，MySQL用反引号代替双引号。

我们现在已穿件了corp数据库表，然后填充了我们的SymmetricDS配置信息和样例数据。下1步，我们将在store节点的数据库中创建样例数据库表，准备接收数据。

5.      打开1个命令提示符，进入store节点的SymmetricDS安装副本的samples文件夹。

6.      履行下面的命令，造store节点的数据库中创建空的样例表：

来自命令行的正告信息是安全的可以疏忽。你可以查看create_sample.xml文件来看看它都有甚么。

登陆数据库，核实两个数据库中的表：

1.      找到需要从corp节点到store节点同步的item表：item和item_selling_price。

2.      找到需要从store节点到corp节点的sale表：sale_transaction和sale_return_line_item。

3.      找到SymmetricDS的系统表，这些表都以sym_作为前缀，像sym_channel,sym_trigger,sym_router和sym_trigger_router.

4.      验证corp节点的item表是不是有样例数据

1.3. Starting SymmetricDS

本教程中的数据库建立和配置现在已完成了。是时候开始使用SymmetricDS了。现在我们启动两个SymmetricDS节点，然后视察它们的日志输出。

1.      打开两个命令行提示符，分别进入到两个安装副本的根目录下的samples目录下。

2.      在corp的samples目录下，履行下面的命令启动corp SymmetricDS：

在首次启动时，corp节点将会创建样例配置文件中所有的trigger。然后在8080端口为corp-000 engine监听同步和注册要求。

3.      在store001节点的samples目录，履行下面的命令，启动SymmetricDS：

这个命令第1次启动store节点的服务器时，将会使用自动创建特性创建SymmetricDS的系统表。然后不断的尝试注册到corp节点（通过前面配置的registration URL，可以知道corp节点的地址）。由于注册还没有打开，store节点将会收到认证失败（403 HTTP响应）。我们在下面的注册部份讨论。

1.4. Registering a Node

当1个未注册的节点启动时，它将尝试注册到registration URL指定的节点（在几近所有的情况下，就是root节点）。通过允许注册和为已注册的节点返回配置信息，Registration 节点集中的管理网络上的其他节点。在本教程中，Registration节点就是root节点，corp节点，这个节点同时参与与其他节点的同步操作。

因此，下1步，我们需要为store节点打开注册，以使store节点可以接收到初始负载的数据，然后就能够接收来自corp的数据，也能够向corp节点发送数据。有几种方式可以完成这个任务。我们将使用SymmetricDS的管理功能，在corp节点上履行1个命令（由于这个节点负责注册管理）。

1.      前面已启动了corp节点和store节点的SymmetricDS利用程序，下面打开1个新的命令行提示符，进入到corp节点的安装副本的根目录下的samples目录。

通过履行下面的命令打开store节点的注册功能：

现在corp的注册功能已为group为store，external id为001的节点打开了。Group和external id信息与store节点中的store-001.properties配置文件中的配置对应。在SymmetricDS中，每个节点都被分配到1个节点组（Node Group），然后给1个external ID代表这个利用程序。在本教程中，我们命名代表商店的group为store，然后我们使用以001开始的数字标示符作为external ID（000代表corp节点）。关于节点组的更多的信息将在下1章节中介绍。

2.      查看store节点的日志输出，看是不是成功注册到corp节点。Store被配置为以随机的时间间隔尝试注册1次，最多1分钟。1旦注册成功，corp和store节点将开始同步。

1.5. Sending an Initial Load

下1步，我们将发送1个数据的初始负载给store节点，再1次在corp节点上使用节点管理功能。

1.      打开1个命令行提示符，进入到corp安装副本的根目录的samples文件夹下。（注意，通常大多数系统命令在corp服务器端直接发出。例如，所有的配置文件，在corp输入，然后同步到任意的client节点。）

2.      履行下面的命令，发送1个数据的初始负载到store节点：

使用这个命令以后，corp节点排队各个store节点拉数据要求。数据的初始负载包括=被配置了同步的每表中的数据。

3.      视察两个节点的日志输出，查看数据传输。Store被配置为每分钟从corp节点拉1次数据。

1.6 Pulling Data

下1步，我们将对中央数据库的item数据做1些修改（我们将增加1个新的商品），然后视察数据被拉到store节点。

1.      打开1个与Corp数据库的交互式sql Session

2.      在store001和store002（本例中只有store001），增加1个新的商品：

1旦statement被提交，数据变化将被SymmetricDS捕获，然后排队等store节点拉数据。

4.      视察两个节点的日志输出，查看数据传输情况。Store被配置为每分钟从corp节点拉1次数据。

5.      在本教程中，item_selling_price被配置为列匹配的Router，特定的定价数据的变化将仅发送给store_id和external ID匹配的节点。在store节点的数据库履行SQL语句，验证是不是有新的数据到达。在本例中，第1条记录将仅仅被发送到store 001。

1.7. Pushing Data

现在，我们将假冒1条交易，然后视察SymmetricDS是怎样把交易信息推送到中央节点的。（在这我们可以发现，数据的拉取和推送都是各个从节点的事，中央节点只负责管理）

1.      对store节点的数据库打开1个SQL会话

2.      增加1个新的交易信息到store节点的数据库。

1旦statement被提交，数据修改将被捕获，然后排队等候store节点推送到中央节点。

3.      视察两个节点的日志输出，查看数据传输情况。Store节点被配置为每分钟推送1次数据到corp节点。

1.8 Verifying Outgoing Batches

前面我们演示了已推送和拉取了数据，下面我们将描写你如何获得数据的batch和发送的相干的信息。1个batch被用来追踪和发送1个或多个数据变化到给定的节点。数据所在的节点创建1个batch，接收数据的节点接收到数据然后做出回应。

除此以外，在SymmetricDS中，表被分组到不同的数据通道，为了允许不同的数据类型在部份数据类型有毛病的情况下也能够同步。例如，如果将要发向给定的channel的batch产生了毛病，这个batch将会在这个channel的每次同步操作中进行尝试，直到这个batch不在产生毛病。只有在这个batch不在产生毛病以后，发向这个channel的其余的batch才会被发送。使用这类方式，在数据源产生的数据变化的顺序能保证以一样的顺序被发送到目的地，并且在目的地以一样的顺序利用这些变化。但是，1个channel上没有毛病的batch不会被另外一个有毛病的batch的channel阻塞。使用这类方式，1个channel上的数据变化不会被另外一个channel上的毛病阻塞。

可以通过下面的步骤查看发出的batch信息：

1.      打开1个与corp或store节点的数据库服务器连接的会话

2.      确认已捕获到的数据变化：

这个表中的每行数据代表1行变化的数据。Data_id是顺序增长的，所以最近的1个data id应当与你的数据插入SQL相干联。Event_type是I代表insert，U代表update，D代表delete。对插入和更新，捕获到的数据在row_data列中，对更新和删除，主键的值在pk_data列中。

3.      使用上1步得到的data_id，确认数据变化在某个batch中：

batch是基于必要的目的节点信息被创建的，称之为Route Job。作为Route Job的1部份，数据变化使用使用batch_id被分配到1个batch，batch_id在追踪和同步数据的时候会用到。Batch和数据之间的连接信息通过sym_data_event表被连接。

4.      使用上1步得到的batch_id，去人数据变化被batch，发送到目的地并得到响应：

初始的Batch，在刚创建和还没有发送到1个节点的时候，有1个NE（new）的状态。1旦收到节点的响应，成功发送时，batch状态将会变成OK，发送失败，将会变成ER。如果这个batch失败，这个batch的error_flag将会被设置为1，已失败的batch可能在它在重新尝试时成功，这时候，这个状态需要被改变。

理解这3个表，还有我们在下个部份讨论到的第4个表，是诊断可能遇到的同步问题的关键。在你使用SymmetricDS的时候，不论是在实验环境还是生产环境，花些时间监控这些表可以更好的理解SymmetricDS是如何工作的。

1.9. Verifying Incoming Batches

接收数据的节点会保持本节点响应的batch信息和加载的数据相干的统计信息。重复的batch默许是疏忽的，但是可以通过修改incoming.batches.skip.duplicates 改变这个行动。

通过下面的步骤视察接收到的batch信息：

1.      打开1个与corp或store节点的数据库交互的SQL会话

2.      使用上个部份取得的batch_id，确认接收和响应的batch信息：

1个batch代表节点加载的数据变化的集合。表中记录了创建和发送这个batch的节点，batch的状态成功时是OK，失败时是ER。

1.10. Multi-Homing

我们的快速入门指南到这就结束了。我们已成功的创建了两个同步节点，然后在两个数据库中履行了同步操作。现在我们退回去，讨论1下在指南的第1步讨论的1个问题。也就是，在指南中，让你安装两个SymmetricDS副本的那1步。

在上边的例子中，我们在每个SymmetricDS安装副本的engines目录中替换了1个属性文件。当SymmetricDS被启动的时候，SymmetricDS被初始化，然后根据提供的配置文件创建1个SymmetricDS engine（再说1次，1个engine就是1个SymmetricDS节点，负责1个特定的数据库）。

事实上，1个SymmetricDS利用程序可以同时启动多个engine。当SymmetricDS启动时，它在engines目录中寻觅1‘.properties’结尾的文件。它将为找到的每个配置文件启动1个SymmetricDS engine。命令行提示符中的―engine参数会覆盖上边的操作，将会使SymmetricDS只启动命令行中指定的1个engine。在1个SymmetricDS安装副本启动多个engine的这类情况，叫做‘multi-homing’。

对上边的例子，如果我们想改成multi-homing的架构，只要要做下面的步骤：

1.      安装1个SymmetricDS副本代替上边的两个安装副本。不在需要1个目录代表两个机器。

2.      从安装副本的samples目录拷贝两个配置文件到engines目录。

3.      上边所有运行过的命令在此安装副本的samples目录下在运行1遍

4.      启动SymmetricDS时，不在需要指定特定的engine，这样将启动两个engine。这个命令还是从sampls目录运行，以下：

注意使用上边的命令，我们不在使用9090端口。SymmetricDS现在在8080端口监听corp和store engine之间的数据交换。

5.      除启动服务器的命令，所有其他的命令的履行还是需要使用―engine参数指定engine。由于要给特定的节点（engine）来处理命令，像打开注册，发起从corp到store的初始负载等等。

生活不易，码农辛苦
如果您觉得本网站对您的学习有所帮助,可以手机扫描二维码进行捐赠