生产者

1. 添加依赖 ```xml <?xml version=”1.0” encoding=”UTF-8”?> 4.0.0

    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.5.6</version>
    <relativePath/> <!-- lookup parent from repository -->

   com.itheima producer 0.0.1-SNAPSHOT producer Demo project for Spring Boot

    <java.version>1.8</java.version>
   

   org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-test test org.apache.rocketmq rocketmq-spring-boot-starter 2.0.3 org.springframework.boot spring-boot-maven-plugin

2. 编写配置
> application.yml

```yaml
spring:
  application:
    name: producer
rocketmq:
  name-server: 192.168.31.130:9876
  producer:
    group: producer-group

1. 发送消息

   ProducerApplicationTests.java

package com.itheima.producer;

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ProducerApplicationTests {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    void testSend() {
        //发送消息，指定topic为：topic4， 指定tag为:tag2
        rocketMQTemplate.convertAndSend("topic4:tag2", "hello springboot rocket");
    }

}

消费者

1. 引入依赖 ```xml <?xml version=”1.0” encoding=”UTF-8”?> 4.0.0

    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.5.6</version>
    <relativePath/> <!-- lookup parent from repository -->
   

   com.itheima consumer 0.0.1-SNAPSHOT consumer Demo project for Spring Boot

    <java.version>1.8</java.version>
   

   org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-test test org.apache.rocketmq rocketmq-spring-boot-starter 2.0.3 org.springframework.boot spring-boot-maven-plugin

2. 编写配置文件
> application.yml

```yaml
spring:
  application:
    name: consumer
rocketmq:
  name-server: 192.168.31.130:9876
  producer:
    group: consumer-group

1. 编写监听器，监听消息 ```java package com.itheima.consumer.listener;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.core.RocketMQListener; import org.springframework.stereotype.Component;

/**

• 消费者实现
• 1.添加两个注解:
• @Component
• @RocketMQMessageListener()
• 参数：
• consumerGroup:消费者的组
• topic：要监听的主题
• selectorExpression: tag，二级消息类型，用来进一步区分某个Topic下的消息分类
  • 1. 实现接口
• RocketMQListener
• 复写方法onMessage *
• @author liqp
• @version 1.0
• @date 2021/11/15 / @Component @RocketMQMessageListener(consumerGroup = “group1”, topic = “topic4”, selectorExpression = ““) public class RocketListener implements RocketMQListener { @Override public void onMessage(String message) {

   System.out.println(message);
  

  } }

```