# rocketmq-spring-boot-starter

**Repository Path**: runningcoder001/rocketmq-spring-boot-starter

## Basic Information

- **Project Name**: rocketmq-spring-boot-starter
- **Description**: 对rocketMQ进行的封装，自制starter，
追求优雅的使用方式
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 99
- **Created**: 2019-09-14
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

rocektmq-spring-boot-starter

# 使用
1. 引入依赖
```xml
<dependency>
    <groupId>.me.jollyfly</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>1.2.1.RELEASE</version>
</dependency>
```
2. 在配置类上添加@EnableRocket
```java
@SpringBootApplication
@EnableRocket
public class MyApp {

    public static void main(String[] args) {
        SpringApplication.run(MyApp.class,args);
    }
}
```
3. application.properties
```
rocketmq.name-srv-addr=localhost:9876
```

4. 创建监听
```java
@RocketListeners(topic = "MY_TOPIC")
public class MyListener {

    @RocketMQListener(messageClass = String.class,tag = "TAG_1")
    public void method1(String message){
        System.out.println(message);
    }

    @RocketMQListener(messageClass = Object.class,tag = "TAG_2")
    public void method2(Object message){
        System.out.println(message.toString());
    }

}
```

5. 使用说明
添加有@RocketListeners注解的类会自动转化为一个Consumer,类中不同的方法，通过RocketMQListener
注解，配置不同的tag消费不同tag的消息。


核心组件  RocketMessageListenerContainer
该组件是一个Consumer容器，容器实现了Spring的SmartLifecycle接口，容器的生命周期由Spring容器进行智能控制
系统中的所有Consumer的生命周期由该容器进行管理。容器可以对Consumer的消费行为进行控制和管理，同时提供Consumer
各个运行信息的获取接口。


# 扩展功能
增加钩子功能，通过实现InterceptorHookSupport.InterceptorPlugin 接口，可以实现在进入消费之前以及消费之后
   对方法进行拦截