鍦?IBM Bluemix 浜戝钩鍙颁笂寮€鍙戝苟閮ㄧ讲鎮ㄧ殑涓嬩竴涓簲鐢ㄣ€?/p>

鐜板湪灏卞紑濮嬪厤璐硅瘯鐢?/a>

鍓嶈█

鍦ㄦ湰绯诲垪鏂囩珷鐨勭 1 閮ㄥ垎锛屾垜浠惌寤轰簡涓€涓敤鎴风即璐归€氱煡鐨勬壒澶勭悊浠诲姟銆傚敖绠¤繖涓畝鍗曠殑搴旂敤灞曠幇浜?Spring Batch 鐨勫熀鏈姛鑳斤紝浣嗘槸瀹冧笌鐪熷疄鐨勫簲鐢ㄧ浉鍘荤敋杩溿€傚湪瀹為檯搴旂敤涓紝鎴戜滑鐨?Job 鍙兘蹇呴』瑕佸寘鍚涓?Step锛屼负浜嗘彁楂樻€ц兘锛屾垜浠彲鑳介渶瑕佽€冭檻 Job 鐨勫苟鍙戦棶棰樸€係pring Batch 鍦ㄨ繖浜涙柟闈㈠張鎻愪緵浜嗗摢浜涘ソ鐨勭壒鎬у憿锛熻鎴戜滑缁х画銆?/p>

鍥為〉棣?/a>

Step Flow

閫氳繃鍓嶆枃鎴戜滑宸茬粡鐭ラ亾锛孲tep 鏄竴涓嫭绔嬬殑銆侀『搴忕殑澶勭悊姝ラ锛屽寘鍚畬鏁寸殑杈撳叆銆佸鐞嗕互鍙婅緭鍑恒€備絾鏄湪浼佷笟搴旂敤涓紝鎴戜滑闈㈠鐨勬洿澶氭儏鍐垫槸澶氫釜姝ラ鎸夌収涓€瀹氱殑椤哄簭杩涜澶勭悊銆傚洜姝ゅ浣曠淮鎶ゆ楠や箣闂寸殑鎵ц椤哄簭鏄垜浠渶瑕佽€冭檻鐨勩€係pring Batch 鎻愪緵浜?Step Flow 鏉ヨВ鍐宠繖涓棶棰樸€?/p>

绀轰緥鏀硅繘

璁╂垜浠洖鍒扮敤鎴风即璐归€氱煡鐨?Job銆傚鎴锋彁鍑轰簡杩涗竴姝ョ殑闇€姹傦細璁¤垂銆佹墸璐广€佺即璐归€氱煡瑕佺‘淇濋『搴忔墽琛屻€傞鍏堬紝涓烘瘡涓敤鎴风敓鎴愯处鍗曪紝鐒跺悗浠庣敤鎴蜂綑棰濅笂杩涜鎵ｉ櫎锛屽浜庝綑棰濅笉瓒崇殑鐢ㄦ埛锛屽彂閫佺即璐归€氱煡銆備笅闈㈢湅涓€涓嬪浣曚娇鐢?Step Flow 瀹炵幇璇ラ渶姹傘€?/p>

鍦ㄨ瑙?Step Flow 涔嬪墠锛屾垜浠厛瀵圭 1 閮ㄥ垎鐨勭ず渚嬭繘琛屾敼杩涳紝灏嗗叾鐢辨枃浠舵搷浣滆縼绉诲埌鏁版嵁搴撲笂锛岃繖鏍蜂究浜庢垜浠悗缁殑璁茶В銆傛暟鎹簱鍒濆鍖栬剼鏈 init_db_mysql.sql锛堜綅浜庣ず渚嬩唬鐮佸寘 batch_sample 鏍圭洰褰曚笅锛夛紝鍏蜂綋閰嶇疆濡傛竻鍗?1 鎵€绀猴細

娓呭崟 1. billing_job.xml

<beans:bean id="jobRepository"
   class="org.springframework.batch.core.repository.support.JobRepositoryFactoryBean">
   <beans:property name="dataSource" ref="dataSource" />
   <beans:property name="transactionManager" ref="transactionManager" />
</beans:bean>
<beans:bean id="userDbReader"
	class="org.springframework.batch.item.database.JdbcPagingItemReader">
	<beans:property name="dataSource" ref="dataSource" />
	<beans:property name="rowMapper" ref="userDbMapper" />
	<beans:property name="queryProvider" ref="userQueryProvider" />
</beans:bean>
<beans:bean id="userDbMapper"
	class="org.springframework.batch.sample.UserDbMapper" />
<beans:bean id="userQueryProvider"
	class="org.springframework.batch.item.database.support.MySqlPagingQueryProvider">
	<beans:property name="selectClause" value="u.id,u.name,u.age,u.balance" />
	<beans:property name="fromClause" value="users u" />
	<beans:property name="sortKey" value="u.id" />
</beans:bean>
<beans:bean id="messageDbWriter"
	class="org.springframework.batch.item.database.JdbcBatchItemWriter">
	<beans:property name="dataSource" ref="dataSource" />
	<beans:property name="sql"
    value="insert into messages(id,user_id,content) values(:id,:user.id,:content)" />
	<beans:property name="itemSqlParameterSourceProvider"
		ref="itemSqlParameterSourceProvider" />
