mysql集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行

本篇內(nèi)容主要講解“MySQL集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行”，感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“mysql集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行”吧!

在網(wǎng)站制作、成都做網(wǎng)站過程中，需要針對(duì)客戶的行業(yè)特點(diǎn)、產(chǎn)品特性、目標(biāo)受眾和市場(chǎng)情況進(jìn)行定位分析，以確定網(wǎng)站的風(fēng)格、色彩、版式、交互等方面的設(shè)計(jì)方向。創(chuàng)新互聯(lián)公司還需要根據(jù)客戶的需求進(jìn)行功能模塊的開發(fā)和設(shè)計(jì)，包括內(nèi)容管理、前臺(tái)展示、用戶權(quán)限管理、數(shù)據(jù)統(tǒng)計(jì)和安全保護(hù)等功能。

一、問題描述

Spring自帶的Task雖然能很好使用定時(shí)任務(wù)，只需要做些簡(jiǎn)單的配置就可以了。不過如果部署在多臺(tái)服務(wù)器上的時(shí)候，這樣定時(shí)任務(wù)會(huì)在每臺(tái)服務(wù)器都會(huì)執(zhí)行，造成重復(fù)執(zhí)行。

二、解決方案

Spring+quartz集群可以解決多服務(wù)器部署定時(shí)器重復(fù)執(zhí)行的問題。

1、下載quartz的Jar包或者在Maven項(xiàng)目加入quartz的依賴包

不再細(xì)說，詳情可參考：

Spring4整合quartz2.2定時(shí)任務(wù)：http://fanshuyao.iteye.com/blog/2309223

2、建立quartz表

quartz是通過表來實(shí)現(xiàn)多服務(wù)器定時(shí)任務(wù)集群的，表的詳細(xì)信息在壓縮包：quartz-2.2.3-distribution.tar.gz，

路徑為：quartz-2.2.3-distribution\quartz-2.2.3\docs\dbTables

這里有很多表的SQL可執(zhí)行語句，直接復(fù)制執(zhí)行即可。

其中附件有quartz-2.2.3-distribution.tar.gz，是2016-07-07最新的。

本人使用的是Mysql，執(zhí)行的是tables_mysql_innodb.sql，另外一個(gè)tables_mysql.sql沒執(zhí)行，看都沒有看，哈哈。

注：最好先建完表，再執(zhí)行后面的索引，不然會(huì)有警告。

里面的表詳細(xì)本人也不了解，就不說了，百度或Google吧。

3、新增一個(gè)Bean文件（spring-quartz.xml），如下：

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"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

	<!-- 配置任務(wù)bean類 -->
	<bean id="quartzTask" class="com.lqy.spring.task.QuartzTask"></bean>
	
	<!-- 配置方法映射工廠類 -->
	<!-- MethodInvokingJobDetailFactoryBean不支持序列化 -->
	<!-- <bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
		<property name="targetObject" ref="quartzTask"></property>
		<property name="targetMethod" value="startTask"></property>
		<property name="concurrent" value="false"></property>
		concurrent : false表示等上一個(gè)任務(wù)執(zhí)行完后再開啟新的任務(wù)
	</bean> -->
	<!-- 配置方法映射工廠類 -->
	<bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
	    <property name="jobClass" value="com.lqy.spring.task.QuartzTaskExtends"></property>
	    <property name="durability" value="true"></property>
	    <property name="requestsRecovery" value="true" /> 
	</bean>
	
	<!-- 配置任務(wù)高度的的時(shí)間/周期 -->
	<bean id="jobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
		<property name="jobDetail" ref="jobDetail"></property>
		<property name="cronExpression" value="0 */1 * * * ?"></property>
		<!-- <property name="startDelay" value="3000"></property> -->
	</bean>
	
	<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="dataSource" ref="dataSource"></property>  
		<!--可選，QuartzScheduler 啟動(dòng)時(shí)更新己存在的Job，這樣就不用每次修改targetObject后刪除qrtz_job_details表對(duì)應(yīng)記錄了 -->    
        <property name="overwriteExistingJobs" value="true" />    
         <!--必須的，QuartzScheduler 延時(shí)啟動(dòng)，應(yīng)用啟動(dòng)完后 QuartzScheduler 再啟動(dòng) -->  
        <property name="startupDelay" value="30" />  
        <!-- 設(shè)置自動(dòng)啟動(dòng) -->  
        <property name="autoStartup" value="true" />
        <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />  
        <property name="configLocation" value="classpath:spring-quartz.properties" />  
		<property name="triggers">
			<list>
				<ref bean="jobTrigger"/>
			</list>
		</property>
	</bean>
	
</beans>

spring-quartz.xml文件里面主要配置的是定時(shí)任務(wù)

