RocketMQ
# 生产者
1. 普通消息
```
public void sendMessage(String topic, Object message) {
this.template.convertAndSend(topic, message);
log.info("普通消息发送完成：message = {}", message);
}
```
2. 同步消息
3. 异步消息
```
public String test(String message) {
Message<String> msg = MessageBuilder.withPayload(message).build();
String topic = "testtopic";
this.rocketmqTemplate.asyncSend(topic, message, new SendCallback() {
@Override
public void onSuccess(SendResult sendResult) {
//log.info("异步消息发送成功，message = {}, SendStatus = {}", message, sendResult.getSendStatus());Sys
System.out.println("异步消息发送成功"+ sendResult.getSendStatus());
}
@Override
public void onException(Throwable e) {
//log.info("异步消息发送异常，exception = {}", e.getMessage());
System.out.println("异步消息发送异常"+ e.getMessage());
}
});
return "发送成功";
}
```
4. 单向消息
5. 同步发送批量消息
6. 发送事务消息
7. 同步发送延时消息
8. 异步发送延时消息
9. 发送单向顺序消息
10. 同步发送顺序消息
# 消费者
# 保证消息可靠性
# 如何处理消息重复消费
# 如何处理消息堆积