</beans:bean>
<beans:bean id="itemSqlParameterSourceProvider"
class="org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider"
 />

鎴戜滑鍒嗗埆浣跨敤 Spring Batch 鎻愪緵鐨?JdbcPagingItemReader 鍜?JdbcBatchItemWriter 杩涜璇诲啓銆傚悓鏃讹紝鎴戝皢 jobRepository 淇敼涓?JobRepositoryFactoryBean锛屽洜姝わ紝杩愯绀轰緥鍓嶏紝鎮ㄨ繕闇€瑕佹墽琛?Spring Batch 鎻愪緵鐨?schema-mysql.sql锛堜綅浜?core 鍖?org\springframework\batch\core 鐩綍涓嬶級銆傜浉鍏冲唴瀹瑰皢鍦ㄧ 3 閮ㄥ垎璇︾粏璁茶В锛屾澶勪笉鍐嶈禈杩般€?/p>

绗竴涓祦绋?/h3>

鍦ㄩ厤缃?Step 鏃讹紝鎴戜滑鍙互鎸囧畾鍏?next 灞炴€э紝璇ュ睘鎬ф寚鍚戝彟涓€涓?Step銆傞€氳繃閰嶇疆 Step 鐨?next 灞炴€э紝鎴戜滑渚垮彲浠ヨ交鏄撳疄鐜颁笂杩版祦绋嬨€傚叿浣撳娓呭崟 2 鎵€绀?/p>

娓呭崟 2. billing_job.xml

<job id="billingJob" restartable="true">
	<step id="billingStep" next="payStep">
		<tasklet>
			<chunk reader="userDbReader" processor="billingProcessor"
             writer="billDbWriter" commit-interval="5" chunk-completion-policy="">
			</chunk>
		</tasklet>
	</step>
	<step id="payStep" next="messageStep">
		<tasklet>
          <chunk reader="billDbReader" processor="payProcessor" writer="payDbWriter" 
			commit-interval="5" chunk-completion-policy=""  skip-limit="100" >
<skippable-exception-classes>
      <include class="org.springframework.batch.sample.MoneyNotEnoughException" />
				</skippable-exception-classes>
			</chunk>
		</tasklet>
	</step>
	<step id="messageStep">
		<tasklet>
			<chunk reader="billArrearsDbReader" processor="messageProcessor"
					writer="messageDbWriter" commit-interval="5"
					chunk-completion-policy="">
			</chunk>
		</tasklet>
	</step>
</job>

鎴戜滑灏?billStep 鐨?next 璁剧疆涓?payStep锛屽皢 payStep 鐨?next 璁剧疆涓?messageStep锛屽悓鏃跺垎鍒寚瀹氫簡璇汇€佸鐞嗐€佸啓鎺ュ彛銆係pring Batch 鍦ㄨ繍琛?billingJob 鏃讹紝棣栧厛鎵ц billingStep锛屾煡鎵剧敤鎴蜂俊鎭敓鎴愯处鍗曡垂鐢紝鐒跺悗鎵ц payStep锛屾煡鎵捐处鍗曚俊鎭敓鎴愭墸璐硅褰曪紝濡傛灉鐢ㄦ埛浣欓涓嶈冻鍒欒烦杩囥€傛渶鍚庯紝鏌ユ壘娆犺垂璐﹀崟锛岀敓鎴愮即璐归€氱煡銆傚彧鏈夊綋涓婁竴姝ユ墽琛屾垚鍔熷悗锛屾墠浼氭墽琛屼笅涓€姝ャ€?/p>

billStep 鍜?payStep 鐨?ItemProcessor 瀹炵幇鍒嗗埆濡傛竻鍗?3 鍜屾竻鍗?4 鎵€绀猴細

娓呭崟 3.BillingItemProcessor 绫?/h5>

public class BillingItemProcessor implements ItemProcessor#<User, Bill> {

	public Bill process(User item) throws Exception {
		Bill b = new Bill();
		b.setUser(item);
		b.setFees(70.00);
		b.setPaidFees(0.0);
		b.setUnpaidFees(70.00);
		b.setPayStatus(0);/*unpaid*/
		return b;
	}

}

娓呭崟 4.PaymentItemProcessor 绫?/h5>

 public class PaymentItemProcessor implements ItemProcessor<Bill, PayRecord> { 
 public PayRecord process(Bill item) throws Exception {
		if (item.getUser().getBalance() <= 0) {
			return null;
		}
		if (item.getUser().getBalance() >= item.getUnpaidFees()) {
			// create payrecord
			PayRecord pr = new PayRecord();
			pr.setBill(item);
			pr.setPaidFees(item.getUnpaidFees());
			// update balance
			item.getUser().setBalance(item.getUser().getBalance() - 
			     item.getUnpaidFees());
			// update bill
			item.setPaidFees(item.getUnpaidFees());
			item.setUnpaidFees(0.0);
			item.setPayStatus(1);/* paid */
			return pr;
		} else {
			throw new MoneyNotEnoughException();
		}
	}
}

