在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:sdmq开源软件地址:https://gitee.com/peachyy/sdmq开源软件介绍:sdmqis a simple delay message queue, based on redis and kotlin 设计 https://www.cnblogs.com/peachyy/p/7398430.html
运行模式
推荐使用master slave的模式 Usage消息体以JSON数据格式参数 目前只提供了
添加任务/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 参数 清空队列数据根据日志中未完成的数据清空队列中全部数据
/clearAll GET 客户端获取队列方式目前默认实现了 消息体中消息与 |
sdmq | rocketMQ | 备注 |
---|---|---|
topic | topic | |
subtopic | tag | |
body | 消息内容 | 消息内容 |
重要
)TTL
机制定位是后期会改为基于kotlin
java
太多麻烦事了
需要配置好数据库地址和redis的地址 如果不是单机模式 也需要配置好zookeep
运行测试类io.sdmq.FixTest
添加任务到队列中
启动Bootstarp
消费前面添加数据 为了方便查询效果 默认的消费方式是consoleCQ
控制台输出
restful
清空队列数据jmsCQ
在不修改代码的情况下覆盖方式 -DClassName=xxxx
请发表评论