8 Star 18 Fork 14

虚线 / redismq

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

利用 redis 实现延迟消息队列。

├─redismq-common    //生产者和消费者公用代码,比如队列信息和redis配置信息
│  ├─src
│  │  ├─main
│  │  │  ├─java
│  │  │  │  └─com
│  │  │  │      └─sqlb
│  │  │  │          └─redismq
│  │  │  │              └─common
│  │  │  │                  ├─config    //存放mq的消费队列胚子信息
│  │  │  │                  ├─msmq      //核心mq代码
│  │  │  │                  └─utils     //操作redis的工具类
│  │  │  └─resources
│  │  │      └─configure
├─redismq-consumer      //消费者
│  ├─src
│  │  ├─main
│  │  │  ├─java
│  │  │  │  └─com
│  │  │  │      └─sqlb
│  │  │  │          └─redismq
│  │  │  │              └─consumer
│  │  │  │                  └─task   //包含定时任务,用来消费队列消息
│  │  │  └─resources
└─redismq-product       //生产者
    ├─src
    │  ├─main
    │  │  ├─java
    │  │  │  └─com
    │  │  │      └─sqlb
    │  │  │          └─redismq
    │  │  │              └─product
    │  │  │                  └─controller   //产生消息的生产者
    │  │  └─resources

实际上是利用了定时任务 @Scheduled(cron="*/5 * * * * *") 每隔5秒钟去redis服务中取出消费者发出的存储在redis中的消息,然后判断是否要消费。

空文件

简介

利用redis,实现延迟消息队列。 展开 收起
Java
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
Java
1
https://gitee.com/olysa/redismq.git
git@gitee.com:olysa/redismq.git
olysa
redismq
redismq
master

搜索帮助

53164aa7 5694891 3bd8fe86 5694891