yangwenjie88 / delay-queue Goto Github PK
View Code? Open in Web Editor NEWredis实现延迟消息队列
delay-queue's People
Contributors
Stargazers
Watchers
Forkers
chenchi2038 williamjie hosken5 chenglinjava68 xiaomin0322 jossc ordinary2008 cpazstido luke202001 moxingwang flylee85 jasonbourn smll8402 sixgodx lovegrave xiongxianze penghaitao1519 javacodemood zclvip zhanglei ljwkevin eliauktm larscheng zmld hpulzl gitchenjh silzhan kaitezhan superliu213 googlemeoften zhuhjgithub will2love stormzhai kkchengxin wuleixxx danrui teakong cnszlzl rxyor iliushui wzzzzor godfaan wuliaozhiyuan foolishwall limboinf donic12 whatisspring cxplaycode hzchenyh liauraljl 345738842 caoran iqiuyu-0821 lp8608 qiuguozi jokeyfeng fengyajing strugglingbird 446541492 tianyiya biglogo yuweichen valley51 shineyeap wudt-github ilaotan ryanlilib redyoung86 pangziwudi shaofrooter xiaozhao1795 shuihuawu laughingnight blackcat308 liuhaiying-ops gitchong dearyh earther01 liuhui163 yuxiaom exhui shaojintian kwjcyr vinfai huoyouxian echohlne mojirml nerlcheng shadongjun jsiu93 xiaoyaobu sludge79 doublecherish 631536516 edwardzcy dadadafei augus-xu zhl007 280455936 ziyuruolandelay-queue's Issues
后续扩展啥时候可以出
后续扩展啥时候可以出
重发的有更新吗？
重发的有更新吗？
snowflake序列号时错误的
你多线程测试一下，就会发现很多冲突的。
主从节点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)
是可以可考虑元信息不放在Redis里面？
DelayQueueJobPool.addDelayQueueJod(delayQueueJob);
这一步存储了 job 的元信息，是否可以考虑将这一步存放在DB里面：
1.Redis的容量这么宝贵，还易失?
2.如果一天添加到延迟的任务的量非常大怎么办？
多个客户端去轮训，会不会重复消费
服务部署分布式集群，会不会出现问题呢
取出来的时候转换失败了
ScoredSortedItem{delayTime=15, delayQueueJodId=11223344} 在redis里的数据是这样的
取出来就报string 不能转ScoredSortedItem类
直接下载你的项目运行的，是redis版本的问题吗？我的是3.0的
为什么需要『再次确认延时时间是否到了』
看到设计中有这样的设计，想知道为什么！
请问可以单机redis部署吗，不走集群。
请问可以单机redis部署吗，不走集群。如果可以的话，需要修改哪些配置呢?
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.