tbschedule是淘宝的一个分布式任务调度框架,可访问官方网址http://code.taobao.org/p/tbschedule/wiki/index/获取源代码和了解具体的介绍,在这里就不再做重复的介绍了,直接给出实例教程。
1、在maven的pom.xml中引入tbschedule依赖
<dependency>
<groupId>com.taobao.pamirs.schedule</groupId>
<artifactId>tbschedule</artifactId>
<version>3.3.3.2</version>
</dependency>
2、创建任务处理类
需实现IScheduleTaskDealSingle 单任务处理的接口 或者IScheduleTaskDealMulti 可批处理的任务接口
@Component
public class SingleJob implements IScheduleTaskDealSingle<TaskModel> {
private static final Logger LOG = LoggerFactory.getLogger(SingleJob.class);
private static int num = 1;
@Override
public boolean execute(TaskModel taskModel, String ownSign) throws Exception {
LOG.info(Thread.currentThread().getName() + " IScheduleTaskDealSingleTest执行开始啦.........." + new Date());
System.out.println(JSON.toJSONString(taskModel));
return true;
}
/**
* @param taskParameter 自定义参数(字符串)
* @param ownSign 环境
* @param taskQueueNum 任务项的数量
* @param taskItemList 集合中TaskItemDefine的id值对应任务项值
* @param eachFetchDataNum 每次获取数据量
* @return
* @throws Exception
*/
@Override
public List<TaskModel> selectTasks(String taskParameter, String ownSign, int taskQueueNum, List<TaskItemDefine> taskItemList, int eachFetchDataNum) throws Exception {
LOG.info(Thread.currentThread().getName() + " IScheduleTaskDealSingleTest配置的参数,taskParameter:{},ownSina:{},taskQueueNum:{},taskItemList:{}, eachFetchDataNum:{}", taskParameter, ownSign, taskQueueNum, taskItemList, eachFetchDataNum);
List<TaskModel> models = new ArrayList<>();
for (int i = 0; i < 1000; i++) {
models.add(new TaskModel(String.valueOf(System.currentTimeMillis()), "taosirTest" + i));
models.add(new TaskModel(String.valueOf(System.currentTimeMillis()), "taosirTest" + i));
}
return models;
}
@Override
public Comparator<TaskModel> getComparator() {
return null;
}
}
3、在spring配置文件中添加配置
<bean id="scheduleManagerFactory" class="com.taobao.pamirs.schedule.strategy.TBScheduleManagerFactory" init-method="init">
<property name="zkConfig">
<map>
<entry key="zkConnectString" value="${schedule.zookeeper.address}" />
<entry key="rootPath" value="${schedule.root.catalog}" />
<entry key="zkSessionTimeout" value="${schedule.timeout}" />
<entry key="userName" value="${schedule.username}" />
<entry key="password" value="${schedule.password}" />
<entry key="isCheckParentPath" value="true" />
</map>
</property>
</bean>
经过这三步,开发任务已经完成。
4.在tbschedule的web控制台配置策略和任务。
4.1 配置zookeeper的相关信息
4.2 配置策略
4.3 配置任务
ScheduleConsole.war可从源代码中获得,部署到tomcat中即可,zookeeper的部署可参考相关文章。
配置好之后,把自己的项目部署到tomcat启动任务即可执行。
如在应用中遇到什么问题,欢迎留言评论交流。
分享到:
相关推荐
本文将深入探讨在给定的压缩包中涉及的几个关键组件:`core-3.3.3`, `javase-3.3.3`, `zxing-1.7-core` 和 `zxing-j2se-1.7`,以及与之相关的JDK版本,包括JDK1.7和JDK1.8。这些组件主要用于二维码生成和处理,对于...
Maven 3.3.3包含了许多内置插件,如maven-compiler-plugin用于编译源代码,maven-surefire-plugin进行单元测试等。 4. **生命周期与构建阶段**:Maven有三个主要的生命周期,即clean、default和site。default生命...
本主题聚焦于如何在Eclipse 4.3.2版本上安装并配置Python 3.3.3的支持,以及涉及到64位系统的兼容性问题。下面将详细介绍整个过程,帮助开发者建立一个高效、稳定的Python开发环境。 首先,我们需要下载Eclipse ...
maven :3.3.3 JDK : 1.8 Intellij IDEA : 2017.2.5 开发工具 spring boot :1.5.9.RELEASE mybatis 3.4.5 :dao层框架 pageHelper : 5.1.2 httpClient : 4.5.3 layui 2.2.3 :前端框架 shiro 1.4.0 :权限...
3.3.3 设定Path、Classpath和J2EE_HOME 3.4 小结 第四章 Tomcat使用指南 4.1 Tomcat简介 4.1.1 Tomcat的目录结构 4.1.2 Tomcat的配置参数 4.2 建立Tomcat的开发环境 4.2.1 下载Tomcat 4.2.2 设定TOMCAT_HOME 4.3 ...
在“apache-maven-3.3.3.zip”这个压缩包中,包含了Maven 3.3.3版本的完整安装文件。 Maven的核心概念之一是POM,它是一个XML文件,包含了项目的基本信息、构建指令、依赖关系等。通过POM,Maven能够自动下载项目所...
《MyBatisCodeHelperPro 3.3.0+2321:助力IntelliJ IDEA的高效开发》 在当今的软件开发领域,集成开发环境(IDE)扮演着至关重要的角色,其中IntelliJ IDEA以其强大的功能和友好的用户体验备受开发者喜爱。...
"apache-maven-3.3.3-bin.rar" 是Apache Maven 3.3.3版本的二进制发行版压缩包。这个版本发布于2015年,是Maven发展的一个稳定阶段。该压缩包包含了运行Maven所需的全部文件,包括可执行的jar文件、配置文件以及相关...
3.3.3 设定Path、Classpath和J2EE_HOME 3.4 小结 第四章 Tomcat使用指南 4.1 Tomcat简介 4.1.1 Tomcat的目录结构 4.1.2 Tomcat的配置参数 4.2 建立Tomcat的开发环境 4.2.1 下载Tomcat 4.2.2 设定TOMCAT_HOME 4.3 ...
SpringSecurity3.1.3 + JDK1.7 + Maven3.3.3 + Jetty9,提供基本的pom.xml,applicationContext.xml,web.xml配置和jetty插件的配置
** Maven 3.3.3 知识点详解 ** Maven 是一个强大的构建工具,主要应用于Java项目,由Apache Software Foundation开发并维护。它的全名是Apache Maven,其核心概念是项目对象模型(Project Object Model,简称POM)...
本博客提供的所有教程的资源原稿均来自于互联网,仅供学习交流之用,切勿进行商业传播。同时,转载时不要移除本申明。如产生任何纠纷,均与本博客所有人、发表该文献之人无任何关系。谢谢合作 本书共分4部分,从...
在Maven 3.3.3这个版本中,我们看到了许多优化和改进,使得开发者能够更加高效地工作。 首先,让我们深入了解Maven的核心概念。POM是Maven的核心,它是XML格式的文件,包含了项目的基本信息、依赖关系、构建配置等...
Maven 3.3.3是该工具的一个稳定版本,包含了丰富的功能和改进,旨在提高开发效率和项目的可维护性。 在Java开发中,Maven通过读取项目的POM.xml文件,自动处理项目的依赖管理、构建流程、测试、打包等任务。POM.xml...
本博客提供的所有教程的资源原稿均来自于互联网,仅供学习交流之用,切勿进行商业传播。同时,转载时不要移除本申明。如产生任何纠纷,均与本博客所有人、发表该文献之人无任何关系。谢谢合作 本书共分4部分,从...