鍦ㄦ竻鍗?3 涓紝鎴戜滑涓烘瘡涓敤鎴风敓鎴愪竴鏉?70 鍏冪殑璐﹀崟锛屽凡缂磋垂鐢ㄤ负 0锛屾湭缂磋垂鐢ㄤ负 70銆傚湪娓呭崟 4 涓紝灏嗚处鍗曢噾棰濅粠鐢ㄦ埛浣欓涓墸闄わ紝骞舵洿鏂拌处鍗曞凡缂村拰鏈即璐圭敤锛屽鏋滀綑棰濅笉瓒筹紝鎻愮ず寮傚父锛堥€氳繃娓呭崟 2 鍙煡锛屾垜浠浜庢绫诲紓甯歌繘琛屼簡璺宠繃澶勭悊锛夈€?/p>

姝ゅ锛屾垜浠幇鍦ㄧ殑缂磋垂閫氱煡闇€瑕佸熀浜庢瑺璐硅处鍗曠敓鎴愶紝鍥犳锛屾垜浠渶瑕佹柊鎻愪緵涓€涓即璐归€氱煡鐨?ItemProcessor锛屽叿浣撳娓呭崟 5 鎵€绀猴細

娓呭崟 5.ArrearsMessagesItemProcessor 绫?/h5>

public class ArrearsMessagesItemProcessor implements
		ItemProcessor<Bill, Message> {

	public Message process(Bill item) throws Exception {
		if (item.getPayStatus() == 0) {/*unpaid*/
			Message m = new Message();
			m.setUser(item.getUser());
			m.setContent("Hello " + item.getUser().getName()
					+ ",please pay promptly at end of this month.");
			return m;
		}
		return null;
	}

}

姣忎釜 Step 鐨勮鍐欐帴鍙ｅ彲鍙傜収 billing_job.xml锛屽潎浣跨敤 Spring Batch 鎻愪緵鐨勫疄鐜扮被锛屾澶勪笉鍐嶈禈杩帮紙姝ゅ闇€瑕佺壒鍒敞鎰?payDbWriter锛岀敱浜庢墸璐规椂锛屾垜浠渶瑕佸悓鏃剁敓鎴愭墸璐硅褰曪紝骞舵洿鏂扮敤鎴峰拰璐﹀崟锛屽洜姝ゆ垜浠娇鐢ㄤ簡 CompositeItemWriter锛夈€傝嚦姝わ紝鎴戜滑宸茬粡瀹屾垚浜嗙涓€姝ワ紝瀹炵幇浜嗗熀鏈殑澶氭楠ら『搴忓鐞嗭紝鎮ㄥ彲浠ヨ繍琛?Main2锛屽苟閫氳繃鏁版嵁搴撴煡鐪嬭繍琛岀粨鏋滐紙bills銆乸ayrecords銆乵essages锛夈€?/p>

鏉′欢娴佺▼鍜屾祦绋嬪喅绛?/h3>

閫氳繃涓婇潰鐨?Step Flow锛屾垜浠凡缁忔弧瓒充簡瀹㈡埛鐨勫垵姝ラ渶姹傦紝浣嗘槸瀹㈡埛鍙堟彁鍑鸿繘涓€姝ヨ姹傦細鑳藉惁褰撴墍鏈夌敤鎴疯垂鐢ㄥ潎瓒冲鐨勬儏鍐典笅锛屼笉鍐嶆墽琛岀即璐归€氱煡澶勭悊銆傚洜涓烘煡璇竴閬嶆瑺璐硅处鍗曞湪涓€瀹氱▼搴︿笂杩樻槸闄嶄綆浜嗗鐞嗘€ц兘銆係pring Batch 鎻愪緵浜嗘潯浠舵祦绋嬪拰娴佺▼鍐崇瓥鏉ユ敮鎸佺被浼煎簲鐢ㄥ満鏅€?/p>

棣栧厛锛岃鎴戜滑鐪嬩竴涓嬪浣曚娇鐢ㄦ潯浠舵祦绋嬫潵瀹炵幇璇ラ渶姹傘€係tep 閫氳繃鍦?next 鍏冪礌涓婅缃?on 灞炴€ф潵鏀寔鏉′欢娴佺▼锛宱n 灞炴€у彇鍊间负 Step 鐨勭粨鏉熺姸鎬侊紝濡?COMPLETED銆丗AILED 绛夛紝鍚屾椂杩樻敮鎸?* 浠ュ強 ? 閫氶厤绗︼紝鍏蜂綋鍙槄璇宦?a style="margin: 0px; padding: 0px; border: 0px; font-size: inherit; vertical-align: baseline; color: #745285;" href="http://www.ibm.com/developerworks/cn/java/j-lo-springbatch2/#resources">鍙傝€冩墜鍐?/a>銆?/p>

