SpringBoot整合RocketMQ开发

下载rocketmq-spring项目，项目下载地址https://github.com/apache/rocketmq，将rocketmq-spring安装到本地仓库：

mvn install -Dmaven.skip.test=true

消息生产者

1）添加依赖

<parent> 
    <groupId>org.springframework.boot</groupId> 
    <artifactId>spring-boot-starter-parent</artifactId> 
    <version>2.0.1.RELEASE</version>
</parent>

<properties> 
    <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot- starter-version> 
</properties>

<dependencies> 
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId> 
        <version>${rocketmq-spring-boot-starter-version}</version> 
    </dependency>
    <dependency> 
        <groupId>org.projectlombok</groupId> 
        <artifactId>lombok</artifactId> 
        <version>1.18.6</version> 
    </dependency> 
    <dependency> 
        <groupId>org.springframework.boot</groupId> 
        <artifactId>spring-boot-starter-test</artifactId> 
        <scope>test</scope> 
    </dependency>
 </dependencies>

2）配置文件

# application.properties 
rocketmq.name-server=192.168.80.121:9876;192.168.80.122:9876 
rocketmq.producer.group=my-group

3）启动类

@SpringBootApplication 
public class MQProducerApplication { 
    public static void main(String[] args) { 
        SpringApplication.run(MQSpringBootApplication.class); 
    } 
}

4）测试类

@RunWith(SpringRunner.class) 
@SpringBootTest(classes = {MQSpringBootApplication.class}) 
public class ProducerTest { 
    @Autowired 
    private RocketMQTemplate rocketMQTemplate; 

    @Test public void test1(){ 
    rocketMQTemplate.convertAndSend("springboot-mq","hello springboot rocketmq"); 
    }
}

消息消费者

1）添加依赖
同消息生产者
2）配置文件
同消息生产者
3）启动类

@SpringBootApplication 
public class MQConsumerApplication { 

    public static void main(String[] args) { 
        SpringApplication.run(MQSpringBootApplication.class); 
    } 
}

4）消息监听器

@Slf4j 
@Component 
@RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1") 
public class Consumer implements RocketMQListener<String> { 
    @Override 
    public void onMessage(String message) { 
        log.info("Receive message："+message); 
    } 
}