服务器数据同步

ugii

现在的网站随着访问量的增加,单一服务器无法承担巨大的访问量,有没有什么方便快捷的方式解决这个问题呢,答案是”有”!
. T4 }6 K8 t9 k* y比如建立服务器群,进行均衡负载.
& o* u1 G2 D- g但是如果要解决像电信网通这样的互访问题(中国网民的悲哀..),这个解决办法就无能为力了!
' {9 _! E7 l, _要解决这个问题最方便快捷的方式就是建立镜像网站!由访问者自己选择适合自己网络的速度最快的网站!这样即可以解决线路问题,又可以解决访问量问题!
1 J. z# N) `- Z& j, a4 k
( B0 @3 m, W6 n( V" [& d7 f+ C
2.网站同步的数据分类

* i' i# O/ b0 _* c8 ^. {网站数据基本分为两类:
5 J0 t" s4 ~' P5 K* m3 d. J! j# L一类是文件,比如HTML,ASP,PHP等网页文件,或者RAR,ZIP,RM,AVI等可下载文件!
要实现他们的同步很简单,用FTP同步软件就可以了!至于哪几个我会在后面做详细介绍.

一类是数据库数据文件,比如MySQL,SQLServer等等!
数据库同步的方法也很多,最简单的办法只是将数据库目录同步一下就OK了!
在后面我也会做详细讲解!
9 Q3 N1 @. {3 C2 d5 H
3 f2 A! e' E" Z) `+ X, C3 F2 X. i
; W1 E& ?' I3 E! `1 b) Q3.网站文件的同步

在这里用到的主要工具就是FTP,网站文件同步分两种情况,一种是本地到远程,一种是远程到远程(FXP)!第一种不用说了,第二种远程到远程即FXP,支持它的软件也很多,但是真正适合多网站同步镜像的却不多!
; O0 S; o  x, B6 |% U# p下面我介绍几个我认为不错的软件!
1 T" o8 }( I' p, U" {) N$ ?) D7 \: {
1.首先我要推荐的是国产的FTP软件”网络传神”,功能非常强大,特别是在网站的同步镜像方面,可惜的是,这款非常经典的软件已经不再更新了,最后更新时间是2003年3月,最后一个版本是3.12!虽然如此还是非常好用的!下面是一段官方的简介:

网络传神完全吸收了Cuteftp和UpdataNow的全部功能，并且增加了其他软件没有的多项功能：支持网站互传；支持网站同步(UPDATANOW)；支持后台上传(多线程上传多个文件)；可同时打开多个站点；多站点计划上传功能，支持镜像站点；支持宏操作支持计划操作；支持文件高级比较上传；支持目录隐藏过滤（为用ForntPage作主页的朋友带来福音）；服务器自动识别功能；资源管理器浏览方式；可以自定义命令；支持RFC959标准具有更好的稳定性；完备的信息返回机制及错误监控机制完整的中文帮助。
: I# x- t. N8 E
/ M6 Q2 p! N* p2 @8 `$ G& \" L: r2.第二款是由ReGet同一开发公司制作的专用于网站同步的软件”WebSynchronizer”,用这款软件,你才会体验到网站同步的方便快捷,简单容易.最新版本是1.3.62,网上能找到XX的最后版本是1.1版!下面是一段简介:

& |  V' q0 Q4 g1 m档案同步化工具-WebSynchronizer，由知名续传软件ReGet之软件出版公司所推出，是网站同步化、档案镜像、档案备份的绝佳工具，可以执行下列主要工作：1)本机资料夹及远程资料夹的同步化；2)两台远程计算机中的资料夹同步化；3)两个本机资料之同步化。

' V6 r' e' N0 m! s4 D3 `) _8 Y1 B3.其他还有一些软件如同步快梭(AutoSyncFTP),也能实现简单的网站同步,不过,这款软件非常不稳定,而且2001年就已经停止开发.所以,不用考虑了!还有上次有朋友提到的SiteMirro,由于网上找不到可以用的版本,所以没有办法测试!


5 G5 C1 ^9 W! X6 Y3 V( K网络传神网站同步镜像使用傻瓜指南

; [. W% C: i1 L! d* X
# E7 ]9 l# S7 e8 I2 h% N' q上次在网络技术版已经发过一个简单的使用方法介绍,如果嫌我罗嗦(o(>_<)o),大家可以参考那篇文章:
http://bbs.et8.net/bbs/showthread.php?t=650129
) E& N$ V: ^5 e! i8 _: J8 x2 U
第一次运行网络传神的时候,它会让你选择”完全模式”和”启动模式”,要使用网站同步必须选择”完全模式”.

6 n( }2 E7 n" u! i9 Y! ?( A2 @( w. g
  q( m$ t( _3 z3 B进入主界面:你会发现这个软件非常像FlashGet,要使用网站同步功能,点击软件左下角的”FTP客户端”.


现在你要做的就是添加你的镜像母站和需要镜像的网站:文件->站点管理,在里面添加你需要同步的几个的FTP服务器,下面我将介绍具体设置(主要是镜像母站的设置)


& I' H( [5 E' T, w& g母站设置最重要的地方就是”比较目录(网站同步)”:

1 {: t- \+ g1 u" U2 d; P- z2 s
9 S, V9 V: f& G1 K, ]* G1.拖动传送
+ l0 U0 ?* T; Y就是手动拖动传送时候的传送方式,非拖动方式不受影响,因为母站的更新基本上是从本地目录进行的,所以建议这里选择第二项”只上传不同的文件”,镜像站点这里可以忽略
6 f; i5 i6 V2 L: }" C2.磁盘比较设置
) ~1 [' g- U$ J$ ~这个功能非常有用,可以通过文件长度和文件日期进行文件差异对比.
. {% @* Y8 i, {& Q
  v, {& g+ q* O; K
你还可以设置本地目录过滤和服务器目录过滤,非常灵活!
% I# v3 n5 i) Z/ I2 J; A好了,添加好母站和镜像站之后,我们来设置同步:
8 P/ i0 V0 Y/ n
% D" D# O( L; r8 p* Y! d
如果是添加镜像站,则会跳出下面的母站选择窗口:


" ~+ w7 o4 V- c设置好多个镜像站点之后,返回主界面就可以进行网站同步了:

" m* f/ j' ]+ L1 R9 a( V
. {: v2 h" z  G注意事项：
一般不要改动镜像站点前面的“对钩”标志，因为镜像站点同步的原理是“根据主站点的同步信息更新镜像站点”，如果景象站点没有更新那么必须将该镜像站点单独同步。
0 S6 g9 h% Z5 m. F& A& H注意一般应该“选项窗口”-〉“FTP客户端”-〉“计划”中的“最大连接个数”和“最大线程个数”一般不要改动保持为“1”。
如果同步时某个站点出错同步没有完全完成只需按“计划”窗口中的按钮单独执行某个站点的传送即可。

再介绍一下网站镜像同步中必要的功能,定时同步,这样你就只要做好母站的更新,其他的让网络传神帮你完成:
/ g3 j- g6 o1 z8 G, T0 U- i点击设置:
3 k* @# i- W* h3 O2 Q* o
  R1 v' u( e' X4 T  o
6 k( a% g: {0 i! g$ r进入网络传神的选项设置窗口,选中FTP客户端中的定时同步


定时下载：在指定的时段内下载文件。
定时上传：在指定的时段内用网站同步的方法进行上传。
- I6 S' e6 H/ r/ ~, y4 Z开始时间：如果要使用定时方式必须设置此项，在设置的时间中会自动开始所有设置为计划的站点。
8 i8 R7 l. F, \4 Z2 \停止时间：如果设置此项则当系统时间大于停止时间时自动停止所有设置为计划的站点。

注意：定时上传种没有“停止时间”选项，网站同步完成后会自动停止，同时网站同步同一时间只能运行一次。
* z1 y( ]& A9 F1 t/ z
网络传神还有很多为便于同步镜像设置的功能,大家实际使用中去体会吧!


WebSynchronizer网站同步镜像使用傻瓜指南


( G5 E& J% X1 y4 r4 F$ CWebSynchronizer功能非常强大,不单单是网站同步,还可以进行本地目录同步,本地到远程同步,功能方面远胜过传神,不过,国内好像没有汉化版,对于一些对英文感冒的朋友用起来会不太舒服,希望CCF里的汉化高手能将他中文化!

- G4 M5 ~8 N# q+ F) O开始运行程序,老外的软件就是智能,一打开这个软件就会有一个同步向导跳出来!

6 a/ G! B8 E/ F! X; ~" _
在这里,你也看出来了吧,这个软件只支持两个目录间的同步.不过,我们可以创建多个项目来解决这个问题!具体我在后面介绍!这里,我们来看看如何建立两个远程目录的同步!
选择第二项,进入下一个选择框:
! S. [  K* Y# |, H" }6 B9 y

- O& |2 l% p& ]1 v. t- E& v5 L网站同步当然是选择第一项了!再进入下一步,要你选择同步的第一个服务器,建议在这里serverslist,先编辑好需要同步的几个FTP

/ E  F; u% p! w1 x
同步方式设置说明:
第一项的意思是:上传下载所有改变的文件
, b5 q* j) B4 X4 ~" D第二项的意思是:不改变文件夹内容,只下载新的文件

" h5 k+ Y1 M% g& a. |; z0 n点击下一步进行第二个服务器设置,方法和第一个一样!
设置完成后,你还可以修改任务名称!
0 O$ B# c6 S- C2 f: P+ X/ f我觉得这点就是这个软件非常优秀的地方,以任务的方式进行管理.非常方便!
) E1 _! ?/ t: v0 E  @) r' `
. g# P1 C9 t& R/ E
1 {: {' j3 |2 D( |/ y$ L$ iOK,现在我们就可以看到他的主界面了!
. e4 E9 s& V! \8 h% c
! Z) N7 q! G" l! {! q* Q
+ `' k) z4 _6 r) b1 C6 S$ Z还有一点要提,他的计划任务更能也很强大,在这里我就不再多说了!用过才知道他的强大!

有朋友会说,我要进行两个以上的网站同步怎么办?
很简单,再多建几个任务就可以了,要镜像多少网站都没有问题!
这个软件的网站同步镜像可以非常灵活,比如可以本地-远程,然后再远程-远程!或者本地-远程1,本地-远程2,远程1-远程2,任何情形下的同步都可以完成!
1 s+ L) ?* u' j1 {" `- d. R
" c6 c2 \; A, A3 p2 @
: K+ [! r, [: k5 `4 d* W5 D数据库同步操作指南
2 C, t: E: @% X8 [
说完了文件同步,我们再来探讨一下数据库同步!
/ o2 Y5 C) L  U% z这里我主要教大家两种最常用的数据库的同步方法!
! D) C; }. g/ c! H7 B3 g0 N3 H
# w, x: n  R6 J9 P: XMySQL
$ A9 N# ?6 v* i- f3 C% K' o! h
MySQL数据同步主要有三种方式:
8 c! N. z/ f) l2 h, b- Y) t% w1.利用MySQL自身的数据库同步功能
9 V4 `! W' P) _2 }' M1 D( S# _* A2 y2.利用MySQL数据库的特性(数据库存在固顶目录,并且以文件形式存储),进行数据库目录同步以达到数据同步目的
3.利用专用的MySQL数据库同步软件

1.利用MySQL自身的数据库同步功能(下面参考自网上的文章,写的非常详细了)
MySQL从3.23.15版本以后提供数据库复制功能。利用该功能可以实现两个数据库同步，主从模式，互相备份模式的功能.
0 Q6 ~# n$ D3 s; d# C) l# c
9 L* I3 I# P, K  R数据库同步复制功能的设置都在mysql的设置文件中体现。mysql的配置文件（一般是my.cnf），在unix环境下在/etc/mysql/my.cnf或者在mysql用户的home目录下的my.cnf。

windows环境中，如果c:根目录下有my.cnf文件则取该配置文件。当运行mysql的winmysqladmin.exe工具时候，该工具会把c:根目录下的my.cnf命名为mycnf.bak。并在winnt目录下创建my.ini。mysql服务器启动时候会读该配置文件。所以可以把my.cnf中的内容拷贝到my.ini文件中，用my.ini文件作为mysql服务器的配置文件。
1 ?, q9 z7 ~  n. t
设置方法：
设置范例环境：
操作系统：window2000professional
mysql：4.0.4-beta-max-nt-log
; w1 e- N+ `& h$ mAip:10.10.10.22
Bip:10.10.10.53
. J5 g  r0 U* _( l2 zA:设置
% K  ~  N8 Z3 t8 e3 F% C: H! [, F1.增加一个用户最为同步的用户帐号：
GRANTFILEON*.*TObackup@'10.10.10.53'IDENTIFIEDBY‘1234’
5 [7 E" W# J' Z% F! Z8 G+ \2.增加一个数据库作为同步数据库：
* z' F: |! B0 W# X; Ucreatedatabasebackup
$ v! c  e2 d- V+ YB:设置
8 x% U# U7 \2 w0 u* N* g1.增加一个用户最为同步的用户帐号：
; n" b! S( q2 B* sGRANTFILEON*.*TObackup@'10.10.10.22'IDENTIFIEDBY‘1234’
2.增加一个数据库作为同步数据库：
createdatabasebackup
主从模式：A->B
; u. z/ a  Z" g+ C8 S$ b( S4 SA为master
  h8 p9 g2 O! |2 X5 `& R5 D修改Amysql的my.ini文件。在mysqld配置项中加入下面配置：
server-id=1
4 |) m# I+ _6 `( m+ b  alog-bin
#设置需要记录log可以设置log-bin=c:mysqlbakmysqllog设置日志文件的目录，
#其中mysqllog是日志文件的名称，mysql将建立不同扩展名，文件名为mysqllog的几个日志文件。
" s1 r7 o' r5 L; z) jbinlog-do-db=backup#指定需要日志的数据库
重起数据库服务。
7 X3 p; S. ~' K2 \1 ]9 H; l- V用showmasterstatus命令看日志情况。
B为slave
修改Bmysql的my.ini文件。在mysqld配置项中加入下面配置：
" r/ G& q) K( d) @' yserver-id=2
0 c, x8 x) [' s$ g; t* p1 p6 Cmaster-host=10.10.10.22
) j; f7 i, T- V. v- D; `master-user=backup#同步用户帐号
master-password=1234
  w& \4 {9 b& u/ e" l* }( P  Smaster-port=3306
master-connect-retry=60预设重试间隔60秒
+ Q7 A  S3 s4 u2 ^: l( `% B5 Freplicate-do-db=backup告诉slave只做backup数据库的更新
0 Q# _/ b7 p$ c" g8 B4 r重起数据库
用showslavestatus看同步配置情况。
6 L9 N1 ?' r- Y7 s# Q注意：由于设置了slave的配置信息，mysql在数据库目录下生成master.info
所以如有要修改相关slave的配置要先删除该文件。否则修改的配置不能生效。
, C. ?7 H$ q( }( H" B- `双机互备模式。
; r2 q& V- V! c如果在A加入slave设置，在B加入master设置，则可以做B->A的同步。
' t4 {: ?/ \' V4 e+ y+ D9 E* @4 n0 U0 A在A的配置文件中mysqld配置项加入以下设置：
1 ?8 w6 h/ x4 Lmaster-host=10.10.10.53
" \# E5 n+ j, v: Umaster-user=backup
5 ~# H% A4 ?7 Q% l! M0 y6 [master-password=1234
replicate-do-db=backup
5 _1 r, H( z, p, f' B4 {% O/ Nmaster-connect-retry=10
0 r7 ?2 i: N5 o' f. T) o在B的配置文件中mysqld配置项加入以下设置：
log-bin=c:mysqllogmysqllog
  T. H2 W7 Q/ H% }binlog-do-db=backup
注意：当有错误产生时*.err日志文件。同步的线程退出，当纠正错误后要让同步机制进行工作，运行slavestart
. B2 g' U( M" d3 u. f重起AB机器，则可以实现双向的热备。
测试：
6 c3 S' Y7 p& |5 K0 X3 C向B批量插入大数据量表AA（1872000）条
A数据库每秒钟可以更新2500条数据。
% {$ [. c, F$ E1 }& L
: x2 K$ S/ e; ^& \
8 ?0 N$ R8 H3 J( Z$ d2.数据库目录同步,方法和文件同步一样,设置好需要同步的两个数据库目录就可以了!
0 ^7 [& \0 g8 n1 ]6 j缺点很明显,数据同步只能单向进行,可以作为备份方案

3.用专用的MySQL同步软件进行同步
( B6 m/ z2 }8 P; p这方面的软件有SQLBalance和MyReplicator,优点是方便直观,还有很多争强功能!
缺点和2一样,只能单项同步!
当然你也可以修改镜像网站的程序为提交数据到母数据库,读取则在当前镜像下的数据,不过,修改起来麻烦!普通用户修改也非常难!呵呵,大家了解一下就可以!给大家一个思路!有能力的朋友可以试试阿!
4 p7 p' p4 n2 y# c
: H2 u1 i. B& ^' H! m3 N4.关于MySQL论坛的数据同步
由于数据来源的不可控制(不好表达),论坛数据是实时的,而且还要考虑来自镜像论坛的数据,如何实现镜像论坛与母论坛数据同步呢?
用1中介绍的MySQL自带的数据库同步功能互相备份模式就可以实现的!
3 u' ^4 E* D! T: X0 A# H不过,具体的应用我没有测试!稳定性不敢保证!
" D  k5 F% ~: a2 n' _* J有能力的朋友推荐用下面这种思路来同步,相对来说减少点效率,但能减少发生的错误!
比如镜像论坛数据同步:
1.母论坛和镜像论坛的数据全写在母论坛数据库里,主从模式,读取只在本地读取,这个需要修改程序!
# X8 O$ ?+ C0 d5 G8 o. z/ o/ m
2.每次写数据,都同时提交到两个数据库中,安全,但是效率很差,也得修改程序!
/ M; K7 e1 ~- J3 t; I8 ?& i

8 U) W$ M. J" t& |MSSQL
3 o6 \  O2 I5 [9 T. g/ A# T" j, b
MSSQL数据同步利用数据库复制技术实现数据同步更新(来自网络,也是非常完美的教程)
复制的概念
复制是将一组数据从一个数据源拷贝到多个数据源的技术，是将一份数据发布到多个存储站点上的有效方式。使用复制技术，用户可以将一份数据发布到多台服务器上，从而使不同的服务器用户都可以在权限的许可的范围内共享这份数据。复制技术可以确保分布在不同地点的数据自动同步更新，从而保证数据的一致性。
SQL复制的基本元素包括
出版服务器、订阅服务器、分发服务器、出版物、文章
! A6 @2 N2 ]% i- o0 i/ QSQL复制的工作原理
" F0 x3 s& o, m1 c( @1 G( r2 z7 \' zSQLSERVER主要采用出版物、订阅的方式来处理复制。源数据所在的服务器是出版服务器，负责发表数据。出版服务器把要发表的数据的所有改变情况的拷贝复制到分发服务器，分发服务器包含有一个分发数据库，可接收数据的所有改变，并保存这些改变，再把这些改变分发给订阅服务器
( M2 S( ]8 r  `& |, n( CSQLSERVER复制技术类型
SQLSERVER提供了三种复制技术，分别是：
1、快照复制（呆会我们就使用这个）
9 ~+ G" s" ?" a6 s# c2、事务复制
3、合并复制
只要把上面这些概念弄清楚了那么对复制也就有了一定的理解。接下来我们就一步一步来实现复制的步骤。
第一先来配置出版服务器
(1)选中指定[服务器]节点
* v# x2 h3 u" f2 t# D(2)从[工具]下拉菜单的[复制]子菜单中选择[发布、订阅服务器和分发]命令
(3)系统弹出一个对话框点[下一步]然后看着提示一直操作到完成。
: x0 h  X( M. b(4)当完成了出版服务器的设置以后系统会为该服务器的树形结构中添加一个复制监视器。同时也生成一个分发数据库(distribution)
第二创建出版物
  _# r3 I5 p4 y0 e4 m/ b(1)选中指定的服务器
(2)从[工具]菜单的[复制]子菜单中选择[创建和管理发布]命令。此时系统会弹出一个对话框
(3)选择要创建出版物的数据库，然后单击[创建发布]
(4)在[创建发布向导]的提示对话框中单击[下一步]系统就会弹出一个对话框。对话框上的内容是复制的三个类型。我们现在选第一个也就是默认的快照发布(其他两个大家可以去看看帮助)
; J3 G* v* M9 J(5)单击[下一步]系统要求指定可以订阅该发布的数据库服务器类型，SQLSERVER允许在不同的数据库如ORACLE或ACCESS之间进行数据复制。但是在这里我们选择运行"SQLSERVER2000"的数据库服务器
$ |1 V" v/ \* i(6)单击[下一步]系统就弹出一个定义文章的对话框也就是选择要出版的表
(7)然后[下一步]直到操作完成。当完成出版物的创建后创建出版物的数据库也就变成了一个共享数据库。
: [/ r# T9 b4 o! S. O第三设计订阅
( K: J0 g  b) h* i(1)选中指定的订阅服务器
( E6 Q4 t. X: R) t(2)从[工具]下拉菜单中选择[复制]子菜单的[请求订阅]
(3)按照单击[下一步]操作直到系统会提示检查SQLSERVER代理服务的运行状态，执行复制操作的前提条件是SQLSERVER代理服务必须已经启动。
0 m% I5 J% i! }- p) c1 H(4)单击[完成]。完成订阅操作。
- v' a: J+ {1 T! L7 C完成上面的步骤其实复制也就是成功了。但是如何来知道复制是否成功了呢？这里可以通过这种方法来快速看是否成功。展开出版服务器下面的复制——发布内容——右键发布内容——属性——击活——状态然后点立即运行代理程序接着点代理程序属性击活调度把调度设置为每一天发生，每一分钟，在0：00：00和23：59：59之间。接下来就是判断复制是否成功了打开C:/ProgramFiles/MicrosoftSQLServer/MSSQL/REPLDATA/unc/XIAOWANGZI_database_database下面看是不是有一些以时间做为文件名的文件夹差不多一分中就产生一个。要是你还不信的话就打开你的数据库看在订阅的服务器的指定订阅数据库下看是不是看到了你刚才所发布的表—
2 [) M! O( X5 ?* ^, @' j' j一个手工同步的方案
--定时同步服务器上的数据
--例子:
8 G6 Y6 N& W- {# u, s--测试环境,SQLServer2000,远程服务器名:xz,用户名为:sa,无密码,测试数据库:test
& F1 o( g8 ^8 @& U1 p+ d--服务器上的表(查询分析器连接到服务器上创建)
createtable[user](idintprimarykey,numbervarchar(4),namevarchar(10))
go
( Y8 }* X& G% B3 G; S' t; W1 ]--以下在局域网(本机操作)
/ q: _7 X' b4 ^2 Q9 K( L--本机的表,state说明:null表示新增记录,1表示修改过的记录,0表示无变化的记录
! @6 u5 J: F5 Z: H* s' f4 t4 vifexists(select*fromdbo.sysobjectswhereid=object_id(N'[user]')andOBJECTPROPERTY(id,N'IsUserTable')=1)
) G) K  z6 p& ~* i& qdroptable[user]
5 Q& O/ S) D4 X1 U! oGO
4 E6 f0 f8 A. {" h# U( H' Ycreatetable[user](idintidentity(1,1),numbervarchar(4),namevarchar(10),statebit)
go
) l' }0 W1 Y2 v: @, O--创建触发器,维护state字段的值
% L; H! D9 z2 H2 q1 @createtriggert_stateon[user]
0 J! w" l$ G6 I0 u" p! A0 m' `afterupdate
8 X9 R3 C; W" i1 Jas
- i* u  a' j8 g7 ^update[user]setstate=1
1 O4 l1 J5 c, t* b8 {6 Qfrom[user]ajoininsertedbona.id=b.id
3 \  ]) g) }" j$ f( \wherea.stateisnotnull
go
--为了方便同步处理,创建链接服务器到要同步的服务器
--这里的远程服务器名为:xz,用户名为:sa,无密码
/ h- O2 n% m# z8 M! Cifexists(select1frommaster..sysserverswheresrvname='srv_lnk')
) a0 ?- ?& p: s$ F" Kexecsp_dropserver'srv_lnk','droplogins'
8 a) ~1 _: s0 {, m% hgo
execsp_addlinkedserver'srv_lnk','','SQLOLEDB','xz'
: {; H5 r6 P4 A5 d+ F9 @execsp_addlinkedsrvlogin'srv_lnk','false',null,'sa'
6 O0 o; p: A7 Ggo
( D5 m; i0 U7 T$ [' I--创建同步处理的存储过程
ifexists(select*fromdbo.sysobjectswhereid=object_id(N'[dbo].[p_synchro]')andOBJECTPROPERTY(id,N'IsProcedure')=1)
/ J$ V" v# P; o$ t1 R6 Fdropprocedure[dbo].[p_synchro]
GO
1 t: B! u' G# fcreateprocp_synchro
( g  V0 _$ `4 `, O% @4 Sas
--setXACT_ABORTon
--启动远程服务器的MSDTC服务
--execmaster..xp_cmdshell'isql/S"xz"/U"sa"/P""/q"execmaster..xp_cmdshell''netstartmsdtc'',no_output"',no_output
--启动本机的MSDTC服务
, F) ^6 n( g. H" q! u& a* J--execmaster..xp_cmdshell'netstartmsdtc',no_output
" l5 d- j4 y* d5 ]6 Y--进行分布事务处理,如果表用标识列做主键,用下面的方法
--BEGINDISTRIBUTEDTRANSACTION
--同步删除的数据
deletefromsrv_lnk.test.dbo.[user]
/ @2 _6 O6 h3 G% o/ X* a9 S. Cwhereidnotin(selectidfrom[user])
2 f' x! X% @5 [& p+ N--同步新增的数据
+ p( K: y6 K; C$ b; Iinsertintosrv_lnk.test.dbo.[user]
selectid,number,namefrom[user]wherestateisnull
--同步修改的数据
updatesrv_lnk.test.dbo.[user]set
number=b.number,name=b.name
fromsrv_lnk.test.dbo.[user]a
join[user]bona.id=b.id
whereb.state=1
) m/ [) z) z! ]& J0 f2 q--同步后更新本机的标志
& V& c, z* t/ h) F. ~' L# O0 Pupdate[user]setstate=0whereisnull(state,1)=1
--COMMITTRAN
& v; q7 o$ {  S& g% f9 a+ Dgo
) y5 F, \( {! q8 J0 \7 `/ f+ y--创建作业,定时执行数据同步的存储过程
ifexists(SELECT1frommsdb..sysjobswherename='数据处理')
EXECUTEmsdb.dbo.sp_delete_job@job_name='数据处理'
execmsdb..sp_add_job@job_name='数据处理'
7 r. u0 r; \' s; Z& }% b( V" |( ~--创建作业步骤
$ r4 C( }% e" I; zdeclare@sqlvarchar(800),@dbnamevarchar(250)
9 [* b0 r( L9 \' _) C7 j6 Uselect@sql='execp_synchro'--数据处理的命令
,@dbname=db_name()--执行数据处理的数据库名
execmsdb..sp_add_jobstep@job_name='数据处理',
@step_name='数据同步',
5 n8 B/ H4 t2 Q" a6 C6 G& H- i9 ?@subsystem='TSQL',
. Q; F2 P( K; _@database_name=@dbname,
9 k# r5 Q2 m- q, t4 C@command=@sql,
( O3 v3 b/ I1 V% ]# s" {9 ]@retry_attempts=5,--重试次数
@retry_interval=5--重试间隔
. [) [# X+ q) q4 `6 J7 X--创建调度
. K( s# W$ z/ `" @4 T, KEXECmsdb..sp_add_jobschedule@job_name='数据处理',
! ?: y. {7 e" p@name='时间安排',
@freq_type=4,--每天
@freq_interval=1,--每天执行一次
@active_start_time=00000--0点执行
6 x4 J1 H% t% n! c; O- lgo