1.需求

商家把需要上下架的商品設(shè)置一個(gè)上下架時(shí)間，后臺服務(wù)端需要按時(shí)將該商品上下架。

2.現(xiàn)狀

目前服務(wù)端：1臺數(shù)據(jù)庫服務(wù)器+2臺無狀態(tài)web服務(wù)器，通過web服務(wù)器讀寫數(shù)據(jù)庫，可能存在沖突。

3.技術(shù)

考慮 quartz+spring+mysql

4.方案

1）給每一個(gè)商品設(shè)置一個(gè)qurartz cron表達(dá)式，問題在于：每一個(gè)商品都要給它new一個(gè)quartz實(shí)例，容易產(chǎn)生內(nèi)存消耗。

CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);
trigger.setCronExpression(updownTime);// 觸發(fā)器時(shí)間設(shè)定

2）設(shè)置quartz定時(shí)器，每秒遍歷數(shù)據(jù)庫（可以考慮時(shí)延減輕負(fù)擔(dān)），每秒遍歷DB，可以配置里面寫死，比如通過spring配置：

<beans>
??????? <!-- 要調(diào)用的工作類 -->
<bean id="quartzJob" class="com.kay.quartz.QuartzJob"></bean>
??????? <!-- 定義調(diào)用對象和調(diào)用對象的方法 -->
<bean id="jobtask"
class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
??????????? <!-- 調(diào)用的類 -->
??????????? <property name="targetObject">
??????????????? <ref bean="quartzJob"/>
??????????? </property>
??????????? <!-- 調(diào)用類中的方法 -->
??????????? <property name="targetMethod">
??????????????? <value>work</value>
??????????? </property>
??????? </bean>
??????? <!-- 定義觸發(fā)時(shí)間 -->
<bean id="doTime" class="org.springframework.scheduling.quartz.CronTriggerBean">
??????????? <property name="jobDetail">
??????????????? <ref bean="jobtask"/>
??????????? </property>
??????????? <!-- cron表達(dá)式 ，每秒執(zhí)行-->
??????????? <property name="cronExpression">
??????????????? <value>0/1 * * * * ?</value>
??????????? </property>
??????? </bean>
??????? <!-- 總管理類 如果將lazy-init='false'那么容器啟動就會執(zhí)行調(diào)度程序? -->
<bean id="startQuertz" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
??????????? <property name="triggers">
??????????????? <list>
??????????????????? <ref bean="doTime"/>
??????????????? </list>
??????????? </property>
??????? </bean>
</beans>

如果不用spring配置quartz的話，還可以通過quartz.properties進(jìn)行配置。

#============================================================================??
# Configure Datasources????
#============================================================================?

org.quartz.dataSource.NAME.driver = 數(shù)據(jù)庫驅(qū)動(requried)
org.quartz.dataSource.NAME.URL = 連接數(shù)據(jù)庫的url (requried)
org.quartz.dataSource.NAME.user = 連接的數(shù)據(jù)庫的用戶名(not requried)
org.quartz.dataSource.NAME.password =連接的數(shù)據(jù)庫的密碼(not requried)
org.quartz.dataSource.NAME.maxConnections = 連接池中最大連接數(shù)（not requried）
org.quartz.dataSource.NAME.validationQuery = sql查詢語句（not requried）

#============================================================================??
#*********************************
#============================================================================?

問題在于：數(shù)據(jù)庫過大時(shí)，掃描時(shí)間可能會增加。