> RocketMQ支持同步(高可靠)、异步(低延迟)、单向(高吞吐)三种发送方式,分别适用于支付、链路及日志场景。 RocketMQ 的 Producer(生产者)发送消息主要有三种方式:同步发送(Sync)、异步发送(Async) 和 单向发送(One-way)。 这三种方式的主要区别在于 可靠性 和 性能(吞吐量/延迟)之间的权衡。 --- 1. 同步发送 (Synchronous Sending) 这是最常用的发送方式。生产者发出消息后,会阻塞当前线程,直到收到 Broker(消息服务器)的响应(ACK)或者超时,才继续执行后续代码。 特点: 可靠性高:只有收到 Broker 的确认才算发送成功,如果失败会抛出异常,便于处理重试机制。 性能:相对较低,因为需要等待网络往返(RTT)。 代码示例: 适用场景: 对数据可靠性要求非常高的场景。 例如:重要的通知邮件、短信通知、订单创建、支付结果等。 2. 异步发送 (Asynchronous Sending) 生产者发出消息后,不阻塞当前线程,立即返回。消息发送的结果(成功或失败)会通过回调接口(Callback) 在另一个线...