Palermo 是一个基于 JVM 的作业处理系统,其灵感来自于 Resque,后端基于 RabbitMQ。 整个系统采用 Clojure 语言开发。
主要特性:
定义作业 Defining jobs
定义作业队列 Defining job queues
定义 workers
作业的序列化和反序列化
队列管理
Palermo 同时包含一个基于 Web 的前端管理系统,可作为独立的 Jetty 应用来运行。
作业任务:
package palermotests; import palermo.job.PalermoJob; public class SleepyJob implements PalermoJob { public SleepyJob(){} @Override public void process(Object arguments) throws Exception { int timeout = (Integer) arguments; System.out.println("SLEEPING..."); try { Thread.sleep(timeout); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("BACK!"); } }
Recently a lot of stars take Michael Kors bags, supermodel Laura Bailey, Pixie Geldof selected the elegant bust knee skirt, olive green color bias, to create a sort of handsome Military style, actress
Sam Palermo - Teaching
我有以下工作要处理在一定的时间间隔或特别的基础上。 作业中的步骤如下: 我也想要用户界面,在那里我可以触发一个特别的基础上的工作,而且我应该能够提供参数从用户界面。 我想用Spring batch来完成这个任务,但它更多的是用于读->处理->写之类的工作。这里,在第一步中,我正在生成由第二步读取的数据。我不确定我是否还可以使用Spring batch来实现这个,或者有更好的方法来实现这个。
我使用的是Laravel作业批处理功能,我有一个仪表板,可以显示批处理的进度(已处理、失败、挂起的作业…等等)。 每个用户都有自己的仪表板,我想根据登录用户显示Batch的进度,但我看不到与批处理表的用户模型有任何关系。 是否有可能以某种方式与这些表建立关系?还有其他选择吗? 谢谢
我有一个MyObject流,我想将它批量持久化到DB中(不是一个接一个,而是一次1000个)。所以我想做一个转变,就像 其中每个列表都有一些固定大小的批处理大小。有没有办法用标准的Java 8 Stream API做到这一点?
我已经开始探索Spring Batch,并遇到了一些基本问题。