springboot rocketmqtemplate

Spring Boot中使用RocketMQTemplate发送消息的步骤如下：
1. 在项目的pom.xml文件中引入RocketMQ的依赖：

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

2. 在启动类中设置RocketMQ的日志框架，可以通过在启动类的main方法中添加以下代码来指定使用Slf4j作为日志框架：

System.setProperty("rocketmq.client.logUseSlf4j", "true");

3. 在代码中使用RocketMQTemplate发送消息。可以通过创建一个RestController类，在其中使用RocketMQTemplate的实例发送消息。示例如下：

@RestController
public class NormalProduceController {
    @Autowired
    private RocketMQTemplate rocketmqTemplate;

    @GetMapping("/test")
    public SendResult test() {
        Message<String> msg = MessageBuilder.withPayload("Hello, RocketMQ").build();
        SendResult sendResult = rocketmqTemplate.send(topic, msg);
        return sendResult;
    }
}

以上是使用RocketMQTemplate发送消息的一般步骤。请注意，具体的配置和使用方法可能因项目的具体需求而有所不同。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [SpringBoot整合RocketMQ，高手都是这么玩的](https://blog.csdn.net/m0_68408835/article/details/130078951)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]