找回密码
 立即注册

本文来自

电脑/上网

电脑/上网

订阅|关注

致力于提供软件新闻发布,和软件知识学习,包括常用软件应用技巧及评测,创意设计相关的图文及视频教程

精选帖子

Elastic Job 定时任务实现

[复制链接]
190 时光飞逝 发表于 2017-9-14 09:25:26
官方文档:http://dangdangdotcom.github.io/elastic-job/elastic-job-lite/00-overview/intro/
该说的文档上都说了;在过程中遇到一些错误记下了
环境:zookeeper版本 zookeeper-3.4.6 或3.4.6以上 不然会莫名其妙的报错
我是maven 搭建的项目 需要包(当然spring的包是不可少的当然你用java来操作的话就不需要spring的包了):
dependency
artifactId elastic-job-common-core /artifactId
groupId com.dangdang /groupId
version 2.1.5 /version
/dependency
dependency
artifactId elastic-job-lite-core /artifactId
groupId com.dangdang /groupId
version 2.1.5 /version
/dependency
dependency
artifactId elastic-job-lite-spring /artifactId
groupId com.dangdang /groupId
version 2.1.5 /version
/dependency
spring-job配置(参数配置就不讲了官方文档都有配置;关键点是配置是配置的数据源作业维度操作历史记录看你自己了需要配你就配不需要就不配 event-trace-rdb-data-source= dataSource ):
?xml version= 1.0 encoding= UTF-8 ?
beans xmlns= http://www.springframework.org/schema/beans
xmlns:xsi= http://www.w3.org/2001/XMLSchema-instance
xmlns:context= http://www.springframework.org/schema/context
xmlns:reg= http://www.dangdang.com/schema/ddframe/reg
xmlns:job= http://www.dangdang.com/schema/ddframe/job
xsi:schemaLocation= http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.dangdang.com/schema/ddframe/reg
http://www.dangdang.com/schema/ddframe/reg/reg.xsd
http://www.dangdang.com/schema/ddframe/job
http://www.dangdang.com/schema/ddframe/job/job.xsd
!--配置作业注册中心 --
reg:zookeeper id= regCenter server-lists= localhost:2181 namespace= erp-job base-sleep-time-milliseconds= 1000 max-sleep-time-milliseconds= 3000 max-retries= 3 /
!-- 0 0 0 * * ? --
job:simple id= customerFollowElasticJob >
java代码实现:
package com.isz.erp.job;
import org.springframework.beans.factory.annotation.Autowired;
import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
testShareData(context.getShardingItem(), context.getShardingTotalCount(), 100, context.getTaskId());
* @Description: 测试分片数据 参数一当前分片 参数二分片总数 参数三 总条数
* @return void
* @date 2017年9月7日 下午5:24:41
public void testShareData(int sharItem,int sharCount,int dataCount,String taskId ){
if(sharItem==(sharCount-1)){//如果总分片数据==当前分片 说明是最后数据
System.out.println( 分片.... +taskId+ ....... +sharItem+ 执行数据: +((dataCount/sharCount)*sharItem)+ 到 +((dataCount/sharCount)*(sharItem==0?1:sharItem+1)+(dataCount%sharCount)));
}else{
System.out.println( 分片.... +taskId+ ........ +sharItem+ 执行数据: +((dataCount/sharCount)*sharItem)+ 到 +(dataCount/sharCount)*(sharItem==0?1:sharItem+1));
public static void main(String[] args) {
//97条数据
int dataCount=97;
//5片
int share=5;
System.out.println( 每个分片执行: +97/5+ 条数数据
System.out.println( 最后一个分片执行: +((97/5)+(dataCount%share))+ 条数数据
启动服务:
package test.dubbo;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
* @描述: 启动Dubbo服务用的MainClass.
* @作者:
* @创建时间:
* @版本: 1.0
public class DubboProvider {
private static final Log log = LogFactory.getLog(DubboProvider.class);
@SuppressWarnings( resource )
public static void main(String[] args) {
try {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
classpath:spring/spring-context.xml
context.start();
} catch (Exception e) {
log.error( == DubboProvider context start error: , e);
synchronized (DubboProvider.class) {
while (true) {
try {
DubboProvider.class.wait();
} catch (InterruptedException e) {
log.error( == synchronized error: , e);
}
启动服务后你应该就可以看到控制太打印的信息了..........................到此程序就玩了
可能要用到的工具:
官网上下载:elastic-job-lite-console-2.1.5 可以看到以下信息(相关参数官网上都有介绍相信你也看的懂是什么)
目录里bin下面有个start.bat如果是linux启动start.sh就好了 然后在浏览器上输入:http://localhost:8899/ 你就会看到如下信息

还可以下载:ZooInspector 看一下节点信息:


就这样完了。。。。。。。。。。。。。。。
elasticJob分片跑批
itlqi:
你好 能发一份demo吗 最近在看这个 实现动态添加没任务没什么思路 807982039@qq.co...

easyui框架session失效问题
ionlywantto:
你好,我现在用easyui,也是通过iframe 连接后在tab中显示,但是遇到一个问题就是,打开i...

java web emoji表情显示
wen2king:
我最近也要做个Java web 类似发帖的功能,emoji表情也要和ios Android 的APP...

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有帐号?立即注册

x
温馨提示:
1、在论坛里发表的文章仅代表作者本人的观点,与本网站立场无关。
2、论坛的所有内容都不保证其准确性,有效性,时间性。阅读本站内容因误导等因素而造成的损失本站不承担连带责任。
3、若因线路及非本站所能控制范围的故障导致暂停服务期间造成的一切不便与损失,论坛不负任何责任。
4,本网站内容均摘自其他网站,如涉及侵权定当第一时间删除
5、如侵犯您的权益请联系936144721@qq.com



上一篇:招商证券被砸牌子:保荐项目一天被毙掉仨
下一篇:新浪财经早报:9月14日重磅消息汇总
转载请说明出处,本文地址:http://bbs.imicun.com/thread-15467687-1-1.html
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

快速回复 返回顶部 返回列表