RocketMQTemplate如何使用

RocketMQTemplate是 Boot集成RocketMQ的模板类，于简化RocketMQ的使用。通过RocketMQTemplate，我们可以方便地发送消息和接收消息。

RocketMQTemplate的步骤如下：
1. 配置RocketMQ的相关参数，包括NameServer地址、Producer和Consumer的组名等。
2. 在Spring的配置文件中配置RocketMQTemplate的相关属性。
3. 在需要发送消息的地方，注入RocketMQTemplate，并调用其send方法发送消息。
4. 在需要接收消息的地方，注入RocketMQTemplate，并使用@RocketMQMessageListener注解监听指定的Topic和Tag。

下面是一个简单的示例代码：

1. 配置RocketMQ的相关参数（application.properties）：

rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=myGroup
rocketmq.consumer.group=myGroup

2. 配置RocketMQTemplate（RocketMQConfig.java）：

@Configuration
public class RocketMQConfig {

    @Value("${rocketmq.name-server}")
    private String nameServer;

    @Value("${rocketmq.producer.group}")
    private String producerGroup;

    @Value("${rocketmq.consumer.group}")
    private String consumerGroup;

    @Bean
    public RocketMQTemplate rocketMQTemplate() {
        DefaultMQProducer producer = new DefaultMQProducer(producerGroup);
        producer.setNamesrvAddr(nameServer);
        RocketMQTemplate rocketMQTemplate = new RocketMQTemplate();
        rocketMQTemplate.setProducer(producer);
        return rocketMQTemplate;
    }

    @Bean
    public DefaultMQPushConsumer defaultMQPushConsumer() throws MQClientException {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerGroup);
        consumer.setNamesrvAddr(nameServer);
        consumer.subscribe("myTopic", "*");
        consumer.registerMessageListener(new MyMessageListener());
        consumer.start();
        return consumer;
    }
}

3. 发送消息（MessageSender.java）：

@Service
public class MessageSender {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(String message) {
        rocketMQTemplate.convertAndSend("myTopic", message);
    }
}

4. 接收消息（MyMessageListener.java）：

@Component
@RocketMQMessageListener(topic = "myTopic", consumerGroup = "myGroup")
public class MyMessageListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

以上是使用RocketMQTemplate发送和接收消息的基本步骤。你可以根据实际需求进行配置和使用。