首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏码匠的流水账

    聊聊jesque的几个dao

    序 本文主要聊一下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

    58210发布于 2018-09-17
  • 来自专栏码匠的流水账

    聊聊jesque的event机制

    序 本文主要介绍一下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

    60210发布于 2018-09-17
  • 来自专栏码匠的流水账

    聊聊jesque的WorkerImpl与WorkerPool

    序 本文主要讲一下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

    57010发布于 2018-09-17
  • 来自专栏码匠的流水账

    聊聊jesque在redis中的数据结构

    序 本文主要介绍一下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

    1.1K10发布于 2018-09-17
  • 来自专栏码匠的流水账

    2017年终总结

    存储byte到postgresql mybatis spring boot starter配置 jpa postgresql 使用uuid作为主键 mongo查看数据库空间大小 redis监控命令 聊聊jesque 的几个dao 聊聊jesque在redis中的数据结构 聊聊jesque的event机制 聊聊jesque的WorkerImpl与WorkerPool springboot使用jest操作elasticsearch

    2.1K10发布于 2018-09-17
  • 来自专栏Throwable's Blog

    使用Redis实现延时任务(二)

    为什么需要分片 这里重新贴一下查询脚本dequeue.lua的内容: -- 参考jesque的部分Lua脚本实现 local zset_key = KEYS[1] local hash_key = KEYS

    1.3K10发布于 2020-06-23
  • 来自专栏Throwable's Blog

    使用Redis实现延时任务(一)

    zset_value) redis.call('HSET', hash_key, hash_field, hash_value) return nil -- /lua/dequeue.lua -- 参考jesque

    1.6K40发布于 2020-06-23
领券