问答 2023-07-31 来自:开发者社区

为啥用RocketMQ发消息,dashboard每次显示两条,但是只是会消费一次?

为啥用RocketMQ发消息,dashboard每次显示两条,但是只是会消费一次?是因为client和server版本不一致导致吗?服务端是5.1,客户端是5.0版本,该如何解决?

问答 2023-07-23 来自:开发者社区

RocketMQ为啥我发消息,dashboard每次显示两条,但是只是会消费一次?

RocketMQ为啥我发消息,dashboard每次显示两条,但是只是会消费一次?不知道是不是client和server版本不一致导致的?服务端是5.1,客户端是5.0版本

问答 2023-02-19 来自:开发者社区

rocketmq发消息,mqtt双向收消息这个功能怎么实现呢?

rocketmq发消息,mqtt双向收消息这个功能怎么实现呢?

文章 2022-12-17 来自:开发者社区

RocketMQ中生产者发消息前为啥一定要调用start()方法?

前言我们在使用RocketMQ发送消息时,一般都会使用DefaultMQProducer,类型的代码如下:DefaultMQProducer producer = new DefaultMQProducer("producer_group"); producer.setNamesrvAddr("42.192.50.8:9876"); try { producer.start(); ...

RocketMQ中生产者发消息前为啥一定要调用start()方法?
文章 2022-02-18 来自:开发者社区

RocketMQ入门到入土(六)发消息的时候选择queue的算法有哪些?(下)

2.2.1、不启用broker故障延迟既然sendLatencyFaultEnable默认是false,那就先看当sendLatencyFaultEnable=false时候的逻辑public MessageQueue selectOneMessageQueue(final String lastBrokerName) { // 第一次就是null,第二次(也就是重试的时候)就不是nul...

文章 2022-02-18 来自:开发者社区

RocketMQ入门到入土(六)发消息的时候选择queue的算法有哪些?(上)

一、说明分为两种,一种是直接发消息,client内部有选择queue的算法,不允许外界改变。还有一种是可以自定义queue的选择算法(内置了三种算法,不喜欢的话可以自定义算法实现)。public class org.apache.rocketmq.client.producer.DefaultMQProducer { // 只发送消息,queue的选择由默认的算法来实现 @Ove...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