当前位置: 首页 > 工具软件 > jesque > 使用案例 >

Jesque 基础入门

羊舌高峰
2023-12-01

Jesque是Resque的java实现,它是一个maven项目,依赖Jedis连接到Redis,使用Jackson序列化Job信息,存储在Redis数据库中。主要用于做定时任务。

添加依赖

你可以去官网下载jar包,当然如果你是一个maven项目,像下面这样直接添加依赖即可:

<dependency>
  <groupId>net.greghaines</groupId>
  <artifactId>jesque</artifactId>
  <version>2.0.2</version>
</dependency>

创建即时任务

final Job job = new Job("TestAction", 
    new Object[]{ 1, 2.3, true, "test", Arrays.asList("inner", 4.5)});

client.enqueue("queue", job);

创建定时任务

final Job job = new Job("TestAction", 
    new Object[]{ 1, 2.3, true, "test", Arrays.asList("inner", 4.5)});

final long delay = 10; // 秒
final long future = System.currentTimeMillis() + 
    (delay * 1000); // job执行时间点,格式:时间戳,单位:毫秒

// 10秒后执行job
client.delayedEnqueue("delayQueue", job, future);

创建循环定时任务

final Job job = new Job("TestAction", 
    new Object[]{ 1, 2.3, true, "test", Arrays.asList("inner", 4.5)});

final long delay = 10; // 秒
final long future = System.currentTimeMillis() + 
    (delay * 1000); // job执行时间点,格式:时间戳,单位:毫秒
final long frequency = 60; // 秒

// 10秒后执行job,以后每隔1分钟执行一次
client.recurringEnqueue("recurDelayQueue", job, future, (frequency * 1000));

取消定时任务

// 取消redis中名为delayQueue的set集合存放的job
client.removeDelayedEnqueue("delayQueue", job);

client.removeRecurringEnqueue("recurDelayQueue", job);

监听消费者

在这里我只是把worker命令为消费者,仅仅是因为它看起来像是在消费我们创建的Jesque任务而已。

worker.getWorkerEventEmitter().addListener(new WorkerListener(){
   public void onEvent(WorkerEvent event, Worker worker, String queue, 
       Job job, Object runner, Object result, Throwable t) {
        if (runner instanceof TestAction) {
            // do something
        }
    }
}, WorkerEvent.JOB_EXECUTE);

我们可以监听到的消费事件,你可以监听这些事件在相应时刻做一些事情:

事件描述
WORKER_START完成启动,即将开始运行。
WORKER_POLL轮询队列。
JOB_PROCESS处理任务。
JOB_EXECUTE执行任务。
JOB_SUCCESS任务执行成功。
JOB_FAILURE任务执行失败。
WORKER_ERROR发现在正常运行时产生异常。
WORKER_STOP完成运行,即将关闭。

增加Jedis配置

{
    InputStream inputStream = JesqueConfig.class.getResourceAsStream(
        "/db.properties");
    Properties properties = new Properties();
    try {
        properties.load(inputStream);
    } catch (IOException e) {
        e.printStackTrace();
    }

    String host = properties.getProperty("redis.host");
    String port = properties.getProperty("redis.port");
    ConfigBuilder configBuilder = new ConfigBuilder();
    if (!StringUtils.isEmpty(host)) {
        configBuilder.withHost(host);
    }
    if (!StringUtils.isEmpty(port)) {
        configBuilder.withPort(Integer.parseInt(port));
    }

    setRedisConfig(configBuilder.build());
}


参考链接:Jesque官网 & 我的一个简单示例

 类似资料: