SpringBoot集成RockMQ

<!--add dependency in pom.xml-->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>${RELEASE.VERSION}</version>
</dependency>

https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-spring-boot-starter

rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group

@Service
public class ProducerService{

    @Resource
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(String message) throws Exception {
          //send message synchronously
        rocketMQTemplate.convertAndSend("test-topic", message);
    }

}

@Slf4j
@Service
@RocketMQMessageListener(topic = "test-topic", 
consumerGroup = "my-group")
public class MessageConsumer implements RocketMQListener<String>{
    public void onMessage(String message) {
        log.info("received message: {}", message);
    }
}

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MQApplication {

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

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class TestSpringRocketMQ {

    @Autowired
    private ProducerService producerService;

    @Test
    public void testSendMessage() {
        producerService.sendMsg("Hello RocketMQ Message");
    }

}

官网：https://github.com/apache/rocketmq-spring