依赖

<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>

如果没有rocketmq-spring-boot-starter这个依赖,可以 下载rocketmq-spring (opens new window)项目

将rocketmq-spring安装到本地仓库

mvn install -Dmaven.skip.test=true

配置

#多个NameServer的地址使用分号(;)分隔
rocketmq.name-server=192.168.1.200:9876
rocketmq.producer.group=spring-boot-rocketmq-topic

发送消息

@SpringBootApplication
public class MQProducerApplication {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public static void main(String[] args) {
        rocketMQTemplate.convertAndSend("springboot-mq","hello springboot rocketmq");
        SpringApplication.run(MQProducerApplication.class);
    }
}

接收消息

@Slf4j
@Component
@RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "#{rocketmq.producer.group}")
public class Consumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("Receive message："+message);
    }
}