RocketMQ 消息队列深入浅出：掌握普通和同步消息

后端

2023-09-17 20:50:42

简介

消息队列是分布式系统中的重要组件，用于在松散耦合的系统之间异步传输消息。RocketMQ 是一个流行的消息队列平台，提供多种特性丰富的消息类型。

普通消息

普通消息是 RocketMQ 中最基本的类型，不具备特殊特性。它们适合于需要快速、可靠地传递消息的场景。

同步发送

同步发送意味着在发送方发出消息后，会等待服务端响应。这确保了消息已成功传送到服务器，但会增加延迟。

异步发送

与同步发送相反，异步发送不会等待服务端的响应。这可以提高发送方的吞吐量，但存在消息丢失的风险。

示例

以下是一个使用 Java 和 Spring Cloud Alibaba 发送普通消息的代码示例：

import com.aliyun.mq.rocketmq.cloud.autoconfigure.RocketMQProperties;
import com.aliyun.mq.rocketmq.cloud.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MessageController {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Autowired
    private RocketMQProperties rocketMQProperties;

    @PostMapping("/message")
    public String sendMessage(@RequestBody String message) {
        rocketMQTemplate.syncSend(rocketMQProperties.getTopic(), message);
        return "Message sent successfully";
    }
}