序 本文主要聊一下jesque的几个dao dao列表 FailureDAO KeysDAO QueueInfoDAO WorkerInfoDAO FailureDAO jesque-2.1.0-sources.jar /net/greghaines/jesque/meta/dao/FailureDAO.java /** * FailureDAO provides access to job failures. /net/greghaines/jesque/meta/dao/KeysDAO.java /** * KeysDAO provides access to available keys. /net/greghaines/jesque/meta/dao/QueueInfoDAO.java /** * QueueInfoDAO provides access to the queues in use by Jesque
序 本文主要介绍一下jesque的event机制 WorkerEvent jesque-2.1.2-sources.jar! /net/greghaines/jesque/worker/WorkerEvent.java /** * The possible WorkerEvents that a WorkerListener /net/greghaines/jesque/worker/WorkerEventEmitter.java /** * A WorkerEventEmitter allows WorkerListeners 事件的触发 jesque-2.1.2-sources.jar! doc jesque
序 本文主要讲一下jesque的WorkerImpl与WorkerPool。 resque Resque是一个使用redis来创建后台任务的ruby组件。而jesque是其java版本。 ; final Thread workerThread = new Thread(worker); workerThread.start(); 这是worker实例 jesque /net/greghaines/jesque/worker/WorkerImpl.java /** * Starts this worker. WorkerPool jesque-2.1.2-sources.jar! doc resque jesque
序 本文主要介绍一下jesque在redis的存储结构 示例配置 namespace=demo listen-queue=demoqueue 启动时的reids对象 127.0.0.1:6379> keys "},\"backtrace\":[\"\\tat com.example.demo.job.DemoJob.run(DemoJob.java:30)\",\"\\tat cn.patterncat.jesque.component.RedisPooledWorkerImpl.execute (RedisPooledWorkerImpl.java:656)\",\"\\tat cn.patterncat.jesque.component.RedisPooledWorkerImpl.process (RedisPooledWorkerImpl.java:611)\",\"\\tat cn.patterncat.jesque.component.RedisPooledWorkerImpl.poll( RedisPooledWorkerImpl.java:420)\",\"\\tat cn.patterncat.jesque.component.RedisPooledWorkerImpl.run(RedisPooledWorkerImpl.java
存储byte到postgresql mybatis spring boot starter配置 jpa postgresql 使用uuid作为主键 mongo查看数据库空间大小 redis监控命令 聊聊jesque 的几个dao 聊聊jesque在redis中的数据结构 聊聊jesque的event机制 聊聊jesque的WorkerImpl与WorkerPool springboot使用jest操作elasticsearch
为什么需要分片 这里重新贴一下查询脚本dequeue.lua的内容: -- 参考jesque的部分Lua脚本实现 local zset_key = KEYS[1] local hash_key = KEYS
zset_value) redis.call('HSET', hash_key, hash_field, hash_value) return nil -- /lua/dequeue.lua -- 参考jesque