RocketMQTemplate 工具类
时间: 2024-05-13 14:17:19 浏览: 102
RocketMQTemplate 是 RocketMQ 官方提供的一个消息发送工具类,它封装了 RocketMQ 的核心 API,使得使用起来更加简单和方便。
RocketMQTemplate 提供了几个主要的方法:
1. convertAndSend:将 Java 对象转换为 RocketMQ 消息并发送。
2. send:发送 RocketMQ 消息。
3. syncSend:同步发送 RocketMQ 消息。
4. asyncSend:异步发送 RocketMQ 消息。
5. sendOneWay:单向发送 RocketMQ 消息。
使用 RocketMQTemplate 需要配置相应的 RocketMQ 生产者和消费者的属性,例如 NameServer 地址、Producer Group 名称、Consumer Group 名称等。在发送消息时,只需要指定 Topic 和消息内容即可。
以下是一个使用 RocketMQTemplate 发送消息的示例代码:
```java
@Autowired
private RocketMQTemplate rocketMQTemplate;
public void sendMessage(String topic, String message) {
rocketMQTemplate.convertAndSend(topic, message);
}
```
在上面的代码中,我们通过 @Autowired 注解注入了 RocketMQTemplate 对象,并调用其 convertAndSend 方法发送消息。其中,topic 是消息主题,message 是消息内容。
阅读全文