Spring Batch 批處理框架

第1篇入門(mén)篇 第1章  Spring Batch簡(jiǎn)介    2 1.1  什么是批處理        2 1.2  Spring Batch   3 1.2.1  典型場(chǎng)景    3 1.2.2  Spring Batch架構(gòu)        4 1.3  Spring Batch優(yōu)勢(shì)  4 1.3.1  豐富的開(kāi)箱即用組件         5 1.3.2  面向Chunk的處理     5 1.3.3  事務(wù)管理能力    5 1.3.4  元數(shù)據(jù)管理         5 1.3.5  易監(jiān)控的批處理應(yīng)用         5 1.3.6  豐富的流程定義         5 1.3.7  健壯的批處理應(yīng)用    6 1.3.8  易擴(kuò)展的批處理應(yīng)用         6 1.3.9  復(fù)用企業(yè)現(xiàn)有IT資產(chǎn)        6 1.4  Spring Batch 2.0新特性         6 1.4.1  支持Java 5 7 1.4.2  支持非順序的Step    7 1.4.3  面向Chunk處理         7 1.4.4  元數(shù)據(jù)訪問(wèn)         11 1.4.5  擴(kuò)展性         11 1.4.6  可配置性    12 1.5  Spring Batch 2.2新特性         13 1.5.1  Spring Data集成         13 1.5.2  支持Java配置   13 1.5.3  Spring Retry         14 1.5.4  Job Parameters   14 1.6  開(kāi)發(fā)環(huán)境搭建        15 第2章  Spring Batch之Hello World    16 2.1  場(chǎng)景說(shuō)明        16 2.2  項(xiàng)目準(zhǔn)備        16 2.2.1  項(xiàng)目結(jié)構(gòu)    16 2.2.2  準(zhǔn)備對(duì)賬單文件         17 2.2.3  定義領(lǐng)域?qū)ο?nbsp;   18 2.3  定義job基礎(chǔ)設(shè)施          18 2.4  定義對(duì)賬Job 19 2.4.1  配置ItemReader         19 2.4.2  配置ItemProcessor    21 2.4.3  配置ItemWriter 22 2.5  執(zhí)行Job 23 2.5.1  Java調(diào)用    23 2.5.2  JUnit單元測(cè)試   24 2.6  概念預(yù)覽        26 第2篇基本篇 第3章  Spring Batch基本概念    28 3.1  命名空間        29 3.2  Job  30 3.2.1  Job Instance         31 3.2.2  Job Parameters   33 3.2.3  Job Execution       34 3.3  Step         35 3.3.1  Step Execution     37 3.4  Execution Context  38 3.5  Job Repository        39 3.5.1  Job Repository Schema        39 3.5.2  配置Memory Job Repository     40 3.5.3  配置DB Job Repository      41 3.5.4  數(shù)據(jù)庫(kù)Schema   42 3.6  Job Launcher  48 3.7  ItemReader    49 3.8  ItemProcessor        50 3.9  ItemWriter     50 第4章配置作業(yè)Job       52 4.1  基本配置        52 4.1.1  重啟Job      54 4.1.2  Job攔截器  55 4.1.3  Job Parameters校驗(yàn)  58 4.1.4  Job抽象與繼承  59 4.2  高級(jí)特性        61 4.2.1  Step Scope   61 4.2.2  屬性Late Binding        62 4.3  運(yùn)行Job 63 4.3.1  調(diào)度作業(yè)    65 4.3.2  命令行執(zhí)行         68 4.3.3  與定時(shí)任務(wù)集成         71 4.3.4  與Web應(yīng)用集成        73 4.3.5  停止Job      77 第5章配置作業(yè)步Step          85 5.1  配置Step        86 5.1.1  Step抽象與繼承         87 5.1.2  Step執(zhí)行攔截器         89 5.2  配置Tasklet   92 5.2.1  重啟Step    93 5.2.2  事務(wù)    94 5.2.3  事務(wù)回滾    96 5.2.4  多線程Step         97 5.2.5  自定義Tasklet    97 5.3  配置Chunk     99 5.3.1  提交間隔    102 5.3.2  異常跳過(guò)    103 5.3.3  Step重試    105 5.3.4  Chunk完成策略 107 5.3.5  讀、處理事務(wù)    110 5.4  攔截器   112 5.4.1  ChunkListener     115 5.4.2  ItemReadListener        116 5.4.3  ItemProcessListener   116 5.4.4  ItemWriteListener       117 5.4.5  SkipListener          117 5.4.6  RetryListener       118 第6章讀數(shù)據(jù)ItemReader     120 6.1  ItemReader    120 6.1.1  ItemReader          120 6.1.2  ItemStream          121 6.1.3  系統(tǒng)讀組件         122 6.2  Flat格式文件         122 6.2.1  Flat文件格式      123 6.2.2  FlatFileItemReader      125 6.2.3  RecordSeparatorPolicy        129 6.2.4  LineMapper          130 6.2.5  DefaultLineMapper     131 6.2.6  LineCallbackHandler   138 6.2.7  讀分隔符文件    139 6.2.8  讀定長(zhǎng)文件         141 6.2.9  讀JSON文件       143 6.2.10  讀記錄跨多行文件  145 6.2.11  讀混合記錄文件       147 6.3  XML格式文件        150 6.3.1  XML解析    150 6.3.2  Spring OXM 151 6.3.3  StaxEventItemReader          153 6.4  讀多文件        156 6.5  讀數(shù)據(jù)庫(kù)        159 6.5.1  JdbcCursorItemReader       160 6.5.2  HibernateCursorItem Reader     167 6.5.3  StoredProcedureItem Reader     171 6.5.4  JdbcPagingItemReader       174 6.5.5  HibernatePagingItem Reader     179 6.5.6  JpaPagingItemReader         183 6.5.7  IbatisPagingItemReader     186 6.6  讀JMS隊(duì)列   190 6.6.1  JmsItemReader  190 6.7  服務(wù)復(fù)用        194 6.8  自定義ItemReader        197 6.8.1  不可重啟ItemReader         197 6.8.2  可重啟ItemReader    199 6.9  攔截器   202 6.9.1  攔截器接口         202 6.9.2  攔截器異常         203 6.9.3  執(zhí)行順序    204 6.9.4  Annotation  204 6.9.5  屬性Merge         205 第7章寫(xiě)數(shù)據(jù)ItemWriter      207 7.1  ItemWrite       207 7.1.1  ItemWriter  208 7.1.2  ItemStream          208 7.1.3  系統(tǒng)寫(xiě)組件         209 7.2  Flat格式文件         210 7.2.1  FlatFileItemWriter       210 7.2.2  LineAggregator   214 7.2.3  FieldExtractor      217 7.2.4  回調(diào)操作    219 7.3  XML格式文件        222 7.3.1  StaxEventItemWriter  222 7.3.2  回調(diào)操作    226 7.4  寫(xiě)多文件        230 7.4.1  MultiResourceItemWriter  230 7.4.2  擴(kuò)展MultiResourceItem Writer         233 7.5  寫(xiě)數(shù)據(jù)庫(kù)        234 7.5.1  JdbcBatchItemWriter 235 7.5.2  HibernateItemWriter 239 7.5.3  IbatisBatchItemWriter        242 7.5.4  JpaItemWriter     245 7.6  寫(xiě)JMS隊(duì)列   248 7.6.1  JmsItemWriter    248 7.7  組合寫(xiě)   252 7.8  Item路由Writer   254 7.9  發(fā)送郵件        258 7.9.1  SimpleMailMessageItem Writer         258 7.10  服務(wù)復(fù)用      262 7.10.1  ItemWriterAdapter   262 7.10.2  PropertyExtracting DelegatingItemWriter       264 7.11  自定義ItemWrite        267 7.11.1  不可重啟ItemWriter        267 7.11.2  可重啟ItemWriter   268 7.12  攔截器 271 7.12.1  攔截器接口       271 7.12.2  攔截器異常       273 7.12.3  執(zhí)行順序  274 7.12.4  Annotation         274 7.12.5  屬性Merge       275 第8章處理數(shù)據(jù)ItemProcessor    277 8.1  ItemProcessor        277 8.1.1  ItemProcessor     277 8.1.2  系統(tǒng)處理組件    278 8.2  數(shù)據(jù)轉(zhuǎn)換        279 8.2.1  部分?jǐn)?shù)據(jù)轉(zhuǎn)換    279 8.2.2  數(shù)據(jù)類型轉(zhuǎn)換    281 8.3  數(shù)據(jù)過(guò)濾        282 8.3.1  數(shù)據(jù)Filter   282 8.3.2  數(shù)據(jù)過(guò)濾統(tǒng)計(jì)    283 8.4  數(shù)據(jù)校驗(yàn)        285 8.4.1  Validator      285 8.4.2  ValidatingItemProcessor     286 8.5  組合處理器   288 8.6  服務(wù)復(fù)用        291 8.6.1  ItemProcessorAdapter        291 8.7  攔截器   293 8.7.1  攔截器接口         293 8.7.2  攔截器異常         295 8.7.3  執(zhí)行順序    295 8.7.4  Annotation  296 8.7.5  屬性Merge         297 第3篇高級(jí)篇 第9章作業(yè)流Step Flow         300 9.1  順序Flow        300 9.2  條件Flow        302 9.2.1  next     303 9.2.2  ExitStatus VS BatchStatus  306 9.2.3  decision條件       308 9.3  并行Flow        311 9.4  外部Flow定義       314 9.4.1  Flow     314 9.4.2  FlowStep      317 9.4.3  JobStep        319 9.5  Step數(shù)據(jù)共享        321 9.6  終止Job 323 9.6.1  end       324 9.6.2  stop     326 9.6.3  fail        327 第10章健壯Job     330 10.1  跳過(guò)Skip       331 10.1.1  配置Skip   331 10.1.2  跳過(guò)策略SkipPolicy  333 10.1.3  跳過(guò)攔截器       335 10.2  重試Retry    338 10.2.1  配置Retry         339 10.2.2  重試策略RetryPolicy        341 10.2.3  重試攔截器       343 10.2.4  重試模板  345 10.3  重啟Restart         353 10.3.1  重啟Job    353 10.3.2  啟動(dòng)次數(shù)限制  355 10.3.3  重啟已完成的任務(wù)  355 第11章擴(kuò)展Job、并行處理         357 11.1  可擴(kuò)展性      357 11.2  多線程Step 358 11.2.1  配置多線程Step       359 11.2.2  線程安全性       360 11.2.3  線程安全Step  361 11.2.4  可重啟的線程安全Step  363 11.3  并行Step      365 11.4  遠(yuǎn)程Step      366 11.4.1  遠(yuǎn)程Step框架 366 11.4.2  基于SI實(shí)現(xiàn)遠(yuǎn)程Step      368 11.5  分區(qū)Step      373 11.5.1  關(guān)鍵接口  374 11.5.2  基本配置  376 11.5.3  文件分區(qū)  378 11.5.4  數(shù)據(jù)庫(kù)分區(qū)       382 11.5.5  遠(yuǎn)程分區(qū)Step  387 后記         392