spring integration 项目实战1、之项目介绍和环境搭建

spring integration 项目实战一、之项目介绍和环境搭建

??????? 网上见到很少的spring integration 的实际使用教程，碰巧最近项目中遇到一个需求，非常适合使用spring integration 进行开发，于是参考spring integration 的Refrence，自己摸索了下算初步完成，现在已经在运行中。在此发布出来，一是为了记录自己的工作成果；二是为了抛块砖头引下玉，希望大家可以多指出改进的地方。一起学习和完善spring integration 的使用。

??????? 一、首先说下项目的大概需求：我们自己的系统A(以下用SYSA代替)，外不系统（SYSB）,SYSA用的是Java、Linux和Oracle环境，SYSB用的是.NET、Windows和SqlServer环境，现在的需求是SYSA中有一部数据要同步给SYSB，为方便叙述以下把要同步的数据看成是一个表，用TBL_SYSCHN,表示。当在SYSA中对TBL_SYNSC进增、删、改的时候要能（准实时）同步到SYSB中。两方商定的主要规则如下：

1、SYSA要能将变化的数据抽取出来并以文件的形式放入共用FTP服务器；

2、SYSA在将同步的文件放入FTP后，通过TCP/IP协议通知SYSB，告诉SYSB可以取新的同步数据了。

3、同步文件格式是JSON格式的；介绍表结构时候同时介绍协议的JSON格式。

4、TCP/IP消息双方共同制定的可识别格式；

（说实话，不知道谁谈定的这种开发规则，简直是蛋疼！！没办法，定了就要开发哇。）

???????? 大概需求就是如此，其实，实际项目中要同步的数据不止一张表。要建立一个多张表共用的同步数据表TBL_SYSCHN_DATA来进行同步；所有要同步的数据通过关联TBL_SYSCHN_DATA来抽取。为叙述方便现在只针对一张表同步来叙述。表结构大致如下：

??????? 二、表结构介绍：

?

?????? 其中TBL_SYSCHN是要同步的数据；TBL_SYSCHN_DATA是记录TBL_SYSCHN中某条数据同步信息的；比如，向TBL_SYSCHN中插入了一条数据，插入的数据的SYSCHN_ID为1；则TBL_SYSCHN_DATA会同时记录一条相应的数据，内容如下：

SYSCHN_DATA_ID ： 自增一个

SYSCHN_TBL_ID ：1 --插入的TBL_SYSCHN的数据的ID

SYSCHN_TBL_NAME：‘TBL_SYSCHN’

SYSCHN_FLAG：‘0’ --表示未同步。

SYSCHN_DATE：null

SYSCHN_OP：1? ---表示插入一条数据。

?

???????? 同步的时候关联着两张表就可将要同步的数据抽取出来。JSON的格式规定为

{"syschnDataId ":'',"syschnTblId":'',"syschnOp":'',"syschnTblName":'',"entryData":{"SYSCHN_TBL_ID ",'',"COL_A":'',"COL_B":'',"COL_C":''}}

而且这些数据写在一行上，中间不能分行，每行以换行符结尾。一个同步文件为N行这样的数据。

??????? 三、TCP/IP，消息的格式为

?????????????客户端发送格式：? FLAG_GB|FTP文件名|文件大小|发送标志|FLAG_ED；

???????????? 服务端返回格式：? FLAG_GB|接受标志|处理标识|FLAG_ED；

?以上就是大体需求，下面按照以上需求用Java? spring integration进行实现。

??????? 四、开发环境搭建

??????? 不少刚接触spring integration的人都刚到对 spring integration无从下手，我在网上也搜索了些资料没有一个详细的关于spring integration的搭建教程，一开始我很不解，直到完成这个项目后才发现是自己有些太无知了，呵呵。其实spring integration的开发环境和Spring的开发环境是一样的，只是要在项目中多加入一些关于spring integration的Jar包而已。下面就说下我的环境

1、JDK1.6或以上；

2、Eclipse或者Spring Tool Suite ，我用的后者；

3、Spring3.2.6；

4、Spring Integration 3.0.0；

5、数据库Oracle；

6、ftp服务器Serv-U;

首先新建工程，我用的Maven；所以新建Maven工程；

?

选择Maven Project->Nnext；

?

?如上图勾选->Next；

?

?

根据你的情况填写以上->Finish;

?

?

?

建好后的项目结构，下面添加pom.xml配置，让Maven自动添加项目所需Jar包；

