# zk-quartz

**Repository Path**: showmsg/zk-quartz

## Basic Information

- **Project Name**: zk-quartz
- **Description**: quartz+zookeeper，实现failover，高可用quartz调度任务执行框架
1.override MethodInvokingJobDetailFactoryBean ，在executeInternal()方法，增加判断当前任务节点是否为master(leader)，其他slaver(follower)节点则监听等待；另新增对象属性zkSchedule，自定义客户端对zookeeper的管理类，路径监听等操作
2.采用curator，实现zookeeper客户端
3.定义curatorWrapper封装curatorframework的操作
4.定义curatorManager类，提供创建、修改、删除、读取子节点路径、数据等公共方法
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 7
- **Created**: 2015-07-31
- **Last Updated**: 2021-11-03

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

it is about zk-quartz

job-spring.xml配置

	<!-- bean声明 -->
	<bean id="zkConfig" class="com.justic.zk.quartz.support.ZkConfig">
		<!-- 配置zookeeper，如zookeeper-cluster则以","分割 -->
		<property name="zkServer" value="10.89.113.184:2181"></property>
		<!-- 配置节点 所在zk-path-->
		<property name="rootPath" value="/quartz/zk/schedule"></property>
		<!-- 配置节点集群，同groupName即节点实现相同任务 -->
		<property name="groupName" value="/group-1"></property>
		<!-- 配置连接zookeeper-server超时时间，单位ms -->
		<property name="connectTimeout" value="15000"></property>
		<!-- 配置连接zookeeper-server session超时时间，单位ms -->
		<property name="sessionTimeout" value="6000"></property>
		<!-- 配置当前节点名称，用于和其他节点名区分，建议命名唯一-->
		<property name="nodeName" value="node-1"></property>
	</bean>
	
	<!-- 具体执行的任务，同quartz使用 -->
	<bean id="mainService" class="com.justic.zk.quartz.Work">
		<constructor-arg index="0" value="node-1"></constructor-arg>
	</bean>
	
	<!-- 任务计划管理类，初始化参数zkConfig 对象 -->
	<bean id="scheduleManager" class="com.justic.zk.quartz.ScheduleManager">
		<property name="zkConfig" ref="zkConfig"></property>
	</bean>

	<!-- 使用MethodInvokingJobDetailFactoryBean，任务类可以不实现Job接口，通过targetMethod指定调用方法 -->
	<!-- 代替org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean 实现zookeeper-leader选举， -->
	<bean id="jobDetail"
		class="com.justic.zk.quartz.support.MethodInvokingJobDetailFactoryBean">
		
		<!-- 实现 zk 必须的-->
		<property name="zkSchedule" ref="scheduleManager"/>
		
		<!-- job-name -->
		<property name="name" value="test-job" />
		<!-- job-group -->
		<property name="group" value="test-group" />

		<!-- 调用的类 -->
		<property name="targetObject" ref="mainService" />

		<!-- 调用类中的方法 -->
		<property name="targetMethod" value="start" />

		<!--是否允许任务并发执行。当值为false时，表示必须等到前一个线程处理完毕后才再启一个新的线程 -->
		<property name="concurrent" value="false" />

	</bean>



	<bean id="simpleTrigger"
		class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
		<property name="jobDetail" ref="jobDetail" />
		<!-- 延迟触发时间，0表示立即执行 -->
		<property name="startDelay" value="0" />
		<!-- 重复触发的时间间隔，5分钟=300s=300000ms -->
		<property name="repeatInterval" value="10000" />
	</bean>


	<!-- 调度工厂 如果将lazy-init='false'那么容器启动就会执行调度程序 不写默认是false -->
	<bean id="scheduler" lazy-init="false" autowire="no"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref bean="simpleTrigger" />
			</list>
		</property>
	</bean>