# dbmq-spring-boot-starter

**Repository Path**: kenewstar/dbmq-spring-boot-starter

## Basic Information

- **Project Name**: dbmq-spring-boot-starter
- **Description**: 一个去中心化的基于数据库的消息队列组件
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-09-26
- **Last Updated**: 2024-10-15

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# dbmq-spring-boot-starter

#### 介绍
一个去中心化的基于数据库的消息队列组件

#### DbMq入门

> 当前支持MySQL、Mongo数据库，默认使用MySQL数据库

1. pom.xml依赖引入

   ```xml
   <dependency>
   	<groupId>io.gitee.kenewstar</groupId>
   	<artifactId>dbmq-spring-boot-starter</artifactId>
   	<version>1.0</version>
   </dependency>
   ```

2. 创建消费者

   ```java
   import io.gitee.kenewstar.dbmq.DbMqConsumer;
   import io.gitee.kenewstar.dbmq.DbMqConsumerInf;
   import io.gitee.kenewstar.dbmq.Message;
   
   import java.util.List;
   
   /**
    * @author kenewstar
    */
   @DbMqConsumer(topic = "mq_demo_test")
   public class DemoConsumer implements DbMqConsumerInf {
       
       @Override
       public void consume(List<Message> list) {
           System.out.println(list.size());
       }
       
   }
   ```

3. 引入生产者发送消息

   ```java
   import cn.hutool.core.lang.UUID;
   
   import io.gitee.kenewstar.dbmq.DbMqMessageProducer;
   import org.springframework.web.bind.annotation.GetMapping;
   import org.springframework.web.bind.annotation.RequestMapping;
   import org.springframework.web.bind.annotation.RestController;
   
   import javax.annotation.Resource;
   import java.util.ArrayList;
   import java.util.List;
   
   /**
    * @author kenewstar
    */
   @RestController
   @RequestMapping("mq")
   public class ProducerController {
   
       @Resource
       private DbMqMessageProducer messageProducer;
   
       @GetMapping("/send")
       public void sendMessage(String topic) {
           List<String> msg = new ArrayList<>();
           for (int i = 0; i < 758; i++) {
               msg.add("{\"demo\": \" "+ UUID.randomUUID() +" \"}");
           }
           messageProducer.sendMessage(topic, msg);
       }
   }
   ```

   当springboot启动后即可通过接口发送消息数据，接着控制台将打印消费的数据

#### 使用MySQL数据库

完整的pom.xml

```xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.14</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>io.gitee.kenewstar</groupId>
    <artifactId>springboot-dbmq</artifactId>
    <version>1.0</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.49</version>
        </dependency>

        <dependency>
            <groupId>io.gitee.kenewstar</groupId>
            <artifactId>dbmq-spring-boot-starter</artifactId>
            <version>1.0</version>
        </dependency>
    </dependencies>

</project>
```

> 或者不引入springboot-jdbc,只需要将DataSource对象交给Spring管理即可

修改application.yml文件

```yaml
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false&useTimezone=true&serverTimezone=Asia/Shanghai
    username: root
    password: kenewstar
    driver-class-name: com.mysql.jdbc.Driver

db-mq:
  type: mysql  # 默认值可以不配置
  heartbeatInterval: 120000  # 默认值可以不配置
```



#### 使用Mongo数据库

完整的pom.xml

```xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.14</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>io.gitee.kenewstar</groupId>
    <artifactId>springboot-dbmq</artifactId>
    <version>1.0</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

        <dependency>
            <groupId>io.gitee.kenewstar</groupId>
            <artifactId>dbmq-spring-boot-starter</artifactId>
            <version>1.0</version>
        </dependency>
    </dependencies>

</project>
```

修改application.yml文件

```yaml
spring:
  data:
    mongodb:
      host: 127.0.0.1
      port: 27017
      database: dbmq

db-mq:
  type: mongo
  heartbeatInterval: 120000
```