代码拉取完成,页面将自动刷新
is a simple delay message queue, based on redis and kotlin
设计 https://www.cnblogs.com/peachyy/p/7398430.html
一个简单、稳定、可扩展的延迟消息队列
sdmq.registry.serverList
zk集群地址列表redis
的 setNx
实现推荐使用master slave的模式
以JSON数据格式参数 目前只提供了http
协议
createTime
的间隔毫秒数/push
POST application/json
{"body":"{ffff}","delay":56600,"id":"20","status":0,"topic":"ces","subtopic":"",ttl":12}
删除任务 需要记录一个JobId
/delete?jobId=xxx
GET
用于任务错乱 脑裂情况 根据日志恢复任务
/reStoreJob?JobId=xxx
GET
根据日志恢复任务
/reStore?expire=true
GET
参数expire
表示是否需要恢复已过期还未执行的数据
根据日志中未完成的数据清空队列中全部数据
清空之后 会删除缓存中的所有任务
/clearAll
GET
目前默认实现了rocketmq
的推送方式。暂时就不用自己去实现推拉数据了。直接强依赖MQ。
rocketmq
消息字段对应关系sdmq | rocketMQ | 备注 |
---|---|---|
topic | topic | |
subtopic | tag | |
body | 消息内容 | 消息内容 |
重要
)TTL
机制定位是后期会改为基于kotlin
java
太多麻烦事了
需要配置好数据库地址和redis的地址 如果不是单机模式 也需要配置好zookeep
运行测试类io.sdmq.FixTest
添加任务到队列中
启动Bootstarp
消费前面添加数据 为了方便查询效果 默认的消费方式是consoleCQ
控制台输出
restful
清空队列数据jmsCQ
在不修改代码的情况下覆盖方式 -DClassName=xxxx
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。