?

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.joinandjoin.javaeye.sip</groupId><artifactId>siptest</artifactId><version>0.0.1-SNAPSHOT</version><name>siptest</name><description>siptest</description><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><spring.integration.version>3.0.0.RELEASE</spring.integration.version><spring.version>3.2.6.RELEASE</spring.version><jackson.version>2.2.3</jackson.version><jackson.asl.version>1.9.13</jackson.asl.version><junit.version>4.11</junit.version><log4j.version>1.2.17</log4j.version></properties><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.1</version><configuration><source>1.6</source><target>1.6</target><compilerArgument>-Xlint:all</compilerArgument><showWarnings>true</showWarnings><showDeprecation>true</showDeprecation></configuration></plugin><plugin><groupId>org.mortbay.jetty</groupId><artifactId>jetty-maven-plugin</artifactId><version>8.1.11.v20130520</version></plugin><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.1</version><configuration><path>/</path></configuration></plugin></plugins></build><dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>${junit.version}</version><scope>test</scope></dependency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>${log4j.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-orm</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-core</artifactId><version>${spring.integration.version}</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-jdbc</artifactId><version>${spring.integration.version}</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-ftp</artifactId><version>${spring.integration.version}</version></dependency><dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-ip</artifactId><version>${spring.integration.version}</version></dependency><dependency><groupId>com.fasterxml.jackson.module</groupId><artifactId>jackson-module-jaxb-annotations</artifactId><version>${jackson.version}</version></dependency><dependency><groupId>org.codehaus.jackson</groupId><artifactId>jackson-mapper-asl</artifactId><version>${jackson.asl.version}</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.6.6</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>jcl-over-slf4j</artifactId><version>1.6.6</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>jul-to-slf4j</artifactId><version>1.6.6</version></dependency><dependency><groupId>org.lazyluke</groupId><artifactId>log4jdbc-remix</artifactId><version>0.2.7</version></dependency><dependency><groupId>com.jolbox</groupId><artifactId>bonecp</artifactId><version>0.8.0.RELEASE</version></dependency><dependency><groupId>com.oracle</groupId><artifactId>ojdbc14</artifactId><version>10.2.0.4.0</version></dependency><dependency><groupId>dom4j</groupId><artifactId>dom4j</artifactId><version>1.6.1</version></dependency><dependency><groupId>org.apache.ftpserver</groupId><artifactId>ftpserver-core</artifactId><version>1.0.6</version></dependency><dependency><groupId>javax.servlet</groupId><artifactId>servlet-api</artifactId><version>2.5</version><scope>provided</scope></dependency><dependency><groupId>javax.servlet.jsp</groupId><artifactId>jsp-api</artifactId><version>2.1</version><scope>provided</scope></dependency><dependency><groupId>javax.servlet</groupId><artifactId>jstl</artifactId><version>1.2</version></dependency></dependencies></project>

?

?保存pom.xml后，可以看到Maven已经为我们添加了所需的Jar包；

?

?

?

但是项目提示错误，

Description?Resource?Path?Location?Type
Project configuration is not up-to-date with pom.xml. Run Maven->Update Project or use Quick Fix.?siptest??line 1?Maven Configuration Problem
提示我们用Maven更新项目，照它说的做

?

?
?按图上选择，之后弹出下图：

?

?

按图勾选其中项目选择你所要更新的项目，OK后，项目错误消除

?

往/src/main/resources路径下添加如下目录结构

?同时添加两个文件，app.properties和log4j.xml

最后目录结构如下

?

其中，spring-integration-context.xml文件初始内容如下，随着项目的进行会逐步完善。

?

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    xmlns:context="http://www.springframework.org/schema/context"    xmlns:int="http://www.springframework.org/schema/integration"    xmlns:int-jdbc="http://www.springframework.org/schema/integration/jdbc"    xmlns:int-ftp="http://www.springframework.org/schema/integration/ftp"    xmlns:int-ip="http://www.springframework.org/schema/integration/ip"    xsi:schemaLocation="    http://www.springframework.org/schema/beans    http://www.springframework.org/schema/beans/spring-beans.xsd    http://www.springframework.org/schema/context                 http://www.springframework.org/schema/context/spring-context.xsd    http://www.springframework.org/schema/integration          http://www.springframework.org/schema/integration/spring-integration.xsd    http://www.springframework.org/schema/integration/jdbc     http://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc-3.0.xsd    http://www.springframework.org/schema/integration/ftp    http://www.springframework.org/schema/integration/ftp/spring-integration-ftp-3.0.xsd    http://www.springframework.org/schema/integration/ip     http://www.springframework.org/schema/integration/ip/spring-integration-ip-3.0.xsd">        <context:property-placeholder location="classpath:app.properties"/></beans>

spring-integration-context.xml文件要确保添加spring-integration、spring-integration-jdbc、spring-integration-ftp

和spring-integration-ip这几命名空间的配置，后面会用到。

?

app.properties是配置文件以后会添加配置内容如数据库连接和连接池配置参数等；

log4j.xml是日志的配置文件，根据你自己的情况自行配置即可；

到此，环境基本搭建完成。

至于Serv-U的配置，大家自己搜索教程操作，这里不再筹述。

?

数据库建表语句：

-- Create tablecreate table TBL_SYSCHN_DATA(  SYSCHN_DATA_ID  NUMBER(14) not null,  SYSCHN_TBL_ID   NUMBER(14) not null,  SYSCHN_TBL_NAME VARCHAR2(255) not null,  SYSCHN_FLAG     NUMBER(2) default 0 not null,  SYSCHN_DATE     DATE,  SYSCHN_OP       NUMBER(2) default 1 not null);-- Create/Recreate primary, unique and foreign key constraints alter table TBL_SYSCHN_DATA  add constraint PK_SYSCHN_DATA primary key (SYSCHN_DATA_ID);-- Create tablecreate table TBL_SYSCHN(  SYSCHN_ID NUMBER(14) not null,  COL_A     VARCHAR2(20) not null,  COL_B     VARCHAR2(20) not null,  COL_C     VARCHAR2(20));-- Create/Recreate primary, unique and foreign key constraints alter table TBL_SYSCHN  add constraint PK_SYSCHN_TBL primary key (SYSCHN_ID);-- Create sequence create sequence TBL_SYSCHN_DATA_SEQminvalue 1maxvalue 999999999999999999999999999start with 1increment by 1cache 20;-- Create sequence create sequence TBL_SYSCHN_SEQminvalue 1maxvalue 999999999999999999999999999start with 1increment by 1cache 20;

?以上开发环境基本搭建完成。

?

未完待续。。。。。。。。。。。。。。。。。

?