BlogJava-OpenHandX 2数据服务为中心的企业架构(java)-最新评论

re: OpenHandX-River 1.0[未登录]

dong — Thu, 17 Apr 2014 03:17:00 GMT

写的太专业了，难得能总结的这么好，可以到杂志发表一下

dong 2014-04-17 11:17 发表评论

re: OpenHandX-River 1.0

qiu768 — Mon, 21 Jan 2013 07:41:00 GMT

时隔一年终于有更新了，不知道传说中的工作流产品弄得怎么样了。

qiu768 2013-01-21 15:41 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

彭明华 — Mon, 03 Dec 2012 09:18:00 GMT

图型方式（使用VML技术）在IE6下可以使用，是我表述不准确。IE9下不正常是EXT2的问题，可以使用IE9兼容方式解决（IE9地址输入框内后部的一个按钮）

彭明华 2012-12-03 17:18 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

wmj2003 — Mon, 26 Nov 2012 02:20:00 GMT

@彭明华
“batchcosole的预览分为两部分，一个是编辑节点运行图，另一个日志分析图时提供。这两个预览又分提供列表和图型方式提供展示，但是图型方式（使用VML技术）必须在IE6以上版本才能看”（注：引用）

异步任务监控调度代码中确实没有图形监控的代码，我看jsp和js代码了。另外在IE浏览器9下面无法打开。可能是extjs3的问题，在firefox下面可以打开。

wmj2003 2012-11-26 10:20 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

彭明华 — Fri, 23 Nov 2012 03:11:00 GMT

@wmj2003
好的,很感谢您的细心回复,我会在近期修改一版上传

彭明华 2012-11-23 11:11 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

wmj2003 — Thu, 22 Nov 2012 02:58:00 GMT

@彭明华（有理解不对的地方请指正。qq 229849534 王明杰-聚灵-济南）

数据库初始化的脚本有问题。记不清楚了，有个时间列默认值给弄错了，本应该在STARTTIME 上面设置默认值，结果设置在COMPLETETIME 上面了。导致整体程序执行错误（通过数据库发送信息的时候）。

事件中心建议修改整体设计规划，采用JcronTab框架实现，可以大大简化事件发送器。
事件发送器：CycleEvent 类
public EventDefine createEvent(Context context,
Map configParams, Event event) throws EventCenterException{
Map params = ParamParse.getParams(event.getConfigs());

if(params==null){
throw new EventCenterException("the configs can not be null");
}
// System.out.println("type="+params.get("type"));
// System.out.println("timeNum="+params.get("timeNum"));
// System.out.println("startTime="+params.get("startTime"));
// System.out.println("endTime="+params.get("endTime"));
if(params.get("type")==null || params.get("type").trim().equals("")){
throw new EventCenterException("the type parameter can not be null,interpose configs please");
}
if(params.get("timeNum")==null || params.get("timeNum").trim().equals("")){
throw new EventCenterException("the timeNum parameter can not be null,interpose configs please");
}
Timestamp ts = null;
if(params!=null && params.get("startTime")!=null && !params.get("startTime").trim().equals("")){
ts = Timestamp.valueOf(params.get("startTime"));
}
Timestamp ets = null;
if(params!=null && params.get("endTime")!=null && !params.get("endTime").trim().equals("")){
ets = Timestamp.valueOf(params.get("endTime"));
}
EventDefine eventDefine = null;
if(ets!=null){//如果定义了结束时间，那么就判断什么时间结束
//TODO 这段逻辑有bug
// if(ts==null || new Timestamp(System.currentTimeMillis()).compareTo(ts)>=0){
// eventDefine = getEvent(event.getId().replaceAll("#time#",String.valueOf(System.currentTimeMillis())),event);
// if(new Timestamp(System.currentTimeMillis()).compareTo(ets)>=0){
// complete = true;
// }
// }
//如果结束时间到了，那么就终止任务。
if(new Timestamp(System.currentTimeMillis()).compareTo(ets)>=0){
complete = true;
}

}else{

List ids = ParamParse.getValues(event.getId());//有多少个ID就创建多少个事件
if(ids!=null && !ids.isEmpty() && (ts==null || new Timestamp(System.currentTimeMillis()).compareTo(ts)>=0)){
if(checkIsCreate(params)){//检查周期性时间是否匹配，匹配就创建任务
String tempId = ids.get(loop).replaceAll("#time#",String.valueOf(System.currentTimeMillis()));
eventDefine = getEvent(tempId,event);
System.out.println("CycleEvent----------开始创建事件请求----eventDefine="+eventDefine.getId());
loop++;
if(loop>=ids.size()){
complete = true;
}
}
}else{
complete = true;
}
}
return eventDefine;
}

控制器中：open.batch.controller.impl.application. LayerNodeMap 有bug。
方法private List getNodes(String mapId,String params) throws SQLException 中，把标记写错了。

if(rs.getString("RERUN")!=null)
node.setReRunMode(rs.getInt("RERUN")); //TODO 重跑模式在这里写错了吧,果然写错了.2012-09-20 又是一个bug已经修正

open.batch.taskserver.message.TaskSenderManager
这个类应做错误处理，将发送失败的任务重新进入队列中。同时需要修改他送任务的接口，让其只返回发送失败的任务。否则一旦发送失败，这个任务就丢失了。
（注：其他发送任务的地方也有类似的问题。）
/**
* @see Runnable#run()
*/
public void run() {
while(!stopFlag){
synchronized(Lock){
if(tasks!=null && !tasks.isEmpty()){
// taskSender.sender(context,tasks,configParams);
// tasks.clear();
//将发送失败的任务重新加入到任务队列
List taskfailures = taskSender.sendernew(context,tasks,configParams); //初步只是实现了DB的方式
tasks.clear();
this.setTasks(taskfailures); //将发送失败的任务重新放入发送队列。
}
}
try {
Thread.sleep(1);
} catch (InterruptedException e) {
log4j.error(null,e);
}
}
complete = true;
}

wmj2003 2012-11-22 10:58 发表评论

re: OpenHandX-Batch1.0 快速部署手册

wmj2003 — Thu, 22 Nov 2012 02:29:00 GMT

@彭明华
看明白了，呵呵，我也忘记早给你回复。以前都是通过查询锁表实现的。这也是一种好方法，多交流。

wmj2003 2012-11-22 10:29 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

彭明华 — Wed, 31 Oct 2012 01:26:00 GMT

@wmj2003
batch核心可能有Bug，能说一下具体的吗，我好解决，谢谢！
batchcosole的预览分为两部分，一个是编辑节点运行图，另一个日志分析图时提供。这两个预览又分提供列表和图型方式提供展示，但是图型方式（使用VML技术）必须在IE6以上版本才能看

彭明华 2012-10-31 09:26 发表评论

re: OpenHandX-Batch1.0 快速部署手册

彭明华 — Wed, 31 Oct 2012 01:19:00 GMT

@wmj2003
最近再忙另外一个项目,很少上blog,抱歉.
upst = cnn.prepareStatement("update " + configParams.get("table") + " set TASKID=TASKID where ID=" + id);
就是一个锁表记录操作,锁完后再查询状态RECTIME,就能保证多台服务器获并发时任务不会重复被执行

彭明华 2012-10-31 09:19 发表评论

re: OpenHandX-Batch 1.02 企业级批量应用架构

wmj2003 — Wed, 19 Sep 2012 03:49:00 GMT

batchcosole 缺少预览功能。另外 batch核心代码有bug。google上应该不是最终版本。呵呵

wmj2003 2012-09-19 11:49 发表评论