RocketMQ

您所在的位置：网站首页 › mq事务性耗时 › RocketMQ

RocketMQ

2024-07-10 01:03| 来源: 网络整理| 查看: 265

RocketMQ-实战普通消息消息发送分类同步消息

同步消息发送是指，Producer发出消息后，需要收到MQ返回ACK之后才会发送下一条消息，该方式的消息可靠性最高，效率低

在这里插入图片描述

异步消息

异步发送消息是指，Producer发出消息后无需等待MQ返回ACK，直接发送下一条消息，该方式消息可靠性有保障，效率也可以

在这里插入图片描述

单向消息

单向发送是指，Producer只负责发消息，不等待，不处理MQ的ACK，MQ也不会返回ACK，该方式消息可靠性最低，效率最高

在这里插入图片描述

代码举例依赖引入

创建一个Maven工程，引入rocketmq依赖

org.apache.rocketmq rocketmq-client 4.9.0 同步消息

使用producer.send(msg);方法发送消息后，可得到一个SendResult返回值，这是同步发送消息

public class SyncProducer { public static void main(String[] args) throws MQClientException, RemotingException, InterruptedException, MQBrokerException { //创建一个producer，参数是Producer Group名称，多个Producer设置相同的Producer Group名称着是集群 DefaultMQProducer producer = new DefaultMQProducer("SyncProducer"); //指定nameServer地址 producer.setNamesrvAddr("192.168.100.101:9876"); //开启生产者 producer.start(); //生产并且发送100条消息 for (int i = 0; i

【本文地址】

RocketMQ

RocketMQ

今日新闻

推荐新闻