# lightMQ-client

**Repository Path**: wangxxxx/lightMQ-client

## Basic Information

- **Project Name**: lightMQ-client
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-04-13
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# lightMQ-client
lightMQ的客户端
使用步骤:
1. 注册topic或者group(默认生成master分组)
```
http://120.24.5.178:8001/registerTopic?topic=test
http://120.24.5.178:8001/registerGroup?topic=test&group=slave
```
2. 在需要使用的项目中使用maven引入
```
<dependency>
    <groupId>com.stalary</groupId>
    <artifactId>lightmqclient</artifactId>
    <version>0.0.1</version>
</dependency>
```
3. 实现MQConsumer接口，自定义消息处理，@MQListener设置需要监听的topic
```
@Component
public class MyConsumer implements MQConsumer {
    @Override
    @MQListener(topics = {"test"})
    public void process(MessageDto messageDto) {
        System.out.println("receive message: " + messageDto);
    }
}
```
4. 注入Producer生产者，进行消息的发送
```
@Resource
private Producer producer;
producer.send("test", "123");
```
5. 在application.properties中进行配置
```
com.stalary.lightmq.group=webflux // 消费分组，不配置则为消费默认分组
com.stalary.lightmq.url=http://120.24.5.178:8001 // 使用服务端的地址，建议自行构建lightmq
com.stalary.lightmq.consumer=false // 是否开启消费者，默认开启，适用于集群中的单点消费
com.stalary.lightmq.block=false // 是否阻塞模式消费，默认非阻塞
com.stalary.lightmq.order=false // 是否顺序生产消息，默认无序，采用异步消费
```