lightMQ
lightMQ copied to clipboard
由java构建的轻量级消息队列,支持订阅和点对点模式
lightMQ
由java构建的轻量级消息队列
特点
构建简单,纯java编写
使用方便,使用客户端可以直接通过注解监听
使用步骤
- 注册topic
- 如采用发布订阅方式,需要注册group
- 发送消息
- 消费消息
消费模式
- 非阻塞消费,无消息直接返回null
- 阻塞消费,无消息进入阻塞
生产模式
- 顺序生产,采用同步策略,速度较慢
- 非顺序生产,采用异步策略,速度较快
提供接口
- registerTopic 注册topic,传入topic
- registerGroup 注册group,传入topic和group
- produce 生产消息,传入topic,key,value,key可不传
- consume 消费消息,传入group,topic,group可不传,默认消费master
- getAllTopic 获取所有topic
客户端地址
https://github.com/stalary/lightMQ-client
部署方式
- 物理机启动
mvn clean install
java -jar target/lightmq-0.1.jar
- docker启动
docker run --rm --name lightmq -p 8001:8001 -d stalary/lightmq