yangwenjie88/delay-queue

redis实现延迟消息队列

delay-queue's Issues

snowflake序列号时错误的

你多线程测试一下，就会发现很多冲突的。

是可以可考虑元信息不放在Redis里面？

DelayQueueJobPool.addDelayQueueJod(delayQueueJob);
这一步存储了 job 的元信息，是否可以考虑将这一步存放在DB里面：
1.Redis的容量这么宝贵，还易失?
2.如果一天添加到延迟的任务的量非常大怎么办？

后续扩展啥时候可以出

后续扩展啥时候可以出

为什么需要『再次确认延时时间是否到了』

看到设计中有这样的设计，想知道为什么！

多个客户端去轮训，会不会重复消费

重发的有更新吗？

重发的有更新吗？

请问可以单机redis部署吗，不走集群。

请问可以单机redis部署吗，不走集群。如果可以的话，需要修改哪些配置呢?

取出来的时候转换失败了

ScoredSortedItem{delayTime=15, delayQueueJodId=11223344} 在redis里的数据是这样的

取出来就报string 不能转ScoredSortedItem类

直接下载你的项目运行的，是redis版本的问题吗？我的是3.0的

主从节点redis，启动报错，应该怎么配置配置文件？

org.redisson.client.RedisConnectionException: Can't connect to servers!
at org.redisson.cluster.ClusterConnectionManager.(ClusterConnectionManager.java:135)
at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:237)
at org.redisson.Redisson.(Redisson.java:117)
at org.redisson.Redisson.create(Redisson.java:156)
at com.yangwenjie.delayqueue.utils.RedissonUtils.(RedissonUtils.java:29)
at com.yangwenjie.delayqueue.core.DelayBucket.getFromBucket(DelayBucket.java:33)
at com.yangwenjie.delayqueue.core.DelayBucketHandler.run(DelayBucketHandler.java:35)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

服务部署分布式集群，会不会出现问题呢