鐢变簬鎴戜滑甯屾湜褰撳瓨鍦ㄤ綑棰濅笉瓒崇殑鎯呭喌鏃讹紝涔熷氨鏄?payStep 鐨勮烦杩囨潯鏁板ぇ浜?0 鏃讹紝鍐嶆墽琛岀即璐归€氱煡 Step锛屽洜姝わ紝鎴戜滑闇€瑕佺壒娈婃寚瀹氫竴绉嶇粨鏉熺姸鎬併€傛澶勶紝鎴戜滑鍙互涓?Step 娣诲姞涓€涓洃鍚櫒锛屼互杩斿洖鎸囧畾鐨勭粨鏉熺姸鎬併€?/p>

淇敼鍚庣殑 payStep 濡傛竻鍗?6 鎵€绀猴紝鐩戝惉鍣ㄥ疄鐜板娓呭崟 7 鎵€绀猴細

娓呭崟 6. billing_job.xml

<step id="payStep">
	<tasklet>
		<chunk reader="billDbReader" processor="payProcessor" writer="payDbWriter"
			commit-interval="5" chunk-completion-policy="" skip-limit="100">
			<skippable-exception-classes>
				<include
        class="org.springframework.batch.sample.MoneyNotEnoughException" />
			</skippable-exception-classes>
		</chunk>
	</tasklet>
<next on="COMPLETED WITH SKIPS" to="messageStep"/>
	<listeners>
		<listener ref="payStepCheckingListener"></listener>
	</listeners>
</step>

娓呭崟 7. PayStepCheckingListener 绫?/h5>

public class PayStepCheckingListener extends StepExecutionListenerSupport {

	@Override
	public ExitStatus afterStep(StepExecution stepExecution) {
		String exitCode = stepExecution.getExitStatus().getExitCode();
		if (!exitCode.equals(ExitStatus.FAILED.getExitCode())
				&& stepExecution.getSkipCount() > 0) {
			return new ExitStatus("COMPLETED WITH SKIPS");
		} else {
			return null;
		}
	}

}

鎺ヤ笅鏉ワ紝鍐嶈鎴戜滑鐪嬩竴涓嬪浣曚娇鐢ㄦ祦绋嬪喅绛栨潵瀹炵幇璇ュ姛鑳姐€傚鏁版儏鍐典笅锛孲tep 鐨勭粨鏉熺姸鎬佸苟涓嶈兘澶熸弧瓒宠緝涓哄鏉傜殑鏉′欢娴佺▼锛屾鏃朵究鐢ㄥ埌浜嗘祦绋嬪喅绛栧櫒銆傞€氳繃瀹冿紝鎴戜滑鍙互鏍规嵁 Job 鍜?Step 鐨勫悇绉嶆墽琛屾儏鍐佃繑鍥炵浉搴旂殑鎵ц鐘舵€佹潵鎺у埗娴佺▼銆?/p>

棣栧厛锛屾垜浠渶瑕佸畾涔変竴涓祦绋嬪喅绛栧櫒锛屼唬鐮佸娓呭崟 8 鎵€绀猴細

娓呭崟 8. MessagesDecider 绫?/h5>

public class MessagesDecider implements JobExecutionDecider {

	public FlowExecutionStatus decide(JobExecution jobExecution,
			StepExecution stepExecution) {
		String exitCode = stepExecution.getExitStatus().getExitCode();
		if (!exitCode.equals(ExitStatus.FAILED.getExitCode())
				&& stepExecution.getSkipCount() > 0) {
			return new FlowExecutionStatus("COMPLETED WITH SKIPS");
		} else {
			return FlowExecutionStatus.COMPLETED;
		}
	}

}

涓?StepExecutionListener 涓嶅悓锛岃绫荤殑 decide 鏂规硶杩斿洖涓€涓?FlowExecutionStatus 瀵硅薄銆備笌涔嬪搴旓紝Job 閰嶇疆淇敼涓哄娓呭崟 9 鎵€绀猴細

娓呭崟 9. billing_job2.xml

<job id="billingJob" restartable="true">
	<step id="billingStep" next="payStep">
	</step>
	<step id="payStep" next="decider">
	</step>
	<decision id="decider" decider="messagesDecider">
		<next on="COMPLETED WITH SKIPS" to="messageStep" />
		<end on="COMPLETED" />
	</decision>
	<step id="messageStep">
	</step>
</job>

鍙互鐪嬪埌 payStep 鐨?next 鍙樻垚浜?decider锛屽湪 decider 涓牴鎹繑鍥炵粨鏋滅‘瀹氭墽琛岃矾寰勶細濡傛灉瀛樺湪璺宠繃鐨勬儏鍐碉紝鎵ц messageStep锛屽惁鍒欑洿鎺ョ粨鏉?Job锛堟敞鎰忥細姝ゅ鎴戜滑鐢ㄥ埌浜?end 鍏冪礌锛夈€?/p>

