脚本宝典收集整理的这篇文章主要介绍了聊聊jesque在redis中的数据结构，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。
序
本文主要介绍一下jesque在redis的存储结构
示例配置
namespace=demo listen-queue=demoqueue启动时的reids对象
127.0.0.1:6379> keys * 1) "demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started" 2) "demo:worker:Mars.local:3820-1:JAVA_DYNAMIC_QUEUES,demoqueue:started" 3) "demo:worker:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue:started" 4) "demo:workers" 5) "demo:worker:Mars.local:3820-2:JAVA_DYNAMIC_QUEUES,demoqueue:started" 6) "demo:worker:Mars.local:3820-4:JAVA_DYNAMIC_QUEUES,demoqueue:started" 127.0.0.1:6379> type demo:workers set 127.0.0.1:6379> smembers demo:workers 1) "Mars.local:3820-4:JAVA_DYNAMIC_QUEUES,demoqueue" 2) "Mars.local:3820-2:JAVA_DYNAMIC_QUEUES,demoqueue" 3) "Mars.local:3820-1:JAVA_DYNAMIC_QUEUES,demoqueue" 4) "Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue" 5) "Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue"namespace:workers
set类型的数据接口，存储该namespace下的workers的名称
namespace:worker:host:queueType,listen-queue:state
这个是标记每个namespace的worker的状态，是个string类型，存储事件产生时间
127.0.0.1:6379> type demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started string 127.0.0.1:6379> get demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started "2017-11-18T15:35:24.913+0800"新增job
127.0.0.1:6379> keys * 1) "demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started" 2) "demo:queue:demoqueue" 3) "demo:worker:Mars.local:3820-1:JAVA_DYNAMIC_QUEUES,demoqueue:started" 4) "demo:worker:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue:started" 5) "demo:queues" 6) "demo:workers" 7) "demo:worker:Mars.local:3820-2:JAVA_DYNAMIC_QUEUES,demoqueue:started" 8) "demo:worker:Mars.local:3820-4:JAVA_DYNAMIC_QUEUES,demoqueue:started"可以发现新增了几个queue相关的对象
demo:queue:demoqueue这个是个锁信息
namespace:queues
是一个set结构，存储队列信息
127.0.0.1:6379> smembers demo:queues 1) "demoqueue"处理完job
127.0.0.1:6379> keys * 1) "demo:worker:Mars.local:3820-1:JAVA_DYNAMIC_QUEUES,demoqueue:started" 2) "demo:worker:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue:started" 3) "demo:queues" 4) "demo:stat:processed" 5) "demo:stat:processed:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue" 6) "demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started" 7) "demo:workers" 8) "demo:worker:Mars.local:3820-4:JAVA_DYNAMIC_QUEUES,demoqueue:started" 9) "demo:worker:Mars.local:3820-2:JAVA_DYNAMIC_QUEUES,demoqueue:started"可以发现新增了两个stat相关的对象
namespace:stat:processed
是string类型，统计处理过的job的数量
127.0.0.1:6379> type demo:stat:processed string 127.0.0.1:6379> get demo:stat:processed "1"namespace:stat:processed:host:queueType,listen-queue
存储每个host处理每个queue的数量
127.0.0.1:6379> type demo:stat:processed:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue string 127.0.0.1:6379> get demo:stat:processed:Mars.local:3820-0:JAVA_DYNAMIC_QUEUES,demoqueue "1"关闭worker的时候
127.0.0.1:6379> keys * 1) "demo:queues" 2) "demo:stat:processed"就只剩下两个信息
job执行失败的时候
127.0.0.1:6379> keys * 1) "demo:stat:failed" 2) "demo:failed" 3) "demo:queues" 4) "demo:stat:processed" 5) "demo:worker:Mars.local:3947-2:JAVA_DYNAMIC_QUEUES,demoqueue:started" 6) "demo:worker:Mars.local:3947-3:JAVA_DYNAMIC_QUEUES,demoqueue:started" 7) "demo:worker:Mars.local:3947-1:JAVA_DYNAMIC_QUEUES,demoqueue:started" 8) "demo:worker:Mars.local:3947-4:JAVA_DYNAMIC_QUEUES,demoqueue:started" 9) "demo:worker:Mars.local:3947-0:JAVA_DYNAMIC_QUEUES,demoqueue:started" 10) "demo:workers" 11) "demo:stat:failed:Mars.local:3947-0:JAVA_DYNAMIC_QUEUES,demoqueue"可以发现多了三个failed相关的对象
@H_512_830@namespace:failed 是一个list类型
127.0.0.1:6379> type demo:failed list 127.0.0.1:6379> lrange demo:failed 0 -1 1) "{"worker"":""Mars.local:3947-0:JAVA_DYNAMIC_QUEUES脚本宝典总结
以上是脚本宝典为你收集整理的聊聊jesque在redis中的数据结构全部内容，希望文章能够帮你解决聊聊jesque在redis中的数据结构所遇到的问题。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。