使用若依微服务版的maven项目中rocketMQ配置
1.Controller层配置（rocketMQ生产者）
@RequiredArgsConstructor
@RestController
@RequestMapping(“/”)
public class ApiController extends BaseController {

@Resource
RocketMQTemplate rocketMQTemplate;

@Value("${topic.topicName}")
public String topicName;

@ApiOperation("测试RocketMQ消息发送")
@PostMapping("/testMQ")
public R<Map<String, Object>> testMQ(@RequestBody String json) {
    SendResult sendResult = rocketMQTemplate.syncSend(topicName, json);
    return R.ok(JSONUtil.toJsonStr(sendResult));
}

}

2.rocketMQ 消费者
@Component
@RocketMQMessageListener(selectorExpression = “”, topic = “$topic.topicName",consumerGroup="${topic.consumerGroup}”)
@Slf4j
public class RocketMQConsumer implements RocketMQListener {

/**
 * 接收消息 处理
 *
 * @param message 消费的消息
 */
@Override
public void onMessage(String message) {
    log.info("接收的消费消息:" + message);
}

}

3.子模块中的pom

    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId>
    </dependency>

4.模块中的pom

		<dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>${rocketmq.version}</version>
        </dependency>
        
        <rocketmq.version>2.1.1</rocketmq.version>

5.Nacos中的rocketMQ配置

6.本地配置rocketMQ后可以自测试
本地安装配置MQ的环境变量后
先进入到D:\server\rocketmq\bin
两个窗口分别启动

A窗口：
start mqnamesrv.cmd
B窗口：
start mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

7.rocket本地配置环境变量
各环境变量配置



path配置