閫氳繃涓婇潰鐨勮杩帮紝鎴戜滑澶т綋浜嗚В浜?Spring Batch 瀵逛簬鏉′欢娴佺▼鐨勬敮鎸侊紙姝ゅ锛屾垜浠彲浠ラ€氳繃璁剧疆 Step 鐨?next 灞炴€т负鍏堝墠鎵ц鐨?Step锛屼粠鑰屽疄鐜版敮鎸佸惊鐜殑 Job锛屼絾鏄瑪鑰呭苟涓嶈涓鸿繖鏄疄鐜板惊鐜换鍔＄殑涓€涓ソ鏂规锛屾晠鍦ㄦ澶勪笉鍋氳缁嗚瑙ｏ級锛屾帴涓嬫潵鍐嶈鎴戜滑鐪嬩竴涓嬫壒澶勭悊涓彟涓€椤归噸瑕佺壒寰佲€斺€斿苟鍙戙€?/p>

鍥為〉棣?/a>

骞跺彂澶勭悊

濡傛灉鎴戜滑鐨勬壒澶勭悊浠诲姟瓒冲绠€鍗曪紝纭欢閰嶇疆鍙婄綉缁滅幆澧冧篃瓒冲濂斤紝閭ｄ箞鎴戜滑瀹屽叏鍙互灏嗘壒澶勭悊浠诲姟璁捐涓哄崟绾跨▼锛屼絾鐜板疄鏄紒涓氬簲鐢ㄥ浜庣‖浠剁殑瑕佹眰瑕佹瘮纭欢鑷韩鍙戝睍蹇殑澶氾紝鏇翠綍鍐佃繕鏈夐偅涔堝鐨勪紒涓氳鍦ㄨ緝宸殑纭欢鐜涓繍琛岃嚜宸辩殑浼佷笟搴旂敤骞跺笇鏈涙嫢鏈変竴涓彲浠ユ帴鍙楃殑鎬ц兘銆傚洜姝ゅ湪浼佷笟搴旂敤涓紝灏ゅ叾鏄秹鍙婂埌澶ф壒閲忔暟鎹鐞嗭紝骞跺彂鏄笉鍙伩鍏嶇殑銆傞偅涔堬紝Spring Batch 鍦ㄥ苟鍙戞柟闈㈠張鎻愪緵浜嗗摢浜涘姛鑳芥敮鎸佸憿锛?/p>

棣栧厛锛孲pring Batch 鎻愪緵浜?Step 鍐呯殑骞跺彂锛岃繖涔熸槸鏈€绠€鍗曠殑涓€绉嶅苟鍙戝鐞嗘敮鎸併€傞€氳繃涓?Step 璁剧疆 task-executor 灞炴€э紝鎴戜滑渚垮彲浠ヤ娇褰撳墠 Step 浠ュ苟鍙戞柟寮忔墽琛屻€傚悓鏃讹紝杩樺彲浠ラ€氳繃 throttle-limit 璁剧疆骞跺彂绾跨▼鏁帮紙榛樿涓?4锛夈€備篃灏辨槸璇存偍涓嶅繀淇敼浠讳綍涓氬姟澶勭悊閫昏緫锛屼粎浠呴€氳繃淇敼閰嶇疆鍗冲彲浠ュ疄鐜板悓姝ュ埌寮傛鐨勫垏鎹€?/p>

濡傛灉鎴戜滑甯屾湜绀轰緥涓殑 billingStep 浠ュ苟鍙戞柟寮忔墽琛岋紝涓斿苟鍙戜换鍔℃暟涓?5锛岄偅涔堝彧闇€瑕佸仛濡備笅閰嶇疆鍗冲彲锛岃娓呭崟 10锛?/p>

娓呭崟 10. billing_job3.xml

<step id="billingStep" next="payStep">
	<tasklet task-executor="taskExecutor" throttle-limit="5">
		<chunk reader="userDbReader" processor="billingProcessor"
		writer="billDbWriter" commit-interval="5" chunk-completion-policy="">
		</chunk>
	</tasklet>
</step>
<beans:bean id="taskExecutor"
	class="org.springframework.core.task.SimpleAsyncTaskExecutor">
</beans:bean>

浠庢竻鍗曞彲浠ョ湅鍑猴紝鎴戜滑涓?billingStep 鎸囧畾浜嗕竴涓紓姝ヤ换鍔℃墽琛屽櫒 SimpleAsyncTaskExecutor锛岃鎵ц鍣ㄥ皢浼氭寜鐓ч厤缃垱寤烘寚瀹氭暟鐩殑绾跨▼鏉ヨ繘琛屾暟鎹鐞嗐€傞€氳繃杩欑鏂瑰紡锛岄伩鍏嶄簡鎴戜滑鎵嬪姩鍒涘缓骞剁鐞嗙嚎绋嬬殑宸ヤ綔锛屼娇鎴戜滑鍙渶瑕佸叧娉ㄤ笟鍔″鐞嗘湰韬€?/p>

闇€瑕佽ˉ鍏呰鏄庣殑鏄紝Spring Core 涓烘垜浠彁渚涗簡澶氱鎵ц鍣ㄥ疄鐜帮紙鍖呮嫭澶氱寮傛鎵ц鍣級锛屾垜浠彲浠ユ牴鎹疄闄呮儏鍐电伒娲婚€夋嫨浣跨敤銆傚綋鐒讹紝鍍忔垜浠澶勯渶瑕佸苟鍙戝鐞嗘椂锛屽繀椤讳娇鐢ㄥ紓姝ユ墽琛屽櫒銆傚嚑绉嶄富瑕佸疄鐜板琛?1 鎵€绀猴細

