下載rocketmq-spring項(xiàng)目，項(xiàng)目下載地址https://github.com/apache/rocketmq，將rocketmq-spring安裝到本地倉(cāng)庫(kù)：

mvn install -Dmaven.skip.test=true

消息生產(chǎn)者

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）啟動(dòng)類

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

4）測(cè)試類

@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"); 
    }
}

消息消費(fèi)者

1）添加依賴
同消息生產(chǎn)者
2）配置文件
同消息生產(chǎn)者
3）啟動(dòng)類

@SpringBootApplication 
public class MQConsumerApplication { 

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

4）消息監(jiān)聽(tīng)器

@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); 
    } 
}