其中和一般Spring整合quartz定時(shí)任務(wù)不同的是：

（1）使用數(shù)據(jù)源：

在Bean id="schedulerFactoryBean"中使用了數(shù)據(jù)源：

Xml代碼  

<property name="dataSource" ref="dataSource"></property>

 數(shù)據(jù)源dataSource是在Spring.xml文件配置的。

（2）jobDetail使用的是org.springframework.scheduling.quartz.JobDetailFactoryBean

由于集群需要把定時(shí)任務(wù)的信息寫入表，需要序列化吧，但MethodInvokingJobDetailFactoryBean 不能序列化，會(huì)報(bào)錯(cuò)。

（3）增加spring-quartz.properties文件

Xml代碼  

#==============================================================  
#Configure Main Scheduler Properties  
#==============================================================   
org.quartz.scheduler.instanceName = defaultScheduler
org.quartz.scheduler.instanceId = AUTO

#==============================================================  
#Configure JobStore  
#============================================================== 
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000  
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.maxMisfiresToHandleAtATime = 1
org.quartz.jobStore.misfireThreshold = 120000
org.quartz.jobStore.txIsolationLevelSerializable = true
 
#==============================================================  
#Configure ThreadPool  
#============================================================== 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

#==============================================================
#Skip Check Update
#update:true
#not update:false
#==============================================================
org.quartz.scheduler.skipUpdateCheck = true 

#============================================================================   
# Configure Plugins    
#============================================================================      
org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin   
org.quartz.plugin.shutdownhook.class = org.quartz.plugins.management.ShutdownHookPlugin
org.quartz.plugin.shutdownhook.cleanShutdown = true

這個(gè)配置文件也是Quartz的配置文件，本人也不了解，只是從網(wǎng)上搜索來的。本來是有數(shù)據(jù)庫的連接配置的，但由于spring配置文件已經(jīng)有數(shù)據(jù)源，我就刪除掉了。

4、把上面的spring-quartz.xml 引入到spring.xml文件中：

Xml代碼  

<import resource="spring-quartz.xml"/>

 或者在web.xml文件加上，這種方法沒有嘗試，但應(yīng)該是可以的：

Xml代碼

<context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:spring.xml,classpath:spring-quartz.xml</param-value>
</context-param>

5、把項(xiàng)目部署到集群環(huán)境中

其實(shí)就是把項(xiàng)目部署到2個(gè)Tomcat中，這樣能看到定時(shí)任務(wù)是否重復(fù)執(zhí)行。

Tomcat+Nginx集群詳情見：http://fanshuyao.iteye.com/blog/2309601

6、啟動(dòng)所有Tomcat，看結(jié)果，如下：

mysql集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行


 由圖可見：定時(shí)器是每分鐘的0秒執(zhí)行一次

在2個(gè)Tomcat中，分別是一個(gè)tomcat執(zhí)行一次，另一個(gè)tomcat執(zhí)行一次，沒有重復(fù)執(zhí)行，這樣就達(dá)到了定時(shí)器的集群效果，成功。

想到的其他方案

1.全局鎖機(jī)制

   對(duì)于只需要執(zhí)行一次初始化的操作，在全局緩存中設(shè)置一個(gè)全局鎖，拿到這個(gè)鎖的節(jié)點(diǎn)執(zhí)行相應(yīng)的任務(wù)。

2.數(shù)據(jù)庫層面的狀態(tài)標(biāo)記

  對(duì)于有些定時(shí)任務(wù)，我們只希望執(zhí)行一次，也就是說多個(gè)節(jié)點(diǎn)，只有一個(gè)節(jié)點(diǎn)在執(zhí)行這個(gè)定時(shí)任務(wù)

  可以在數(shù)據(jù)庫對(duì)這個(gè)任務(wù)進(jìn)行狀態(tài)標(biāo)記，根據(jù)狀態(tài)來調(diào)節(jié)節(jié)點(diǎn)間定時(shí)任務(wù)的執(zhí)行

3.代碼分離

  如果有可能，將定時(shí)任務(wù)獨(dú)立出來，成為一個(gè)單獨(dú)的項(xiàng)目工程，部署單節(jié)點(diǎn)，避免集群部署

4.設(shè)置執(zhí)行定時(shí)任務(wù)的機(jī)器名，在代碼中判斷

到此，相信大家對(duì)“mysql集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

本文名稱：mysql集群環(huán)境下怎么解決定時(shí)器重復(fù)執(zhí)行
鏈接地址：http://bm7419.com/article48/jjdphp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供關(guān)鍵詞優(yōu)化、網(wǎng)頁設(shè)計(jì)公司、響應(yīng)式網(wǎng)站、微信公眾號(hào)、網(wǎng)站收錄、建站公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

商城網(wǎng)站建設(shè)