琛?1. 浠诲姟鎵ц鍣ㄥ垪琛?/h5>

鍏舵锛孲pring Batch 杩樻敮鎸?Step 闂寸殑骞跺彂锛岃繖鏄€氳繃 Split Flow 瀹炵幇鐨勩€傝鎴戜滑鐪嬬湅 Split Flow 鏄浣曚娇鐢ㄧ殑銆傚湪姝や箣鍓嶏紝璁╂垜浠鎯充竴涓嬶紝鍋囧瀹㈡埛鍩轰簬涓婇潰鐨勭ず渚嬫彁鍑鸿繘涓€姝ラ渶姹傦細姣忔湀涓虹敤鎴风敓鎴愭墸璐归€氱煡锛屽苟鐢熸垚璐﹀崟銆佹墸璐广€佺即璐归€氱煡锛堝浜庤垂鐢ㄤ笉瓒崇殑鎯呭喌锛夈€?/p>

褰撶劧锛岃瀹炵幇涓婅堪闇€姹傛湁寰堝绉嶆柟寮忥紝姣斿锛屾寜鐓х敓鎴愯处鍗曘€佹墸璐归€氱煡銆佹墸璐广€佺即璐归€氱煡鐨勯『搴忎覆琛屾墽琛岋紝鐒惰€岋紝姝ょ澶勭悊鏂瑰紡鍔垮繀浼氶檷浣庢€ц兘锛屽嵆浣挎垜浠彲浠ヤ娇鐢?Step 澶氱嚎绋嬪鐞嗘潵鎻愰珮鎬ц兘锛屽彲浠嶄笉鏄渶浼樻柟寮忋€傞偅涔堟垜浠濡備綍鏀硅繘鍛紵鏄剧劧锛屾垜浠彲浠ュ皢鐢熸垚鎵ｈ垂閫氱煡鍜屾墸璐瑰苟琛屾墽琛岋紝鍥犱负杩欎袱姝ユ槸瀹屽叏鐙珛鐨勩€備慨鏀瑰悗鐨?billing_job 濡傛竻鍗?11 鎵€绀猴細

娓呭崟 11. billing_job3.xml

 <job id="billingJob" restartable="true">
	<step id="billingStep" next="splitStep">
		<tasklet task-executor="taskExecutor" throttle-limit="5">
			<chunk reader="userDbReader" processor="billingProcessor"
        writer="billDbWriter" commit-interval="5" chunk-completion-policy="">
			</chunk>
		</tasklet>
	</step>
	<split id="splitStep" task-executor="taskExecutor"  next="decider">
		<flow>
			<step id="billingMessageStep">
				<tasklet>
                  <chunk reader="billDbReader" processor="billMessageItemProcessor"
					writer="messageDbWriter" commit-interval="5"
							chunk-completion-policy="">
					</chunk>
				</tasklet>
			</step>
		</flow>
		<flow>
			<step id="payStep">
				<tasklet>
                   <chunk reader="billDbReader" processor="payProcessor"
                   writer="payDbWriter" commit-interval="5" chunk-completion-policy=""
                   skip-limit="100">
                    <skippable-exception-classes>
                      <include 
                  class="org.springframework.batch.sample.MoneyNotEnoughException" />
                      </skippable-exception-classes>
					</chunk>
				</tasklet>
			</step>
		</flow>
	</split>
	<decision id="decider" decider="messagesDecider">
		<next on="COMPLETED WITH SKIPS" to="paymentMessageStep" />
		<end on="COMPLETED" />
	</decision>
	<step id="paymentMessageStep">
		<tasklet>
			<chunk reader="billArrearsDbReader" processor="messageProcessor"
					writer="messageDbWriter" commit-interval="5"
					chunk-completion-policy="">
			</chunk>
		</tasklet>
	</step>
</job>

浠庢竻鍗?10 鍙互鐪嬪嚭锛宐illingStep 鐨勪笅涓€姝ュ彉鎴愪簡涓€涓?split 鍏冪礌锛岃鍏冪礌涓嬪寘鍚袱涓?flow銆傗€渇low鈥濋【鍚嶆€濅箟鍖呭惈涓€绯诲垪鍙墽琛岀殑 step锛岀ず渚嬩腑涓や釜 flow 鍒嗗埆鍖呭惈 billingMessageStep锛堢敓鎴愭墸璐归€氱煡锛夊拰 payStep 涓や釜 step銆係pring Batch 鎵ц split 鏃讹紝灏嗕細骞惰鎵ц鍏朵笅鎵€鏈?flow锛岃€屼笖鍙湁褰撴墍鏈?step 鍧囨墽琛屽畬姣曚箣鍚庯紝鎵嶄細鎵ц split 鍏冪礌鐨勪笅涓€姝ワ紝褰撶劧锛屽墠鎻愭槸鎮ㄤ负 split 鍏冪礌鎸囧畾鐨?task-executor"涓?SimpleAsyncTaskExecutor锛岃灞炴€ч粯璁や负 SyncTaskExecutor锛屽嵆涓茶鎵ц銆?/p>

