标签:java spring 工厂模式 interface abstract
之前在项目中遇到这样一种情景:代码中有一个共用的任务处理模块,不同的数据会通过唯一键(任务名称和key fields)全部存入公共任务表里,然后在同步模块通过任务名称去获取相应的任务进行同步处理。
在存入公共任务表之前,不同的任务线都会进行各自的逻辑处理,而且基本上不存在共用的代码,所以在这里考虑建一个工厂类,由Spring注入一个Map<String, interface>,String对应的各个任务的名称,interface对应的是每个任务的处理接口。e.g.
<bean id="linkingDetectService" class="cn.vobile.service.linkingdetect.LinkingDetectServiceImpl"> <property name="taskPriority" ref="normal" /> <property name="commonTaskService" ref="commonTaskService" /> <property name="gson" ref="gson" /> </bean> <bean id="reclaimMatchSubscriptionService" class="cn.vobile.service.matchsubscription.reclaim.ReclaimMatchSubscriptionServiceImpl"> <property name="taskPriority" ref="normal" /> <property name="matchSubscriptionService" ref="matchSubscriptionService"/> <property name="gson" ref="gson" /> <property name="matchedVideoService" ref="matchedVideoCommonService" /> <property name="transactionTemplate" ref="masterTransactionTemplate" /> </bean> <bean id="commonTaskFactory" class="cn.vobile.service.commontask.CommonTaskFactory"> <property name="serviceMap"> <map> <entry key="linkingDetect"><ref bean="linkingDetectService"/></entry> <entry key="reclaimMatchSubscription"><ref bean="reclaimMatchSubscriptionService"/></entry> </map> </property> </bean>
public class CommonTaskFactory {
private Map<String, AbstractCommonService> serviceMap;
/**
* Create a task service by taskName.
*
* @param serviceName
* @return
*/
public AbstractCommonService create(String taskKey){
return serviceMap.get(taskKey);
}
/**
*
* @param serviceMap
*/
public void setServiceMap(Map<String, AbstractCommonService> serviceMap) {
this.serviceMap = serviceMap;
}
}public interface AbstractCommonService {
/**
* save a task to workingCommonTask
*
* @param matchedVideo
* @param taskName
* @param matchType
* @param priority
*/
void addWorkingTask(MatchedVideo matchedVideo, CommonTaskName taskName, MatchType matchType);
}AbstractCommonService linkingService = commonTaskFactory.create(CommonTaskKey.LINKINGDETECT.getCode()); linkingService.addWorkingTask(matchedVideo, CommonTaskName.SYNC_ADD_VIDEO_TO_TAISAN, null);
注:另外还有一种场景,各种任务存入公共任务表之前也许会存在很多的冗余代码(有很多的代码逻辑都是基本相同的),那么此时可以写一个抽象类(实现接口AbstractCommonService),把共用的代码写在该类中(每个任务线之间不同的部分可以使用抽象方法实现),然后各自不同的部分在各自的service类(继承抽象类)中实现父类中的抽象方法。
标签:java spring 工厂模式 interface abstract
原文地址:http://blog.csdn.net/thjnemo/article/details/42149833