閫氳繃涓婅堪涓ょ鏂瑰紡锛屾垜浠彲浠ュ疄鐜?Job 鐨勫苟鍙戝鐞嗭紝浣嗘樉鐒惰鏂瑰紡鏈夊叾灞€闄愭€э紝鍗充粎闄愪簬鍗曟満銆?/p>

璁╂垜浠鎯充竴涓嬪涓嬪満鏅細鍦ㄤ笂杩扮即璐逛换鍔′腑锛岀敤鎴风敓鎴愯处鍗曢潪甯告參锛堜篃璁告槸鍥犱负涓氬姟澶勭悊杩囦簬澶嶆潅锛屼篃璁稿洜涓虹敓鎴愯处鍗曠殑杩囩▼涓悓鏃跺鐞嗕簡濂藉鍏宠仈淇℃伅锛夈€傝繖绉嶅満鏅垜浠鎬庝箞浼樺寲鍛紵鏄剧劧锛屽嵆渚挎垜浠皢璇ユ楠ら厤缃负骞惰锛岄偅涔堝畠鐨勪紭鍖栫┖闂翠篃鏄湁闄愮殑锛屽洜涓虹嚎绋嬪苟鍙戝埌涓€瀹氭暟閲忎箣鍚庡繀瀹氬彈闄愪簬绯荤粺纭欢閰嶇疆銆傝繖涓椂鍊欙紝鎴戜滑鑷劧浼氭兂鍒颁慨鏀归儴缃叉柟寮忥紝灏嗚€楁椂鎿嶄綔鍒嗛厤鍒板涓満鍣ㄤ笂骞惰鎵ц銆傞偅涔堝熀浜?Spring Batch 鎴戜滑璇ュ浣曞疄鐜板憿锛熸澶勪究鐢ㄥ埌浜?PartitionStep銆傝鎴戜滑鐪嬩竴涓嬪畠鏄浣曟墽琛岀殑锛屽叾鏃跺簭鍥惧鍥?1 鎵€绀猴細

鍥?1. PartitionStep 搴忓垪鍥?/h5>

浠庡浘涓垜浠彲浠ョ湅鍒帮紝PartitionStep 骞朵笉璐熻矗璇汇€佸啓鏁版嵁锛屽畠鍙槸鏍规嵁閰嶇疆鐨勭瓥鐣ワ紙PartitionHandler锛夊皢 StepExecution 杩涜鍒嗚В锛屽苟濮旀淳鍒版寚瀹氱殑 Step 涓婂苟琛屾墽琛岋紙璇?Step 鍙兘鏄湰鍦帮紝涔熷彲鑳芥槸杩滅▼锛夛紝鎵ц瀹屾瘯鍚庯紝灏嗘墍鏈夋墽琛岀粨鏋滆繘琛屽悎骞讹紙鐢?StepExecutionAggregator 瀹屾垚锛変綔涓鸿嚜韬殑鎵ц缁撴灉銆傚埄鐢?PartitionStep锛屽湪濮旀淳 Step 涓鸿繙绋嬭皟鐢ㄧ殑鎯呭喌涓嬶紝鎴戜滑鍙互寰堝鏄撻€氳繃澧炲姞浠庢満鏁扮洰鐨勬柟寮忔潵鎻愰珮浠诲姟杩愯鏁堢巼锛屽ぇ澶ф彁楂樹簡绯荤粺鐨勫彲浼哥缉鎬с€傝€屼笖姝ょ鏂瑰紡骞朵笉浼氬奖鍝?PartitionStep 鎵€鍦?Job 鐨勬墽琛岄『搴忥紝鍥犱负 PartitionStep 鍙湁褰撴墍鏈夊娲?Step 瀹屾垚涔嬪悗锛屾墠浼氱户缁線涓嬫墽琛屻€?/p>

涓嶈繃浣跨敤 PartitionStep 闇€瑕佹敞鎰忎互涓嬪嚑鐐癸細

• 鐢变簬鏁版嵁鐨勮鍐欎互鍙婂鐞嗗潎鍦ㄤ粠鏈轰笂杩涜锛屽洜姝ら渶瑕佺‘淇濆苟鍙戠殑浠庢満涔嬮棿涓嶄細閲嶅璇诲彇鏁版嵁锛堝綋鐒讹紝杩欎釜闂鏄墍鏈夋壒澶勭悊搴旂敤閲囩敤涓讳粠鍜岄泦缇ゆ灦鏋勬椂鎵€蹇呴』鑰冭檻鐨勯棶棰橈紝鑰屽苟闈炲彧鏈?Spring Batch 鎵嶄細鏈夛級銆?/li>
• 纭繚鍒嗚В鍒板悇涓粠鏈轰笂鐨?StepExecution 鏄笉鍚岀殑銆傚湪 StepExecutionSplitter 鐨勯粯璁ゅ疄鐜?SimpleStepExecutionSplitter 涓紝棣栧厛閫氳繃涓€涓?Partitioner 寰楀埌鍒嗚В鍚庣殑 ExecutionContext锛岀劧鍚庨拡瀵规瘡涓?ExecutionContext锛屽垱寤?StepExecution锛堝綋鐒讹紝濡傛灉 Step 涓洪噸澶嶆墽琛岋紝閭ｄ箞灏嗕細寰楀埌涓婃杩愯鐨?ExecutionContext 鍜?StepExecution锛岃€岄潪閲嶆柊鍒涘缓锛夈€?/li>

浠庣浜岀偣鍙互鐪嬪嚭锛岄€氳繃鍦?ExecutionContext 璁剧疆鍞竴鐨勪俊鎭紝鎴戜滑渚垮彲浠ヤ繚璇佹瘡涓粠鏈鸿鍙栫殑鏁版嵁鏄笉鍚岀殑銆?/p>

涓讳粠鏂瑰紡鐨勫叿浣撻厤缃娓呭崟 12 鎵€绀猴細

娓呭崟 12. partition.xml

 <beans:bean name="step"
	class="org.springframework.batch.core.partition.support.PartitionStep">
	<beans:property name="partitionHandler">
		<beans:bean
class="org.springframework.batch.core.partition.support.TaskExecutorPartitionHandler">
			<beans:property name="step" ref="remoteStep" />
			<beans:property name="gridSize" value="10" />
			<beans:property name="taskExecutor" ref="taskExecutor" />
		</beans:bean>
	</beans:property>
	<beans:property name="stepExecutionSplitter">
      <beans:bean 
class="org.springframework.batch.core.partition.support.SimpleStepExecutionSplitter">
			<beans:constructor-arg ref="jobRepository" />
			<beans:constructor-arg ref="messageStep" />
			<beans:constructor-arg ref="simplePartitioner" />
		</beans:bean>
	</beans:property>
	<beans:property name="jobRepository" ref="jobRepository" />
</beans:bean>

<step id="messageStep">
	<tasklet task-executor="taskExecutor">
		<chunk reader="messageReader" processor="messageProcessor"
		writer="messageWriter" commit-interval="5" chunk-completion-policy=""
				retry-limit="2">
			<retryable-exception-classes>
				<include class="java.lang.RuntimeException" />
			</retryable-exception-classes>
		</chunk>
	</tasklet>
</step>
<beans:bean id="remoteStep"
	class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">
	<beans:property name="serviceInterface" 
	    value="org.springframework.batch.core.Step" />
	<beans:property name="serviceUrl" 
	     value="${batch.remote.base.url}/steps/messageStep" />
</beans:bean>

姝ゅ鍙噰鐢?Spring Batch 鐨勯粯璁ゅ疄鐜帮紝灏?Step 鍙戦€佸埌涓€鍙颁粠鏈轰笂鎵ц锛屽綋鐒讹紝鎮ㄥ畬鍏ㄥ彲浠ュ熀浜?Spring Batch 褰撳墠鎺ュ彛锛岃交鏄撴墿灞曞嚭鍒嗗彂鍒?N 鍙颁粠鏈轰笂鎵ц鐨勫疄鐜般€?/p>

姝ゅ锛屽湪鑰楁椂鐨?Step 姣旇緝鐙珛鐨勬儏鍐典笅锛堝鍙戦€佹墸璐归€氱煡鐨?Step锛屽悗缁?Step 涓嶄細渚濊禆鎵ｈ垂閫氱煡 Step 鐨勪换浣曡緭鍑虹粨鏋滐級锛屾垜浠繕鍙互閲囩敤鍙︿竴绉嶄富浠庢灦鏋勩€傚湪涓绘満涓婇厤缃竴涓爣鍑嗙殑 Step锛屽叾 ItemWriter 璐熻矗灏嗚鍙栫殑璁板綍浠?Message 鐨勫舰寮忓彂閫佺粰娑堟伅涓棿浠讹紙褰撶劧锛岃鏂规骞舵湭鍏呭垎鍒╃敤 Spring Batch 鐨勭壒鎬э紝鑰屾槸鐢辨秷鎭腑闂翠欢瀹屾垚骞跺彂澶勭悊锛夈€?/p>

鎬荤粨

閫氳繃鏈枃鐨勮瑙ｏ紝鎮ㄥ凡缁忓熀鏈簡瑙ｄ簡 Spring Batch 涓娴佺▼銆佹潯浠朵互鍙婂苟鍙戠殑鏀寔銆傚埄鐢?Spring Batch 鎻愪緵鐨勮繖浜涚壒鎬э紝鎴戜滑瀹屽叏鍙互鏋勫缓鍑洪珮鎬ц兘銆侀珮鍙墿灞曟€у拰鍙淮鎶ゆ€х殑鎵瑰鐞嗗簲鐢ㄣ€傚湪鏈郴鍒楁枃绔犵殑鏈€鍚庝竴閮ㄥ垎锛屾垜灏嗙户缁粰鎮ㄤ粙缁?Spring Batch 鍏充簬鎵瑰鐞嗙洃鎺ф柟闈㈢殑鍐呭銆?/p>